Searched refs:transfer_address (Results 1 – 14 of 14) sorted by relevance
75 const std::string& transfer_address) in Worker()76 : address(address), transfer_address(transfer_address) {} in Worker()79 const std::string transfer_address; member154 const std::string& transfer_address) in Task()158 transfer_address(transfer_address) {} in Task()163 const std::string transfer_address; member
35 const std::string& transfer_address) { in Start() argument36 return impl_.Start(worker_address, transfer_address); in Start()
32 string transfer_address = 2; field89 string transfer_address = 4; field98 string transfer_address = 6; field
137 std::string transfer_address = worker_address; in StartServiceInternal() local145 transfer_address = in StartServiceInternal()150 TF_RETURN_IF_ERROR(service_->Start(worker_address, transfer_address)); in StartServiceInternal()
37 const std::string& transfer_address);
84 std::make_shared<Worker>(address, register_worker.transfer_address()); in RegisterWorker()159 create_pending_task.transfer_address()); in CreatePendingTask()193 create_task.transfer_address()); in CreateTask()
45 const std::string& transfer_address);
34 string transfer_address = 4; field
68 const std::string& transfer_address) { in Start() argument71 transfer_address_ = transfer_address; in Start()
91 const std::string& transfer_address,
61 const std::string& worker_address, const std::string& transfer_address, in WorkerHeartbeat() argument67 req.set_transfer_address(transfer_address); in WorkerHeartbeat()
222 request->transfer_address()); in WorkerHeartbeat()598 create_task->set_transfer_address(worker->transfer_address); in CreatePendingTask()615 create_task->set_transfer_address(worker->transfer_address); in CreateTask()765 task_info->set_transfer_address(task->transfer_address); in ClientHeartbeat()
17 string transfer_address = 3; field
469 task_info.transfer_address(), dataset()->protocol_, in AddTask()