Searched refs:high_prio_queue (Results 1 – 9 of 9) sorted by relevance
32 class high_prio_queue;58 deficit_type quantum(const high_prio_queue&, deficit_type x) { in quantum()65 class high_prio_queue : public drr_queue<inode_policy> { class75 inode_policy, high_prio_queue, nested_queue_type, nested_queue_type>;
142 connection_queue_t high_prio_queue; member468 if ((c= thread_group->high_prio_queue.front())) in queue_get()470 thread_group->high_prio_queue.remove(c); in queue_get()611 return (tg->high_prio_queue.is_empty() && in queues_are_empty()783 bool listener_picks_event= thread_group->high_prio_queue.is_empty() && in listener()797 thread_group->high_prio_queue.push_back(c); in listener()
140 connection_queue_t high_prio_queue; member459 if ((c= thread_group->high_prio_queue.front())) in queue_get()461 thread_group->high_prio_queue.remove(c); in queue_get()609 return (tg->high_prio_queue.is_empty() && in queues_are_empty()781 bool listener_picks_event= thread_group->high_prio_queue.is_empty() && in listener()795 thread_group->high_prio_queue.push_back(c); in listener()
405 auto high_prio_queue = in TEST_F() local407 high_prio_queue->SetQueuePriority(TaskQueue::kHighestPriority); in TEST_F()408 auto high_prio_runner = high_prio_queue->CreateTaskRunner(kTaskTypeNone); in TEST_F()
406 auto high_prio_queue = in TEST_F() local408 high_prio_queue->SetQueuePriority(TaskQueue::kHighestPriority); in TEST_F()409 auto high_prio_runner = high_prio_queue->CreateTaskRunner(kTaskTypeNone); in TEST_F()