Home
last modified time | relevance | path

Searched refs:pending_tasks (Results 1 – 4 of 4) sorted by relevance

/external/libchrome/base/test/
Dscoped_mock_time_message_loop_task_runner_unittest.cc35 TestPendingTask PopFront(base::circular_deque<TestPendingTask>* pending_tasks) { in PopFront() argument
36 TestPendingTask task = std::move(pending_tasks->front()); in PopFront()
37 pending_tasks->pop_front(); in PopFront()
101 base::circular_deque<TestPendingTask> pending_tasks = in TEST_F() local
104 EXPECT_EQ(2U, pending_tasks.size()); in TEST_F()
106 TestPendingTask pending_task = PopFront(&pending_tasks); in TEST_F()
112 pending_task = PopFront(&pending_tasks); in TEST_F()
/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state.cc160 job->pending_tasks.emplace(task, create_pending_task.starting_round()); in CreatePendingTask()
169 DCHECK(!job->pending_tasks.empty()); in ClientHeartbeat()
170 auto& task = job->pending_tasks.front(); in ClientHeartbeat()
181 job->pending_tasks.pop(); in ClientHeartbeat()
Ddispatcher_impl.cc719 if (!job->pending_tasks.empty()) { in ClientHeartbeat()
720 const auto& task = job->pending_tasks.front(); in ClientHeartbeat()
756 if (!job->pending_tasks.empty()) { in ClientHeartbeat()
757 response->set_block_round(job->pending_tasks.front().target_round); in ClientHeartbeat()
Ddispatcher_state.h145 std::queue<PendingTask> pending_tasks; member