Searched refs:worker_idx (Results 1 – 7 of 7) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | rpcbench_test.cc | 68 for (int worker_idx = 0; worker_idx < n; ++worker_idx) { in MakeGRPCCluster() local
69 worker_threads->Schedule([worker_idx, n, num_cpus, num_gpus, &port] { in MakeGRPCCluster()
73 server.set_task_index(worker_idx); in MakeGRPCCluster()
|
| D | collective_param_resolver_distributed_test.cc | 289 void RestartWorker(int worker_idx, int num_workers, int num_devices, in RestartWorker() argument
292 strings::StrCat("/job:worker/replica:0/task:", worker_idx); in RestartWorker()
|
| /external/libaom/libaom/av1/common/ |
| D | thread_common.c | 624 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in loop_restoration_alloc() local
625 if (worker_idx < num_workers - 1) { in loop_restoration_alloc()
626 CHECK_MEM_ERROR(cm, lr_sync->lrworkerdata[worker_idx].rst_tmpbuf, in loop_restoration_alloc()
628 CHECK_MEM_ERROR(cm, lr_sync->lrworkerdata[worker_idx].rlbs, in loop_restoration_alloc()
632 lr_sync->lrworkerdata[worker_idx].rst_tmpbuf = cm->rst_tmpbuf; in loop_restoration_alloc()
633 lr_sync->lrworkerdata[worker_idx].rlbs = cm->rlbs; in loop_restoration_alloc()
683 for (int worker_idx = 0; worker_idx < num_workers - 1; worker_idx++) { in av1_loop_restoration_dealloc() local
685 lr_sync->lrworkerdata + worker_idx; in av1_loop_restoration_dealloc()
|
| /external/libaom/libaom/av1/decoder/ |
| D | decoder.c | 188 for (int worker_idx = 0; worker_idx < pbi->max_threads - 1; worker_idx++) { in av1_decoder_remove() local
189 DecWorkerData *const thread_data = pbi->thread_data + worker_idx; in av1_decoder_remove()
|
| D | decodeframe.c | 3402 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in reset_dec_workers() local
3403 AVxWorker *const worker = &pbi->tile_workers[worker_idx]; in reset_dec_workers()
3404 DecWorkerData *const thread_data = pbi->thread_data + worker_idx; in reset_dec_workers()
3431 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in launch_dec_workers() local
3432 AVxWorker *const worker = &pbi->tile_workers[worker_idx]; in launch_dec_workers()
3438 if (worker_idx == num_workers - 1) { in launch_dec_workers()
3450 for (int worker_idx = num_workers; worker_idx > 0; --worker_idx) { in sync_dec_workers() local
3451 AVxWorker *const worker = &pbi->tile_workers[worker_idx - 1]; in sync_dec_workers()
3461 int worker_idx; in decode_mt_init() local
3471 for (worker_idx = 0; worker_idx < num_threads; ++worker_idx) { in decode_mt_init()
[all …]
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_performance_tests.py | 306 shortname='qps_worker_%s_%s' % (language, worker_idx),
311 for worker_idx, worker in enumerate(workers)
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_performance_tests.py | 315 (language, worker_idx),
320 for worker_idx, worker in enumerate(workers)
|