Home
last modified time | relevance | path

Searched defs:worker_id (Results 1 – 25 of 30) sorted by relevance

12

/external/tensorflow/tensorflow/core/distributed_runtime/integration_test/
Dc_api_multi_client_test.cc35 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()
Dc_api_session_coordination_test.cc83 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
Dc_api_coordination_test.cc121 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()
Dc_api_multi_client_function_test.cc207 auto worker_thread_fn = [&](int worker_id) { in TEST_P()
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_continuous_run_test.py70 def worker_step_fn(worker_id): argument
103 def worker_step_fn(worker_id, num_dims): argument
/external/pytorch/torch/utils/data/
Dbackward_compatibility.py10 def worker_init_fn(worker_id): argument
Ddataloader.py104 def _sharding_worker_init_fn(worker_init_fn, world_size, rank_id, worker_id): argument
1494 def _mark_worker_as_unavailable(self, worker_id, shutdown=False): argument
/external/pytorch/torch/csrc/distributed/autograd/
Dinit.cpp105 [](int64_t worker_id) { in dist_autograd_init()
128 [](int64_t worker_id) { DistAutogradContainer::init(worker_id); }, in dist_autograd_init()
/external/pytorch/torch/utils/data/_utils/
Dworker.py178 def _generate_state(base_seed, worker_id): argument
241 worker_id, argument
/external/pytorch/torch/csrc/distributed/autograd/context/
Dcontainer.cpp36 DistAutogradContainer& DistAutogradContainer::init(int64_t worker_id) { in init()
242 for (const auto& worker_id : workerIds) { in sendReleaseContextRpc() local
/external/tensorflow/tensorflow/core/kernels/
Dbincount_op.cc68 [&](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/pytorch/test/distributed/elastic/timer/
Dapi_test.py50 def _reap_worker(self, worker_id): argument
/external/pytorch/test/cpp/dist_autograd/
Dtest_dist_autograd.cpp42 rpc::worker_id_t worker_id = 1; in TEST_F() local
/external/perfetto/src/trace_processor/importers/ninja/
Dninja_log_parser.cc163 uint32_t worker_id = static_cast<uint32_t>(workers.size()) + 1; in NotifyEndOfFile() local
/external/kernel-headers/original/uapi/linux/
Dvhost_types.h56 unsigned int worker_id; member
63 unsigned int worker_id; member
/external/perfetto/test/stress_test/
Dstress_producer.cc111 void StressTestDataSource::Worker::WorkerMain(uint32_t worker_id) { in WorkerMain()
/external/crosvm/virtio_sys/src/
Dvhost.rs94 pub worker_id: ::std::os::raw::c_uint, field
100 pub worker_id: ::std::os::raw::c_uint, field
/external/rust/android-crates-io/crates/grpcio/src/
Dcq.rs219 pub fn worker_id(&self) -> ThreadId { in worker_id() method
/external/googleapis/google/dataflow/v1beta3/
Denvironment.proto233 string worker_id = 5; field
/external/google-cloud-java/java-dataflow/proto-google-cloud-dataflow-v1beta3/src/main/proto/google/dataflow/v1beta3/
Denvironment.proto233 string worker_id = 5; field
/external/pytorch/test/
Dtest_dataloader.py842 def disable_stderr(worker_id): argument
1028 def _test_worker_info_init_fn(worker_id): argument
1092 def init_fn(worker_id): argument
3389 def worker_init_fn(self, worker_id): argument
/external/google-cloud-java/java-tpu/proto-google-cloud-tpu-v1/src/main/proto/google/cloud/tpu/v1/
Dcloud_tpu.proto619 string worker_id = 4; field
/external/googleapis/google/cloud/tpu/v1/
Dcloud_tpu.proto619 string worker_id = 4; field
/external/googleapis/google/cloud/tpu/v2/
Dcloud_tpu.proto782 string worker_id = 4; field
/external/google-cloud-java/java-tpu/proto-google-cloud-tpu-v2/src/main/proto/google/cloud/tpu/v2/
Dcloud_tpu.proto775 string worker_id = 4; field

12