Home
last modified time | relevance | path

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

123

/aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/src/task/
Dspawn_pinned.rs87 .map(|worker| worker.task_count.load(Ordering::SeqCst)) in get_task_loads_for_each_worker()
307 let (worker, task_count) = self in find_and_incr_least_burdened_worker()
310 .map(|worker| (worker, worker.task_count.load(Ordering::SeqCst))) in find_and_incr_least_burdened_worker()
317 .task_count in find_and_incr_least_burdened_worker()
319 task_count, in find_and_incr_least_burdened_worker()
320 task_count + 1, in find_and_incr_least_burdened_worker()
326 return (worker, JobCountGuard(Arc::clone(&worker.task_count))); in find_and_incr_least_burdened_worker()
334 worker.task_count.fetch_add(1, Ordering::SeqCst); in find_worker_by_idx()
336 (worker, JobCountGuard(Arc::clone(&worker.task_count))) in find_worker_by_idx()
366 task_count: Arc<AtomicUsize>, field
[all …]
/aosp_15_r20/external/libchrome/base/message_loop/
H A 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::__anonbd03d7180211::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 …]
/aosp_15_r20/external/cronet/base/synchronization/
H A Dcondition_variable_unittest.cc84 int task_count() const;
116 void SpinUntilTaskCountLessThan(int task_count);
271 EXPECT_EQ(0, queue.task_count()); in TEST_F()
295 while (queue.task_count()) in TEST_F()
320 EXPECT_EQ(0, queue.task_count()); in TEST_F()
341 EXPECT_EQ(0, queue.task_count()); in TEST_F()
362 EXPECT_EQ(0, queue.task_count()); in TEST_F()
381 EXPECT_EQ(0, queue.task_count()); in TEST_F()
414 EXPECT_EQ(0, queue.task_count()); in TEST_F()
429 while (queue.task_count() != 0) in TEST_F()
[all …]
/aosp_15_r20/external/libchrome/base/synchronization/
H A 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 …]
/aosp_15_r20/external/cronet/base/message_loop/
H A Dmessage_pump_glib_unittest.cc252 int task_count = 0; in TEST_F() local
257 FROM_HERE, BindOnce(&IncrementInt, &task_count)); in TEST_F()
268 ASSERT_EQ(10, task_count); in TEST_F()
273 task_count = 0; in TEST_F()
276 FROM_HERE, BindOnce(&IncrementInt, &task_count), Milliseconds(10 * i)); in TEST_F()
291 ASSERT_EQ(10, task_count); in TEST_F()
356 int task_count() const { return task_count_; } in task_count() function in base::__anon64ced08e0211::ConcurrentHelper
397 EXPECT_EQ(0, helper->task_count()); in TEST_F()
470 int task_count = 0; in TestGLibLoopInternal() local
476 FROM_HERE, BindOnce(&IncrementInt, &task_count)); in TestGLibLoopInternal()
[all …]
/aosp_15_r20/external/linux-kselftest/tools/testing/selftests/futex/functional/
H A 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()
/aosp_15_r20/external/ruy/ruy/
H A Dthread_pool.cc214 void ThreadPool::ExecuteImpl(int task_count, int stride, Task* tasks) { in ExecuteImpl() argument
216 RUY_DCHECK_GE(task_count, 1); in ExecuteImpl()
219 if (task_count == 1) { in ExecuteImpl()
225 CreateThreads(task_count - 1); in ExecuteImpl()
226 count_busy_threads_.Reset(task_count - 1); in ExecuteImpl()
227 for (int i = 1; i < task_count; i++) { in ExecuteImpl()
H A 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);
/aosp_15_r20/external/cronet/net/base/
H A Dprioritized_task_runner.cc19 uint32_t task_count) in Job() argument
24 task_count(task_count) {} in Job()
81 return left.task_count > right.task_count; in operator ()()
H A Dprioritized_task_runner.h96 uint32_t task_count);
109 uint32_t task_count = 0; member
/aosp_15_r20/external/libchrome/base/test/
H A 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()
/aosp_15_r20/external/cronet/base/test/
H A Dsequenced_task_runner_test_template.cc62 int task_count) { in PostNonNestableTasks() argument
63 for (int i = 0; i < task_count; ++i) { in PostNonNestableTasks()
148 int task_count) { in CheckEventOrdersForEachTask() argument
156 for (int i = 0; i < task_count; ++i) { in CheckEventOrdersForEachTask()
236 int task_count) { in CheckNonNestableInvariants() argument
261 CheckEventOrdersForEachTask(events, task_count); in CheckNonNestableInvariants()
/aosp_15_r20/external/tensorflow/tensorflow/python/distribute/
H A Dmulti_worker_util.py45 def task_count(cluster_spec, task_type): function
95 if task_count(cluster_spec, "chief") > 1:
98 if task_count(cluster_spec, "evaluator") > 1:
102 if task_type in cluster_spec.jobs and task_id >= task_count(
/aosp_15_r20/packages/modules/UprobeStats/src/
DConfigResolver.cpp76 auto task_count = config.tasks().size(); in resolveSingleTask() local
77 if (task_count == 0) { in resolveSingleTask()
81 if (task_count > 1) { in resolveSingleTask()
82 LOG(ERROR) << "config has " << task_count in resolveSingleTask()
/aosp_15_r20/external/libchrome/base/task/sequence_manager/test/
H A 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()
/aosp_15_r20/external/cronet/base/task/sequence_manager/test/
H A Dsequence_manager_for_test.cc89 size_t task_count = 0; in PendingTasksCount() local
92 task_count += queue->GetNumberOfPendingTasks(); in PendingTasksCount()
94 return task_count; in PendingTasksCount()
/aosp_15_r20/external/rust/android-crates-io/crates/ash/src/extensions/nv/
Dmesh_shader.rs24 task_count: u32, in cmd_draw_mesh_tasks()
27 (self.fp.cmd_draw_mesh_tasks_nv)(command_buffer, task_count, first_task); in cmd_draw_mesh_tasks()
/aosp_15_r20/external/libchrome/base/task/sequence_manager/
H A 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()
/aosp_15_r20/hardware/google/gfxstream/third-party/astc-encoder/Source/
Dastcenc_internal_entry.h170 void init(unsigned int task_count) in init() argument
175 m_task_count = task_count; in init()
/aosp_15_r20/external/gemmlowp/internal/
H A 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()
/aosp_15_r20/external/tensorflow/tensorflow/core/kernels/batching_util/
H A Dbounded_executor_test.cc67 int task_count() { in task_count() function in tensorflow::serving::__anone063a9340111::TaskTracker
147 EXPECT_EQ(task_tracker.task_count(), num_tasks); in TEST()
/aosp_15_r20/external/cronet/base/task/
H A Djob_perftest.cc177 void DisruptivePostTasks(size_t task_count, TimeDelta delay) { in DisruptivePostTasks() argument
178 for (size_t i = 0; i < task_count; ++i) { in DisruptivePostTasks()
182 BindOnce(&DisruptivePostTasks, task_count, delay), in DisruptivePostTasks()
/aosp_15_r20/external/cronet/base/task/sequence_manager/
H A Dthread_controller_with_message_pump_impl_unittest.cc530 int task_count = 0; in TEST_F() local
534 EXPECT_EQ(5, task_count); in TEST_F()
538 task_source_.AddTask(FROM_HERE, BindLambdaForTesting([&] { task_count++; }), in TEST_F()
556 int task_count = 0; in TEST_F() local
560 EXPECT_EQ(1, task_count); in TEST_F()
567 EXPECT_EQ(2, task_count); in TEST_F()
569 EXPECT_EQ(3, task_count); in TEST_F()
576 if (!task_count++) in TEST_F()
H A Dtask_queue_impl.cc639 size_t task_count = 0; in GetNumberOfPendingTasks() local
640 task_count += main_thread_only().delayed_work_queue->Size(); in GetNumberOfPendingTasks()
641 task_count += main_thread_only().delayed_incoming_queue.size(); in GetNumberOfPendingTasks()
642 task_count += main_thread_only().immediate_work_queue->Size(); in GetNumberOfPendingTasks()
645 task_count += any_thread_.immediate_incoming_queue.size(); in GetNumberOfPendingTasks()
646 return task_count; in GetNumberOfPendingTasks()
/aosp_15_r20/external/tensorflow/tensorflow/core/profiler/convert/
H A Dop_stats_combiner.cc96 dst->set_task_count(src.task_count() + dst->task_count()); in CombineRunEnvironment()

123