| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 111 def new_task(self, loop, coro, name='TestTask'): member in BaseTaskTests
120 self.loop.set_task_factory(self.new_task)
126 t = self.new_task(self.loop, coro())
139 t = self.new_task(self.loop, coro())
157 self.new_task(self.loop, run()) for _ in range(100)
188 t = self.new_task(self.loop, notmuch())
197 t = self.new_task(loop, notmuch())
244 t_orig = self.new_task(self.loop, notmuch())
343 t = self.new_task(self.loop, gen)
365 t = self.new_task(self.loop, notmuch())
[all …]
|
| /external/toolchain-utils/bestflags/ |
| D | steering.py | 110 for new_task in new_generation.Pool():
111 result_queue.put(new_task)
112 cache.add(new_task)
|
| D | hill_climb_best_neighbor.py | 101 new_task = Task(FlagSet(next_flag.values()))
103 if new_task not in cache:
104 children_tasks.add(new_task)
|
| D | iterative_elimination.py | 156 new_task = task.Task(flag_set)
157 if new_task not in cache:
158 results.add(new_task)
|
| D | testing_batch.py | 125 new_task = GATask(new_flag)
127 if new_task in tasks:
130 tasks.add(new_task)
|
| /external/adhd/cras/src/server/ |
| D | cras_server.c | 338 struct system_task *new_task; in add_task() local
344 new_task = (struct system_task *)calloc(1, sizeof(*new_task)); in add_task()
345 if (new_task == NULL) in add_task()
348 new_task->callback = cb; in add_task()
349 new_task->callback_data = callback_data; in add_task()
351 DL_APPEND(serv->system_tasks, new_task); in add_task()
|
| /external/llvm-project/openmp/runtime/test/tasking/ |
| D | bug_nested_proxy_task.c | 70 kmp_int32 __kmpc_omp_task_with_deps ( ident_t *loc_ref, kmp_int32 gtid, kmp_task_t * new_task,
74 __kmpc_omp_task( ident_t *loc_ref, kmp_int32 gtid, kmp_task_t * new_task );
|
| D | bug_proxy_task_dep_waiting.c | 67 kmp_int32 __kmpc_omp_task_with_deps ( ident_t *loc_ref, kmp_int32 gtid, kmp_task_t * new_task,
71 __kmpc_omp_task( ident_t *loc_ref, kmp_int32 gtid, kmp_task_t * new_task );
|
| /external/llvm-project/openmp/runtime/src/ |
| D | kmp_tasking.cpp | 1417 kmp_task_t *new_task, kmp_int32 naffins, in __kmpc_omp_reg_task_with_affinity() argument
1610 kmp_task_t *new_task) { in __kmpc_omp_task_parts() argument
1611 kmp_taskdata_t *new_taskdata = KMP_TASK_TO_TASKDATA(new_task); in __kmpc_omp_task_parts()
1634 if (__kmp_push_task(gtid, new_task) == TASK_NOT_PUSHED) // if cannot defer in __kmpc_omp_task_parts()
1638 __kmp_invoke_task(gtid, new_task, current_task); in __kmpc_omp_task_parts()
1647 ANNOTATE_HAPPENS_BEFORE(new_task); in __kmpc_omp_task_parts()
1667 kmp_int32 __kmp_omp_task(kmp_int32 gtid, kmp_task_t *new_task, in __kmp_omp_task() argument
1669 kmp_taskdata_t *new_taskdata = KMP_TASK_TO_TASKDATA(new_task); in __kmp_omp_task()
1674 __kmp_push_task(gtid, new_task) == TASK_NOT_PUSHED) // if cannot defer in __kmp_omp_task()
1679 __kmp_invoke_task(gtid, new_task, current_task); in __kmp_omp_task()
[all …]
|
| D | kmp_taskdeps.cpp | 509 kmp_task_t *new_task, kmp_int32 ndeps, in __kmpc_omp_task_with_deps() argument
514 kmp_taskdata_t *new_taskdata = KMP_TASK_TO_TASKDATA(new_task); in __kmpc_omp_task_with_deps()
605 if (__kmp_check_deps(gtid, node, new_task, ¤t_task->td_dephash, in __kmpc_omp_task_with_deps()
631 kmp_int32 ret = __kmp_omp_task(gtid, new_task, true); in __kmpc_omp_task_with_deps()
|
| D | kmp.h | 3723 kmp_task_t *new_task);
3740 kmp_task_t *new_task);
3758 ident_t *loc_ref, kmp_int32 gtid, kmp_task_t *new_task, kmp_int32 ndeps,
3766 extern kmp_int32 __kmp_omp_task(kmp_int32 gtid, kmp_task_t *new_task,
3794 ident_t *loc_ref, kmp_int32 gtid, kmp_task_t *new_task, kmp_int32 naffins,
|
| /external/python/cpython3/Lib/asyncio/ |
| D | base_events.py | 620 new_task = not futures.isfuture(future)
622 if new_task:
631 if new_task and future.done() and not future.cancelled():
|
| /external/llvm-project/lldb/tools/debugserver/source/MacOSX/ |
| D | MachProcess.mm | 2223 const task_t new_task =
2225 if (old_task != new_task)
2229 new_task);
|