Searched refs:immediate_work_queue (Results 1 – 5 of 5) sorted by relevance
120 immediate_work_queue(new WorkQueue(task_queue, in MainThreadOnly()172 std::unique_ptr<WorkQueue> immediate_work_queue = in UnregisterTaskQueue() local173 std::move(main_thread_only().immediate_work_queue); in UnregisterTaskQueue()330 if (!main_thread_only().immediate_work_queue->Empty()) in ReloadImmediateWorkQueueIfEmpty()333 main_thread_only().immediate_work_queue->ReloadEmptyImmediateQueue(); in ReloadImmediateWorkQueueIfEmpty()355 main_thread_only().immediate_work_queue->InsertFenceSilently( in ReloadEmptyImmediateQueue()368 !main_thread_only().immediate_work_queue->Empty()) { in IsEmpty()380 task_count += main_thread_only().immediate_work_queue->Size(); in GetNumberOfPendingTasks()390 !main_thread_only().immediate_work_queue->Empty()) { in HasTaskToRunImmediately()469 main_thread_only().immediate_work_queue->Size() + in TraceQueueSize()[all …]
240 WorkQueue* immediate_work_queue() { in immediate_work_queue() function241 return main_thread_only().immediate_work_queue.get(); in immediate_work_queue()244 const WorkQueue* immediate_work_queue() const { in immediate_work_queue() function245 return main_thread_only().immediate_work_queue.get(); in immediate_work_queue()351 std::unique_ptr<WorkQueue> immediate_work_queue; member
96 queue->immediate_work_queue()->AssignSetIndex(priority); in SetQueuePriority()121 immediate_work_queue_sets_.AddQueue(queue->immediate_work_queue(), priority); in AddQueue()135 immediate_work_queue_sets_.ChangeSetIndex(queue->immediate_work_queue(), in ChangeSetIndex()148 immediate_work_queue_sets_.RemoveQueue(queue->immediate_work_queue()); in RemoveQueue()284 queue->immediate_work_queue()); in CheckContainsQueueForTest()
111 task_queues_[queue_indices[i]]->immediate_work_queue()->Push( in PushTasks()124 task_queues_[queue_indices[i]]->immediate_work_queue()->Push( in PushTasksWithEnqueueOrder()319 EXPECT_TRUE(task_queues_[2]->immediate_work_queue()->Empty()); in TEST_F()329 EXPECT_FALSE(task_queues_[2]->immediate_work_queue()->Empty()); in TEST_F()747 task_queues_[0]->immediate_work_queue()->Push(TaskQueueImpl::Task( in TEST_F()756 EXPECT_EQ(chosen_work_queue, task_queues_[0]->immediate_work_queue()); in TEST_F()776 task_queue->immediate_work_queue()->Push(std::move(task)); in TEST_F()810 task_queue->immediate_work_queue()->Push(std::move(task1)); in TEST_F()811 task_queue2->immediate_work_queue()->Push(std::move(task2)); in TEST_F()853 task_queues_[0]->immediate_work_queue()->Push(TaskQueueImpl::Task( in TEST_P()
420 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->immediate_work_queue()->Empty()); in TEST_P()426 runners_[0]->GetTaskQueueImpl()->immediate_work_queue()->Empty()); in TEST_P()