| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_channel_test.cc | 93 std::vector<string> workers; in TEST() local
94 cc->ListWorkers(&workers); in TEST()
100 workers); in TEST()
104 std::vector<string> workers; in TEST() local
105 cc->ListWorkersInJob("mnist", &workers); in TEST()
111 workers); in TEST()
115 std::vector<string> workers; in TEST() local
116 cc->ListWorkersInJob("other", &workers); in TEST()
117 EXPECT_TRUE(workers.empty()); in TEST()
159 std::vector<string> workers; in TEST() local
[all …]
|
| D | grpc_channel.cc | 188 void ListWorkers(std::vector<string>* workers) override { in ListWorkers() argument
190 cache->ListWorkers(workers); in ListWorkers()
195 std::vector<string>* workers) override { in ListWorkersInJob() argument
197 cache->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
254 void ListWorkers(std::vector<string>* workers) override { in ListWorkers() argument
255 workers->reserve(workers->size() + host_ports_.size()); in ListWorkers()
257 workers->emplace_back(MakeAddress(job_id_, id_host_port.first)); in ListWorkers()
262 std::vector<string>* workers) override { in ListWorkersInJob() argument
264 ListWorkers(workers); in ListWorkersInJob()
|
| /external/libchrome/ipc/ |
| D | ipc_sync_channel_unittest.cc | 265 void RunTest(std::vector<Worker*> workers) { in RunTest() argument
268 for (size_t i = 0; i < workers.size(); ++i) { in RunTest()
269 if (workers[i]->mode() & Channel::MODE_SERVER_FLAG) { in RunTest()
270 workers[i]->Start(); in RunTest()
271 workers[i]->WaitForChannelCreation(); in RunTest()
276 for (size_t i = 0; i < workers.size(); ++i) { in RunTest()
277 if (workers[i]->mode() & Channel::MODE_CLIENT_FLAG) in RunTest()
278 workers[i]->Start(); in RunTest()
282 for (size_t i = 0; i < workers.size(); ++i) in RunTest()
283 workers[i]->done_event()->Wait(); in RunTest()
[all …]
|
| /external/ltp/testcases/kernel/io/direct_io/ |
| D | dma_thread_diotest.c | 134 static int workers; variable
231 workers = sysconf(_SC_NPROCESSORS_ONLN); in main()
232 if (workers > MAX_WORKERS) in main()
233 workers = MAX_WORKERS; in main()
260 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
270 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
277 worker[workers - 1].length = in dma_thread_diotest_verify()
278 READSIZE - PAGE_SIZE * (workers - 1); in dma_thread_diotest_verify()
288 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
298 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
[all …]
|
| /external/python/cpython3/Lib/ |
| D | compileall.py | 51 quiet=0, legacy=False, optimize=-1, workers=1, argument
70 if workers is not None:
71 if workers < 0:
73 elif workers != 1:
79 workers = 1
83 if workers is not None and workers != 1 and ProcessPoolExecutor is not None:
84 workers = workers or None
85 with ProcessPoolExecutor(max_workers=workers) as executor:
293 if args.workers is not None:
294 args.workers = args.workers or None
[all …]
|
| /external/ltp/testcases/kernel/fs/read_all/ |
| D | read_all.c | 93 static struct worker *workers; variable
283 struct worker *wa = workers; in spawn_workers()
285 bzero(workers, worker_count * sizeof(*workers)); in spawn_workers()
302 if (!workers) in stop_workers()
306 if (workers[i].q) in stop_workers()
307 TST_RETRY_FUNC(queue_push(workers[i].q, stop_code), 1); in stop_workers()
311 if (workers[i].q) { in stop_workers()
312 queue_destroy(workers[i].q, 0); in stop_workers()
313 workers[i].q = 0; in stop_workers()
325 TST_RETRY_FUNC(queue_push(workers[j].q, path), 1); in rep_sched_work()
[all …]
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 37 static struct worker *workers; variable
83 SAFE_PTHREAD_CREATE(&threads[i], NULL, worker, &workers[i]); in testrun()
107 workers = SAFE_MALLOC(sizeof(struct worker) * nthreads); in setup()
110 snprintf(workers[i].dir, sizeof(workers[i].dir), in setup()
112 SAFE_MKDIR(workers[i].dir, 0700); in setup()
120 free(workers); in cleanup()
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_performance_tests.py | 110 workers, argument
116 cmd = 'QPS_WORKERS="%s" ' % ','.join(workers)
140 def create_quit_jobspec(workers, remote_host=None): argument
144 w.host_and_port for w in workers)
295 workers = [(None, 10000), (None, 10010)]
298 workers = [(worker_hosts[0], 10000), (worker_hosts[0], 10010)]
301 workers = [(worker_host, 10000) for worker_host in worker_hosts]
311 for worker_idx, worker in enumerate(workers)
349 worker for workers in workers_by_lang.values() for worker in workers
377 workers = workers_by_lang[str(language)][:]
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | rpcbench_test.cc | 45 std::vector<string>* workers, in MakeGRPCCluster() argument
49 workers->clear(); in MakeGRPCCluster()
53 workers->push_back(strings::StrCat("grpc://localhost:", port[i])); in MakeGRPCCluster()
94 LOG(ERROR) << "W '" << (*workers)[0] << "'"; in MakeGRPCCluster()
96 options_copy.target = (*workers)[0]; in MakeGRPCCluster()
104 std::vector<string> workers; member
111 MakeGRPCCluster(options, kWorkers, &workers, &devices); in Cluster()
112 LOG(ERROR) << "C " << workers.size() << " " << devices.size() << " " in Cluster()
113 << workers[0] << " " << workers[1]; in Cluster()
114 options.target = workers[0]; in Cluster()
|
| D | worker_cache_wrapper.h | 32 virtual void ListWorkers(std::vector<string>* workers) const { in ListWorkers() argument
33 return wrapped_->ListWorkers(workers); in ListWorkers()
36 std::vector<string>* workers) const { in ListWorkersInJob() argument
37 return wrapped_->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
|
| D | test_utils.h | 135 void ListWorkers(std::vector<string>* workers) const override { in ListWorkers() argument
136 workers->clear(); in ListWorkers()
138 workers->push_back(it.first); in ListWorkers()
143 std::vector<string>* workers) const override { in ListWorkersInJob() argument
144 workers->clear(); in ListWorkersInJob()
150 workers->push_back(it.first); in ListWorkersInJob()
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | runtest_mp.py | 157 workers = [MultiprocessThread(pending, output, regrtest.ns)
160 % len(workers))
161 for worker in workers:
164 def get_running(workers): argument
166 for worker in workers:
187 running = get_running(workers)
207 running = get_running(workers)
232 running = [worker.current_test for worker in workers]
242 for worker in workers:
|
| /external/tensorflow/tensorflow/core/util/ |
| D | work_sharder.cc | 32 void Shard(int max_parallelism, thread::ThreadPool* workers, int64 total, in Shard() argument
44 if (max_parallelism >= workers->NumThreads()) { in Shard()
45 workers->ParallelFor(total, cost_per_unit, work); in Shard()
49 [&workers](Sharder::Closure c) { workers->Schedule(c); }, in Shard()
|
| D | work_sharder_test.cc | 66 for (auto workers : {0, 1, 2, 3, 5, 7, 10, 11, 15, 100, 1000}) { in TEST()
71 RunSharding(workers, total, cost_per_unit, maxp, &threads); in TEST()
80 for (auto workers : {1, 2, 3}) { in TEST()
84 Shard(workers, &threads, total_elements, cost_per_unit, in TEST()
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 102 VPxWorker workers[kNumWorkers]; in TEST_P() local
107 vpx_get_worker_interface()->init(&workers[n]); in TEST_P()
109 workers[n].hook = ThreadHook; in TEST_P()
110 workers[n].data1 = &hook_data[n]; in TEST_P()
111 workers[n].data2 = &return_value[n]; in TEST_P()
116 EXPECT_NE(vpx_get_worker_interface()->reset(&workers[n]), 0); in TEST_P()
121 Run(&workers[n]); in TEST_P()
125 vpx_get_worker_interface()->end(&workers[n]); in TEST_P()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | driver.cc | 223 auto workers = (!run_inproc) ? get_workers("QPS_WORKERS") : deque<string>(); in RunScenario() local
245 workers.push_front(addr); in RunScenario()
247 workers.push_back(addr); in RunScenario()
250 GPR_ASSERT(workers.size() != 0); in RunScenario()
255 num_clients = workers.size() - num_servers; in RunScenario()
261 GPR_ASSERT(workers.size() >= num_clients + num_servers); in RunScenario()
264 workers.resize(num_clients + num_servers); in RunScenario()
277 workers[i].c_str(), i); in RunScenario()
280 workers[i], GetCredentialsProvider()->GetChannelCredentials( in RunScenario()
314 host = get_host(workers[i]); in RunScenario()
[all …]
|
| /external/tensorflow/tensorflow/python/keras/engine/ |
| D | training_generator.py | 52 workers=1, argument
144 _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers,
156 workers=workers,
309 workers=workers,
374 def _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers, argument
407 if not is_sequence and use_multiprocessing and workers > 1:
497 workers=1, argument
504 if workers > 0:
511 enqueuer.start(workers=workers, max_queue_size=max_queue_size)
|
| D | training_generator_test.py | 84 workers=4,
104 workers=0)
123 workers=2,
134 workers=0)
149 workers=2,
158 workers=0)
163 workers=2,
172 workers=0)
294 workers=0,
301 workers=0,
|
| /external/autotest/client/site_tests/power_HotCPUSuspend/ |
| D | power_HotCPUSuspend.py | 73 workers = max(16, cpus * 2)
74 pool = multiprocessing.Pool(workers)
78 logging.info('starting %d workers', workers)
79 results = [pool.apply_async(cpu_stress) for _ in xrange(workers)]
104 logging.info('killing %d workers', workers)
|
| /external/tensorflow/tensorflow/python/keras/utils/ |
| D | data_utils.py | 494 self.workers = 0
503 def start(self, workers=1, max_queue_size=10): argument
512 self.executor_fn = self._get_executor_init(workers)
515 self.executor_fn = lambda _: ThreadPool(workers)
516 self.workers = workers
550 def _get_executor_init(self, workers): argument
589 def _get_executor_init(self, workers): argument
600 workers, initializer=init_pool_generator, initargs=(seqs, None))
706 def _get_executor_init(self, workers): argument
716 return multiprocessing.Pool(workers,
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | rdma_mgr.cc | 43 std::vector<string> workers; in RdmaMgr() local
45 &workers); in RdmaMgr()
46 num_remote_workers_ = workers.size() - 1; in RdmaMgr()
48 for (size_t i = 0; i < workers.size(); i++) { in RdmaMgr()
49 if (local_worker_.compare(workers[i]) != 0) { in RdmaMgr()
51 {workers[i], in RdmaMgr()
52 new RdmaChannel(rdma_adapter_, local_worker_, workers[i])}); in RdmaMgr()
|
| /external/autotest/client/tests/stress/ |
| D | control | 22 -c, --cpu N spawn N workers spinning on sqrt()
23 -i, --io N spawn N workers spinning on sync()
24 -m, --vm N spawn N workers spinning on malloc()/free()
29 -d, --hdd N spawn N workers spinning on write()/unlink()
31 --hdd-noclean do not unlink files created by hdd workers
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/util/ |
| D | VersionInfoTest.java | 370 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
374 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
375 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
379 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
380 workers[i].start(); in TestMultiThread()
384 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
386 workers[i].join(); in TestMultiThread()
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/util/ |
| D | VersionInfoTest.java | 373 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
377 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
378 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
382 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
383 workers[i].start(); in TestMultiThread()
387 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
389 workers[i].join(); in TestMultiThread()
|
| /external/tensorflow/tensorflow/contrib/opt/python/training/ |
| D | agn_optimizer_test.py | 48 workers = [
59 return cluster_dict, workers, ps_servers
64 def _get_workers(num_workers, period, workers, num_ps=1): argument
124 workers[worker_id].target, hooks=[hook])
142 _, workers, _ = create_local_cluster(num_workers=num_workers, num_ps=num_ps)
145 communication_period, workers)
203 _, workers, _ = create_local_cluster(num_workers=num_workers, num_ps=num_ps)
206 num_workers, communication_period, workers, num_ps=2)
|