| /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 | 238 void ListWorkers(std::vector<string>* workers) override { in ListWorkers() argument
240 cache->ListWorkers(workers); in ListWorkers()
245 std::vector<string>* workers) override { in ListWorkersInJob() argument
247 cache->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
304 void ListWorkers(std::vector<string>* workers) override { in ListWorkers() argument
305 workers->reserve(workers->size() + host_ports_.size()); in ListWorkers()
307 workers->emplace_back(MakeAddress(job_id_, id_host_port.first)); in ListWorkers()
312 std::vector<string>* workers) override { in ListWorkersInJob() argument
314 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/tensorflow/tensorflow/python/keras/engine/ |
| D | training_generator.py | 52 workers=1, argument
148 _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers,
160 workers=workers,
317 workers=workers,
379 def _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers, argument
412 if not is_sequence and use_multiprocessing and workers > 1:
502 workers=1, argument
509 if workers > 0:
516 enqueuer.start(workers=workers, max_queue_size=max_queue_size)
583 workers=1, argument
[all …]
|
| D | training_v2.py | 203 max_queue_size=10, workers=1, use_multiprocessing=False, **kwargs): argument
234 workers=workers,
402 workers=1, use_multiprocessing=False, **kwargs): argument
423 workers=workers,
483 workers=1, use_multiprocessing=False, **kwargs): argument
487 max_queue_size=max_queue_size, workers=workers,
491 callbacks=None, max_queue_size=10, workers=1, argument
496 workers=workers, use_multiprocessing=use_multiprocessing, **kwargs)
513 workers=1, argument
581 workers=workers,
[all …]
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 25 static struct worker *workers; variable
71 SAFE_PTHREAD_CREATE(&threads[i], NULL, worker, &workers[i]); in testrun()
95 workers = SAFE_MALLOC(sizeof(struct worker) * nthreads); in setup()
98 snprintf(workers[i].dir, sizeof(workers[i].dir), in setup()
100 SAFE_MKDIR(workers[i].dir, 0700); in setup()
108 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/ltp/testcases/kernel/fs/read_all/ |
| D | read_all.c | 81 static struct worker *workers; variable
289 struct worker *wa = workers; in spawn_workers()
291 memset(workers, 0, worker_count * sizeof(*workers)); in spawn_workers()
319 ret = queue_push(workers[i].q, buf); in work_push_retry()
337 if (!workers) in stop_workers()
341 if (workers[i].q) in stop_workers()
346 if (workers[i].q) { in stop_workers()
347 queue_destroy(workers[i].q, 0); in stop_workers()
348 workers[i].q = 0; in stop_workers()
387 workers = SAFE_MALLOC(worker_count * sizeof(*workers)); in setup()
[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 void ListWorkers(std::vector<string>* workers) const override { in ListWorkers() argument
33 return wrapped_->ListWorkers(workers); in ListWorkers()
36 std::vector<string>* workers) const override { 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/perfetto/infra/ci/ |
| D | Makefile | 95 .PHONY: stop-workers
96 stop-workers:
102 .PHONY: start-workers
103 start-workers: .deps/gce-template
120 .PHONY: restart-workers
121 restart-workers: stop-workers start-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()
50 [&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/python/cpython3/Lib/ |
| D | compileall.py | 51 quiet=0, legacy=False, optimize=-1, workers=1, argument
70 if workers < 0:
72 if workers != 1:
78 workers = 1
82 if workers != 1 and ProcessPoolExecutor is not None:
84 workers = workers or None
85 with ProcessPoolExecutor(max_workers=workers) as executor:
311 args.legacy, workers=args.workers,
|
| /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/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/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/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 150 worker.nextParkedWorker = workers[index] in <lambda>()
169 val worker = workers[index] ?: return null // stack is empty in <lambda>()
226 private val workers: Array<Worker?> = arrayOfNulls(maxPoolSize + 1) in <lambda>() constant in kotlinx.coroutines.scheduling.CoroutineScheduler
304 val created = synchronized(workers) { createdWorkers } in <lambda>()
307 val worker = workers[i]!! in <lambda>()
460 synchronized(workers) { in <lambda>()
472 require(newIndex > 0 && workers[newIndex] == null) in <lambda>()
475 workers[newIndex] = worker in <lambda>()
553 for (worker in workers) { in <lambda>()
856 synchronized(workers) { in <lambda>()
[all …]
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | runtest_mp.py | 314 def get_running(workers): argument
316 for worker in workers:
338 self.workers = None
341 self.workers = [TestWorkerProcess(index, self)
344 % len(self.workers))
345 for worker in self.workers:
350 for worker in self.workers:
352 for worker in self.workers:
356 if not any(worker.is_alive() for worker in self.workers):
377 running = get_running(self.workers)
[all …]
|
| /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/perfetto/src/trace_processor/importers/ninja/ |
| D | ninja_log_parser.cc | 154 auto& workers = workers_by_build[job.build_id]; in NotifyEndOfFile() local
155 for (Worker& cur : workers) { in NotifyEndOfFile()
170 snprintf(name, sizeof(name), "Worker %zu", workers.size() + 1); in NotifyEndOfFile()
175 workers.emplace_back(Worker{/*busy_until=*/job.end_ms, track_id}); in NotifyEndOfFile()
176 worker = &workers.back(); in NotifyEndOfFile()
|
| /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()
|