Searched defs:worker_address (Results 1 – 17 of 17) sorted by relevance
| /external/tensorflow/tensorflow/core/data/service/ |
| D | common.proto | 31 string worker_address = 8; field
47 string worker_address = 1; field
|
| D | dispatcher_state_test.cc | 69 Status RegisterWorker(std::string worker_address, DispatcherState& state) { in RegisterWorker()
126 const std::string& worker_address, DispatcherState& state) { in CreateTask()
341 std::string worker_address = "test_worker_address"; in TEST() local
372 std::string worker_address = "test_worker_address"; in TEST() local
391 std::string worker_address = "test_worker_address"; in TEST() local
415 std::string worker_address = "test_worker_address"; in TEST() local
453 std::string worker_address = "test_worker_address"; in TEST() local
467 std::string worker_address = "test_worker_address"; in TEST() local
486 std::string worker_address = "test_worker_address"; in TEST() local
|
| D | journal.proto | 38 string worker_address = 1; field
118 string worker_address = 3; field
128 string worker_address = 4; field
|
| D | worker_impl.cc | 108 Status DataServiceWorkerImpl::Start(const std::string& worker_address, in Start()
482 void LocalWorkers::Add(absl::string_view worker_address, in Add()
491 absl::string_view worker_address) { in Get()
505 void LocalWorkers::Remove(absl::string_view worker_address) { in Remove()
|
| D | auto_shard_rewriter.cc | 93 absl::string_view worker_address) { in ShouldReplaceDynamicPort()
177 void WorkerIndexResolver::AddWorker(absl::string_view worker_address) { in AddWorker()
|
| D | grpc_worker_impl.cc | 42 Status GrpcWorkerImpl::Start(const std::string& worker_address, in Start()
|
| D | dispatcher_impl.cc | 243 const std::string& worker_address, in FindNewTasks()
279 const std::string& worker_address = request->worker_address(); in WorkerHeartbeat() local
657 const std::string& worker_address) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in CreateTasksForWorker()
702 std::shared_ptr<const Job> job, const std::string& worker_address) in CreatePendingTask()
719 const std::string& worker_address, in CreateTask()
745 const std::string& worker_address, WorkerService::Stub*& out_stub) in GetOrCreateWorkerStub()
|
| D | dispatcher_client.cc | 47 const std::string& worker_address, const std::string& transfer_address, in WorkerHeartbeat()
73 const std::string& worker_address, in WorkerUpdate()
|
| D | dispatcher.proto | 19 string worker_address = 1; field
32 string worker_address = 1; field
|
| D | server_lib.cc | 137 std::string worker_address = str_util::StringReplace( in StartServiceInternal() local
|
| D | worker_client.cc | 179 explicit LocalDataTransferClient(absl::string_view worker_address) in LocalDataTransferClient()
|
| D | task_runner.cc | 139 string worker_address) in RoundRobinTaskRunner()
|
| D | dispatcher_state.h | 194 const std::string worker_address; member
|
| D | dispatcher_state.cc | 408 absl::string_view worker_address, in TasksForWorker()
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | service_config.proto | 47 string worker_address = 4; field
|
| /external/tensorflow/tensorflow/python/data/experimental/service/ |
| D | server_lib.py | 255 worker_address=None, argument
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/service/ |
| D | test_base.py | 101 def worker_address(self): member in TestWorker
|