| /aosp_15_r20/external/tensorflow/tensorflow/core/data/service/ |
| H A D | dispatcher_state_test.cc | 77 Status RegisterWorker(std::string worker_address, DispatcherState& state) { in RegisterWorker()
135 const std::string& worker_address, DispatcherState& state) { in CreateTask()
406 std::string worker_address = "test_worker_address"; in TEST() local
438 std::string worker_address = "test_worker_address"; in TEST() local
470 std::string worker_address = "test_worker_address"; in TEST() local
489 std::string worker_address = "test_worker_address"; in TEST() local
513 std::string worker_address = "test_worker_address"; in TEST() local
551 std::string worker_address = "test_worker_address"; in TEST() local
565 std::string worker_address = "test_worker_address"; in TEST() local
584 std::string worker_address = "test_worker_address"; in TEST() local
|
| H A D | worker_impl.cc | 160 Status DataServiceWorkerImpl::Start(const std::string& worker_address, in Start()
605 void LocalWorkers::Add(absl::string_view worker_address, in Add()
614 absl::string_view worker_address) { in Get()
628 void LocalWorkers::Remove(absl::string_view worker_address) { in Remove()
|
| H A D | dispatcher_impl.cc | 302 const std::string& worker_address, in FindNewTasks()
338 const std::string& worker_address = request->worker_address(); in WorkerHeartbeat() local
779 const std::string& worker_address) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in CreateTasksForWorker()
828 const std::string& worker_address) TF_EXCLUSIVE_LOCKS_REQUIRED(mu_) { in CreatePendingTask()
849 const std::string& worker_address, std::shared_ptr<const Task>& task) in CreateTask()
877 const std::string& worker_address, WorkerService::Stub*& out_stub) in GetOrCreateWorkerStub()
|
| H A D | journal.proto | 41 string worker_address = 1; field
124 string worker_address = 3; field
136 string worker_address = 4; field
|
| H A D | common.proto | 37 string worker_address = 8; field
55 string worker_address = 1; field
|
| H A D | auto_shard_rewriter.cc | 80 absl::string_view worker_address) { in ShouldReplaceDynamicPort()
166 void WorkerIndexResolver::AddWorker(absl::string_view worker_address) { in AddWorker()
|
| H A D | dispatcher.proto | 19 string worker_address = 1; field
35 string worker_address = 1; field
|
| H A D | grpc_worker_impl.cc | 43 Status GrpcWorkerImpl::Start(const std::string& worker_address, in Start()
|
| H A D | server_lib.cc | 167 std::string worker_address = str_util::StringReplace( in StartServiceInternal() local
|
| H A D | worker_client.cc | 187 explicit LocalDataTransferClient(absl::string_view worker_address) in LocalDataTransferClient()
|
| H A D | task_runner.cc | 207 string worker_address) in RoundRobinTaskRunner()
|
| H A D | dispatcher_client.cc | 60 const std::string& worker_address, in WorkerUpdate()
|
| H A D | dispatcher_state.h | 217 const std::string worker_address; member
|
| H A D | dispatcher_state.cc | 458 absl::string_view worker_address, in TasksForWorker()
|
| /aosp_15_r20/external/perfetto/src/bigtrace/orchestrator/ |
| H A D | orchestrator_main.cc | 43 std::string worker_address; member
152 std::string worker_address = in OrchestratorMain() local
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/protobuf/ |
| H A D | service_config.proto | 59 string worker_address = 4; field
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/data/experimental/service/ |
| H A D | server_lib.py | 274 worker_address=None, argument
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/data/experimental/kernel_tests/service/ |
| H A D | test_base.py | 121 def worker_address(self): member in TestWorker
|