Searched refs:worker_idx (Results 1 – 5 of 5) 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()
|
| /external/libaom/libaom/av1/common/ |
| D | thread_common.c | 617 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in loop_restoration_alloc() local
618 if (worker_idx < num_workers - 1) { in loop_restoration_alloc()
619 CHECK_MEM_ERROR(cm, lr_sync->lrworkerdata[worker_idx].rst_tmpbuf, in loop_restoration_alloc()
621 CHECK_MEM_ERROR(cm, lr_sync->lrworkerdata[worker_idx].rlbs, in loop_restoration_alloc()
625 lr_sync->lrworkerdata[worker_idx].rst_tmpbuf = cm->rst_tmpbuf; in loop_restoration_alloc()
626 lr_sync->lrworkerdata[worker_idx].rlbs = cm->rlbs; in loop_restoration_alloc()
676 for (int worker_idx = 0; worker_idx < num_workers - 1; worker_idx++) { in av1_loop_restoration_dealloc() local
678 lr_sync->lrworkerdata + worker_idx; in av1_loop_restoration_dealloc()
|
| /external/libaom/libaom/av1/decoder/ |
| D | decoder.c | 168 for (int worker_idx = 0; worker_idx < pbi->max_threads - 1; worker_idx++) { in av1_decoder_remove() local
169 DecWorkerData *const thread_data = pbi->thread_data + worker_idx; in av1_decoder_remove()
|
| D | decodeframe.c | 3780 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in reset_dec_workers() local
3781 AVxWorker *const worker = &pbi->tile_workers[worker_idx]; in reset_dec_workers()
3782 DecWorkerData *const thread_data = pbi->thread_data + worker_idx; in reset_dec_workers()
3808 for (int worker_idx = 0; worker_idx < num_workers; ++worker_idx) { in launch_dec_workers() local
3809 AVxWorker *const worker = &pbi->tile_workers[worker_idx]; in launch_dec_workers()
3815 if (worker_idx == num_workers - 1) { in launch_dec_workers()
3827 for (int worker_idx = num_workers; worker_idx > 0; --worker_idx) { in sync_dec_workers() local
3828 AVxWorker *const worker = &pbi->tile_workers[worker_idx - 1]; in sync_dec_workers()
3838 int worker_idx; in decode_mt_init() local
3848 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)
|