Searched defs:worker_id (Results 1 – 13 of 13) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/integration_test/ |
| D | c_api_multi_client_test.cc | 35 int worker_id, int cluster_size)> in StartWorkers()
50 auto worker_thread_fn = [&](int worker_id) { in StartWorkers()
97 int cluster_size) { in TEST()
125 int cluster_size) { in TEST()
161 int cluster_size) { in TEST()
|
| D | c_api_session_coordination_test.cc | 83 for (int worker_id = 0; worker_id < num_workers; worker_id++) { in TEST_P() local
173 for (int worker_id = 0; worker_id < num_workers; worker_id++) { in TEST_P() local
|
| D | c_api_coordination_test.cc | 121 auto worker_thread_fn = [&](int worker_id) { in TEST()
188 auto worker_thread_fn = [&](int worker_id) { in TEST()
278 auto worker_thread_fn = [&](int worker_id) { in TEST()
349 auto worker_thread_fn = [&](int worker_id) { in TEST()
|
| D | c_api_multi_client_function_test.cc | 207 auto worker_thread_fn = [&](int worker_id) { in TEST_P()
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | multi_worker_continuous_run_test.py | 70 def worker_step_fn(worker_id): argument
103 def worker_step_fn(worker_id, num_dims): argument
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | bincount_op.cc | 68 [&](int64_t start_ind, int64_t limit_ind, int64_t worker_id) { in Compute()
141 [&](int64_t start_ind, int64_t limit_ind, int64_t worker_id) { in Compute()
181 [&](int64_t start_row, int64_t end_row, int64_t worker_id) { in Compute()
|
| /external/perfetto/src/trace_processor/importers/ninja/ |
| D | ninja_log_parser.cc | 155 uint32_t worker_id = static_cast<uint32_t>(workers.size()) + 1; in NotifyEndOfFile() local
|
| /external/perfetto/test/stress_test/ |
| D | stress_producer.cc | 111 void StressTestDataSource::Worker::WorkerMain(uint32_t worker_id) { in WorkerMain()
|
| /external/rust/crates/grpcio/src/ |
| D | cq.rs | 219 pub fn worker_id(&self) -> ThreadId { in worker_id() method
|
| /external/angle/src/tests/ |
| D | capture_replay_tests.py | 434 def SetWorkerId(self, worker_id): argument
799 def RunTests(args, worker_id, job_queue, result_list, message_queue, logger, ninja_lock): argument
|
| /external/linux-kselftest/tools/testing/selftests/bpf/ |
| D | test_progs.h | 88 int worker_id; /* id number of current worker, main process is -1 */ member
|
| D | test_progs.c | 933 int worker_id; member
|
| /external/tensorflow/tensorflow/python/distribute/coordinator/ |
| D | cluster_coordinator.py | 167 def _select_worker_slice(worker_id, structured): argument
|