Home
last modified time | relevance | path

Searched refs:queue_type (Results 1 – 12 of 12) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp137 typedef detail::action_queue queue_type; typedef
157 queue_type::push(queue_type::item_type(now(), scbl)); in schedule()
161 queue_type::push(queue_type::item_type(when, scbl)); in schedule()
193 if (queue_type::owned()) { in schedule()
195 queue_type::get_worker_interface()->schedule(when, scbl); in schedule()
200 queue_type::ensure(std::make_shared<derecurser>()); in schedule()
204 queue_type::destroy(); in schedule()
207 const auto& recursor = queue_type::get_recursion().get_recurse(); in schedule()
212 if (queue_type::empty()) { in schedule()
218 auto next = queue_type::top().when; in schedule()
[all …]
Drx-newthread.hpp27 typedef detail::action_queue queue_type; typedef
91 queue_type::ensure(std::make_shared<new_worker>(keepAlive)); in new_worker()
94 queue_type::destroy(); in new_worker()
Drx-runloop.hpp127 typedef detail::action_queue queue_type; typedef in rxcpp::schedulers::run_loop
143 queue_type::ensure(sc->create_worker_interface()); in run_loop()
152 queue_type::destroy(); in ~run_loop()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-take_last.hpp47 typedef std::queue<T> queue_type; typedef
48 typedef typename queue_type::size_type queue_size_type;
80 queue_type items; in on_subscribe()
Drx-skip_last.hpp47 typedef std::queue<T> queue_type; typedef
48 typedef typename queue_type::size_type queue_size_type;
80 queue_type items; in on_subscribe()
Drx-observe_on.hpp69 typedef std::deque<base_notification_type> queue_type; typedef
84 mutable queue_type fill_queue;
85 mutable queue_type drain_queue;
105 queue_type fill_expired; in finish()
107 queue_type drain_expired; in finish()
/external/libchrome/base/task/sequence_manager/
Dwork_queue.h36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);
101 QueueType queue_type() const { return queue_type_; } in queue_type() function
Dwork_queue.cc15 QueueType queue_type) in WorkQueue() argument
16 : task_queue_(task_queue), name_(name), queue_type_(queue_type) {} in WorkQueue()
Dsequence_manager_impl.cc344 work_queue->queue_type()}; in TakeTask()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp30 typedef std::deque<base_notification_type> queue_type; typedef
44 mutable queue_type fill_queue;
/external/kernel-headers/original/uapi/linux/
Dkfd_ioctl.h53 __u32 queue_type; /* to KFD */ member
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-scheduler.hpp913 > queue_type; typedef in rxcpp::schedulers::detail::schedulable_queue
915 queue_type q;