Searched refs:next_task (Results 1 – 10 of 10) sorted by relevance
| /external/openscreen/third_party/chromium_quic/demo/ |
| D | server.cc | 118 auto& next_task = *it; in main() local
119 next_task.delay -= base::TimeDelta::FromMicroseconds( in main()
121 if (next_task.delay.InMicroseconds() < 0) { in main()
122 printf("task: %s\n", next_task.whence.ToString().c_str()); in main()
123 std::move(next_task.task).Run(); in main()
|
| D | client.cc | 112 auto& next_task = *it; in main() local
113 next_task.delay -= base::TimeDelta::FromMicroseconds( in main()
115 if (next_task.delay.InMicroseconds() < 0) { in main()
116 printf("task: %s\n", next_task.whence.ToString().c_str()); in main()
117 std::move(next_task.task).Run(); in main()
|
| /external/python/cpython3/Lib/asyncio/ |
| D | staggered.py | 99 next_task = loop.create_task(run_one_coro(this_failed))
100 running_tasks.append(next_task)
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task.rs | 89 let task = self.next_task(); in tick_max()
103 fn next_task(&self) -> task::Notified<Runtime> { in next_task() method
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 505 match self.next_task() { in tick()
525 fn next_task(&self) -> Option<task::Notified<Arc<Shared>>> { in next_task() method
|
| /external/webrtc/rtc_base/ |
| D | task_queue_win.cc | 385 const auto& next_task = timer_tasks_.top(); in ScheduleNextTimer() local
386 int64_t delay_ms = std::max(0ll, next_task.due_time() - GetTick()); in ScheduleNextTimer()
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner.h | 259 TestPendingTask* next_task);
|
| D | test_mock_time_task_runner.cc | 429 TestPendingTask* next_task) { in DequeueNextTask() argument
436 *next_task = std::move(const_cast<TestOrderedPendingTask&>(tasks_.top())); in DequeueNextTask()
|
| /external/llvm-project/openmp/runtime/src/ |
| D | kmp_tasking.cpp | 4167 kmp_task_t *next_task; in __kmp_taskloop_linear() local
4204 next_task = __kmp_task_dup_alloc(thread, task); // allocate new task in __kmp_taskloop_linear()
4205 kmp_taskdata_t *next_taskdata = KMP_TASK_TO_TASKDATA(next_task); in __kmp_taskloop_linear()
4207 kmp_taskloop_bounds_t(next_task, task_bounds); in __kmp_taskloop_linear()
4218 ptask_dup(next_task, task, lastpriv); in __kmp_taskloop_linear()
4222 gtid, i, next_task, lower, upper, st, in __kmp_taskloop_linear()
4226 __kmp_omp_taskloop_task(NULL, gtid, next_task, in __kmp_taskloop_linear()
4229 __kmp_omp_task(gtid, next_task, true); // schedule new task in __kmp_taskloop_linear()
4350 kmp_task_t *next_task; in __kmp_taskloop_recur() local
4381 next_task = __kmp_task_dup_alloc(thread, task); // duplicate the task in __kmp_taskloop_recur()
[all …]
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 317 if let Some(task) = core.next_task(&self.worker) { in run()
447 fn next_task(&mut self, worker: &Worker) -> Option<Notified> { in next_task() method
|