| /external/ltp/testcases/kernel/fs/read_all/ |
| D | read_all.c | 78 static long worker_count; variable
291 memset(workers, 0, worker_count * sizeof(*workers)); in spawn_workers()
293 for (i = 0; i < worker_count; i++) { in spawn_workers()
310 worker_max = worker_count; in work_push_retry()
340 for (i = 0; i < worker_count; i++) { in stop_workers()
345 for (i = 0; i < worker_count; i++) { in stop_workers()
358 if (j >= worker_count) in rep_sched_work()
376 if (tst_parse_long(str_worker_count, &worker_count, 1, LONG_MAX)) { in setup()
385 if (!worker_count) in setup()
386 worker_count = MIN(MAX(tst_ncpus() - 1, 1), max_workers); in setup()
[all …]
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | multi_worker_util_test.py | 123 multi_worker_util.worker_count(cluster_spec, task_type="chief"), 3)
125 multi_worker_util.worker_count(cluster_spec, task_type="worker"), 3)
134 multi_worker_util.worker_count(cluster_spec, task_type="evaluator"), 1)
140 multi_worker_util.worker_count(cluster_spec, task_type="worker")
149 multi_worker_util.worker_count(cluster_spec, task_type="ps")
|
| D | multi_worker_util.py | 186 def worker_count(cluster_spec, task_type): function
|
| D | input_lib_test.py | 620 worker_count = multi_worker_util.worker_count(cr.cluster_spec(),
631 return dataset.shard(worker_count, id_in_cluster).batch(1)
681 worker_count = multi_worker_util.worker_count(cr.cluster_spec(),
692 return dataset.shard(worker_count, id_in_cluster).batch(1)
|
| D | parameter_server_strategy.py | 363 num_input_pipelines = multi_worker_util.worker_count(
384 num_input_pipelines = multi_worker_util.worker_count(
|
| D | collective_all_reduce_strategy.py | 422 self._num_workers = multi_worker_util.worker_count(cluster_spec, task_type)
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | ev_epollex_linux.cc | 285 gpr_atm worker_count; member
797 gpr_atm_no_barrier_store(&pollset->worker_count, 0);
873 int worker_count = gpr_atm_no_barrier_load(&pollset->worker_count); local
874 GPR_ASSERT(worker_count > 0);
876 (pollable_obj->event_count - pollable_obj->event_cursor) / worker_count;
1014 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, 1);
1095 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, -1);
|
| /external/angle/src/tests/ |
| D | capture_replay_tests.py | 832 worker_count = min(multiprocessing.cpu_count() - 1, args.max_jobs)
835 CreateTraceFolders(worker_count)
891 worker_count = min(worker_count, test_batch_num)
893 for worker_id in range(worker_count):
981 DeleteTraceFolders(worker_count)
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 112 worker_count = 5 variable in ExecutorMixin
121 max_workers=self.worker_count,
126 max_workers=self.worker_count,
148 for _ in range(self.worker_count)]
203 worker_count = 2 variable in InitializerMixin
214 for _ in range(self.worker_count)]
221 worker_count = 2 variable in FailingInitializerMixin
821 self.executor.map(str, [2] * (self.worker_count + 1))
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epollex_linux.cc | 260 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/ |
| D | test_futures.py | 137 worker_count = 5 variable in ExecutorMixin
142 self.executor = self.executor_type(max_workers=self.worker_count)
159 for _ in range(self.worker_count)]
|
| /external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/ |
| D | pod_tpu_driver.cc | 253 int worker_count = 0; in PodTpuDriver() local
270 drivers_.insert({worker_count, std::move(tpu_driver)}); in PodTpuDriver()
276 worker_count++; in PodTpuDriver()
|