Home
last modified time | relevance | path

Searched refs:worker_count (Results 1 – 8 of 8) sorted by relevance

/external/ltp/testcases/kernel/fs/read_all/
Dread_all.c90 static long worker_count; variable
285 bzero(workers, worker_count * sizeof(*workers)); in spawn_workers()
287 for (i = 0; i < worker_count; i++) { in spawn_workers()
305 for (i = 0; i < worker_count; i++) { in stop_workers()
310 for (i = 0; i < worker_count; i++) { in stop_workers()
323 if (j >= worker_count) in rep_sched_work()
341 if (tst_parse_long(str_worker_count, &worker_count, 1, LONG_MAX)) { in setup()
350 if (!worker_count) in setup()
351 worker_count = MIN(MAX(tst_ncpus() - 1, 1), max_workers); in setup()
352 workers = SAFE_MALLOC(worker_count * sizeof(*workers)); in setup()
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_util_test.py115 multi_worker_util.worker_count(cluster_spec, task_type="chief"), 3)
117 multi_worker_util.worker_count(cluster_spec, task_type="worker"), 3)
126 multi_worker_util.worker_count(cluster_spec, task_type="evaluator"), 1)
132 multi_worker_util.worker_count(cluster_spec, task_type="worker")
141 multi_worker_util.worker_count(cluster_spec, task_type="ps")
Dmulti_worker_util.py104 def worker_count(cluster_spec, task_type): function
Dcollective_all_reduce_strategy.py174 self._num_workers = multi_worker_util.worker_count(cluster_spec, task_type)
Dparameter_server_strategy.py267 num_input_pipelines = multi_worker_util.worker_count(
/external/python/cpython3/Lib/test/
Dtest_concurrent_futures.py106 worker_count = 5 variable in ExecutorMixin
115 max_workers=self.worker_count,
120 max_workers=self.worker_count,
142 for _ in range(self.worker_count)]
197 worker_count = 2 variable in InitializerMixin
208 for _ in range(self.worker_count)]
215 worker_count = 2 variable in FailingInitializerMixin
695 self.executor.map(str, [2] * (self.worker_count + 1))
/external/grpc-grpc/src/core/lib/iomgr/
Dev_epollex_linux.cc260 gpr_atm worker_count; member
847 gpr_atm_no_barrier_store(&pollset->worker_count, 0);
921 int worker_count = gpr_atm_no_barrier_load(&pollset->worker_count); local
922 GPR_ASSERT(worker_count > 0);
924 (pollable_obj->event_count - pollable_obj->event_cursor) / worker_count;
1064 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, 1);
1145 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, -1);
/external/python/futures/
Dtest_futures.py137 worker_count = 5 variable in ExecutorMixin
142 self.executor = self.executor_type(max_workers=self.worker_count)
159 for _ in range(self.worker_count)]