Searched refs:queue_type (Results 1 – 12 of 12) sorted by relevance
137 typedef detail::action_queue queue_type; typedef157 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 …]
27 typedef detail::action_queue queue_type; typedef95 queue_type::ensure(std::make_shared<new_worker>(keepAlive)); in new_worker()98 queue_type::destroy(); in new_worker()
127 typedef detail::action_queue queue_type; typedef in rxcpp::schedulers::run_loop143 queue_type::ensure(sc->create_worker_interface()); in run_loop()152 queue_type::destroy(); in ~run_loop()
47 typedef std::queue<T> queue_type; typedef48 typedef typename queue_type::size_type queue_size_type;80 queue_type items; in on_subscribe()
69 typedef std::deque<base_notification_type> queue_type; typedef84 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()
36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);101 QueueType queue_type() const { return queue_type_; } in queue_type() function
15 QueueType queue_type) in WorkQueue() argument16 : task_queue_(task_queue), name_(name), queue_type_(queue_type) {} in WorkQueue()
344 work_queue->queue_type()}; in TakeTask()
30 typedef std::deque<base_notification_type> queue_type; typedef44 mutable queue_type fill_queue;
54 __u32 queue_type; /* to KFD */ member
913 > queue_type; typedef in rxcpp::schedulers::detail::schedulable_queue915 queue_type q;