/external/libchrome/base/message_loop/ |
D | message_pump_glib_unittest.cc | 238 int task_count = 0; in TEST_F() local 243 BindOnce(&IncrementInt, &task_count)); in TEST_F() 254 ASSERT_EQ(10, task_count); in TEST_F() 259 task_count = 0; in TEST_F() 262 BindOnce(&IncrementInt, &task_count), in TEST_F() 278 ASSERT_EQ(10, task_count); in TEST_F() 343 int task_count() const { return task_count_; } in task_count() function in base::__anon48c769090211::ConcurrentHelper 384 EXPECT_EQ(0, helper->task_count()); in TEST_F() 459 int task_count = 0; in TestGLibLoopInternal() local 465 BindOnce(&IncrementInt, &task_count)); in TestGLibLoopInternal() [all …]
|
/external/libchrome/base/synchronization/ |
D | condition_variable_unittest.cc | 85 int task_count() const; 117 void SpinUntilTaskCountLessThan(int task_count); 280 EXPECT_EQ(0, queue.task_count()); in TEST_F() 304 while (queue.task_count()) in TEST_F() 329 EXPECT_EQ(0, queue.task_count()); in TEST_F() 350 EXPECT_EQ(0, queue.task_count()); in TEST_F() 371 EXPECT_EQ(0, queue.task_count()); in TEST_F() 390 EXPECT_EQ(0, queue.task_count()); in TEST_F() 429 EXPECT_EQ(0, queue.task_count()); in TEST_F() 444 while (queue.task_count() != 0) in TEST_F() [all …]
|
/external/linux-kselftest/tools/testing/selftests/futex/functional/ |
D | futex_requeue_pi.c | 148 int task_count = 0; in broadcast_wakerfn() local 171 task_count += args->ret; in broadcast_wakerfn() 172 if (task_count < THREAD_MAX - waiters_woken.val) in broadcast_wakerfn() 176 0, MAX_WAKE_ITERS, task_count, THREAD_MAX); in broadcast_wakerfn() 186 args->ret = task_count; in broadcast_wakerfn() 197 int task_count = 0; in signal_wakerfn() local 206 while (task_count < THREAD_MAX && waiters_woken.val < THREAD_MAX) { in signal_wakerfn() 208 task_count, waiters_woken.val); in signal_wakerfn() 235 task_count += args->ret; in signal_wakerfn() 250 args->ret = task_count; in signal_wakerfn()
|
/external/ruy/ruy/ |
D | thread_pool.cc | 167 void ThreadPool::ExecuteImpl(int task_count, int stride, Task* tasks) { in ExecuteImpl() argument 169 RUY_DCHECK_GE(task_count, 1); in ExecuteImpl() 172 if (task_count == 1) { in ExecuteImpl() 178 CreateThreads(task_count - 1); in ExecuteImpl() 179 counter_to_decrement_when_ready_.Reset(task_count - 1); in ExecuteImpl() 180 for (int i = 1; i < task_count; i++) { in ExecuteImpl()
|
D | thread_pool.h | 76 void Execute(int task_count, TaskType* tasks) { in Execute() argument 77 ExecuteImpl(task_count, sizeof(TaskType), static_cast<Task*>(tasks)); in Execute() 96 void ExecuteImpl(int task_count, int stride, Task* tasks);
|
/external/tensorflow/tensorflow/python/distribute/ |
D | multi_worker_util.py | 49 def task_count(cluster_spec, task_type): function 99 if task_count(cluster_spec, "chief") > 1: 102 if task_count(cluster_spec, "evaluator") > 1: 106 if task_type in cluster_spec.jobs and task_id >= task_count(
|
D | parameter_server_strategy_v2.py | 500 if multi_worker_util.task_count(cluster_spec, "ps") < 1: 503 if multi_worker_util.task_count(cluster_spec, "worker") < 1:
|
/external/libchrome/base/task/sequence_manager/test/ |
D | sequence_manager_for_test.cc | 63 size_t task_count = 0; in PendingTasksCount() local 65 task_count += queue->GetNumberOfPendingTasks(); in PendingTasksCount() 66 return task_count; in PendingTasksCount()
|
/external/libchrome/base/test/ |
D | sequenced_task_runner_test_template.cc | 61 int task_count) { in PostNonNestableTasks() argument 62 for (int i = 0; i < task_count; ++i) { in PostNonNestableTasks() 147 int task_count) { in CheckEventOrdersForEachTask() argument 155 for (int i = 0; i < task_count; ++i) { in CheckEventOrdersForEachTask() 235 int task_count) { in CheckNonNestableInvariants() argument 260 CheckEventOrdersForEachTask(events, task_count); in CheckNonNestableInvariants()
|
D | sequenced_task_runner_test_template.h | 57 void PostNonNestableTasks(SequencedTaskRunner* task_runner, int task_count); 111 int task_count);
|
/external/gemmlowp/internal/ |
D | multi_thread_gemm.h | 671 const int task_count = thread_count; in MultiThreadGemm() local 678 rows, cols, depth, task_count, context->l1_bytes_to_use(), in MultiThreadGemm() 695 for (int n = 0; n < task_count; ++n) { in MultiThreadGemm() 698 rows, RoundUp<KernelFormat::kRows>(rows * (n + 1) / task_count)); in MultiThreadGemm()
|
/external/tensorflow/tensorflow/core/profiler/convert/ |
D | op_stats_combiner.cc | 103 dst->set_task_count(src.task_count() + dst->task_count()); in CombineRunEnvironment()
|
D | xplane_to_op_stats_test.cc | 92 EXPECT_EQ(1, run_env.task_count()); in TEST()
|
D | op_stats_to_overview_page.cc | 294 re.set_task_count(run_environment.task_count()); in ComputeRunEnvironment()
|
/external/libchrome/base/task/sequence_manager/ |
D | task_queue_impl.cc | 377 size_t task_count = 0; in GetNumberOfPendingTasks() local 378 task_count += main_thread_only().delayed_work_queue->Size(); in GetNumberOfPendingTasks() 379 task_count += main_thread_only().delayed_incoming_queue.size(); in GetNumberOfPendingTasks() 380 task_count += main_thread_only().immediate_work_queue->Size(); in GetNumberOfPendingTasks() 383 task_count += immediate_incoming_queue().size(); in GetNumberOfPendingTasks() 384 return task_count; in GetNumberOfPendingTasks()
|
/external/tensorflow/tensorflow/core/profiler/protobuf/ |
D | op_stats.proto | 65 int32 task_count = 2; field
|
D | overview_page.proto | 166 int32 task_count = 2; field
|
/external/rust/crates/libc/src/unix/bsd/apple/ |
D | mod.rs | 698 pub task_count: ::c_int, 1392 self.task_count == other.task_count 1402 .field("task_count", &self.task_count) 1411 self.task_count.hash(state);
|