Home
last modified time | relevance | path

Searched refs:task_count (Results 1 – 18 of 18) sorted by relevance

/external/libchrome/base/message_loop/
Dmessage_pump_glib_unittest.cc238 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/
Dcondition_variable_unittest.cc85 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/
Dfutex_requeue_pi.c148 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/
Dthread_pool.cc167 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()
Dthread_pool.h76 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/
Dmulti_worker_util.py49 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(
Dparameter_server_strategy_v2.py500 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/
Dsequence_manager_for_test.cc63 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/
Dsequenced_task_runner_test_template.cc61 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()
Dsequenced_task_runner_test_template.h57 void PostNonNestableTasks(SequencedTaskRunner* task_runner, int task_count);
111 int task_count);
/external/gemmlowp/internal/
Dmulti_thread_gemm.h671 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/
Dop_stats_combiner.cc103 dst->set_task_count(src.task_count() + dst->task_count()); in CombineRunEnvironment()
Dxplane_to_op_stats_test.cc92 EXPECT_EQ(1, run_env.task_count()); in TEST()
Dop_stats_to_overview_page.cc294 re.set_task_count(run_environment.task_count()); in ComputeRunEnvironment()
/external/libchrome/base/task/sequence_manager/
Dtask_queue_impl.cc377 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/
Dop_stats.proto65 int32 task_count = 2; field
Doverview_page.proto166 int32 task_count = 2; field
/external/rust/crates/libc/src/unix/bsd/apple/
Dmod.rs698 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);