Home
last modified time | relevance | path

Searched defs:worker_address (Results 1 – 13 of 13) sorted by relevance

/external/tensorflow/tensorflow/core/data/service/
Djournal.proto31 string worker_address = 1; field
88 string worker_address = 3; field
97 string worker_address = 4; field
Ddispatcher_state_test.cc52 Status RegisterWorker(std::string worker_address, DispatcherState& state) { in RegisterWorker()
107 const std::string& worker_address, DispatcherState& state) { in CreateTask()
264 std::string worker_address = "test_worker_address"; in TEST() local
295 std::string worker_address = "test_worker_address"; in TEST() local
314 std::string worker_address = "test_worker_address"; in TEST() local
338 std::string worker_address = "test_worker_address"; in TEST() local
376 std::string worker_address = "test_worker_address"; in TEST() local
390 std::string worker_address = "test_worker_address"; in TEST() local
409 std::string worker_address = "test_worker_address"; in TEST() local
Dgrpc_worker_impl.cc34 Status GrpcWorkerImpl::Start(const std::string& worker_address, in Start()
Dcommon.proto32 string worker_address = 1; field
Ddispatcher.proto16 string worker_address = 1; field
27 string worker_address = 1; field
Ddispatcher_impl.cc211 const std::string& worker_address = request->worker_address(); in WorkerHeartbeat() local
542 const std::string& worker_address) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in CreateTasksForWorker()
587 std::shared_ptr<const Job> job, const std::string& worker_address) in CreatePendingTask()
604 const std::string& worker_address, in CreateTask()
630 const std::string& worker_address, WorkerService::Stub*& out_stub) in GetOrCreateWorkerStub()
Dserver_lib.cc134 std::string worker_address = str_util::StringReplace( in StartServiceInternal() local
Ddata_service.cc61 const std::string& worker_address, const std::string& transfer_address, in WorkerHeartbeat()
87 const std::string& worker_address, in WorkerUpdate()
Dworker_impl.cc67 Status DataServiceWorkerImpl::Start(const std::string& worker_address, in Start()
Ddispatcher_state.h162 const std::string worker_address; member
Ddispatcher_state.cc333 absl::string_view worker_address, in TasksForWorker()
/external/tensorflow/tensorflow/core/protobuf/
Dservice_config.proto37 string worker_address = 4; field
/external/tensorflow/tensorflow/python/data/experimental/service/
Dserver_lib.py245 worker_address=None, argument