Searched refs:host_ports (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_channel.h | 40 HostPortsJob(const string& job_id, const std::map<int, string>& host_ports) in HostPortsJob()
41 : job_id(job_id), host_ports(host_ports) {} in HostPortsJob()
43 const std::map<int, string> host_ports; member
47 const std::vector<string>& host_ports);
50 const std::map<int, string>& host_ports);
|
| D | grpc_tensorflow_server.cc | 61 const std::vector<string> host_ports = str_util::Split(spec, ';'); in FillServerDef() local
62 for (size_t i = 0; i < host_ports.size(); ++i) { in FillServerDef()
63 (*job_def->mutable_tasks())[i] = host_ports[i]; in FillServerDef()
65 size_t num_tasks = host_ports.size(); in FillServerDef()
67 my_num_tasks = host_ports.size(); in FillServerDef()
70 << str_util::Join(host_ports, ", ") << "}"; in FillServerDef()
|
| D | grpc_channel.cc | 116 const std::vector<string>& host_ports) { in AddHostPortsJob() argument
118 for (size_t i = 0; i < host_ports.size(); ++i) { in AddHostPortsJob()
119 host_ports_map[i] = host_ports[i]; in AddHostPortsJob()
125 const string& job_id, const std::map<int, string>& host_ports) { in AddHostPortsJob() argument
130 for (const auto& id_host_port : host_ports) { in AddHostPortsJob()
133 host_ports_jobs_.emplace_back(job_id, host_ports); in AddHostPortsJob()
245 const std::map<int, string>& host_ports, in SparseGrpcChannelCache() argument
248 host_ports_(host_ports), in SparseGrpcChannelCache()
332 new SparseGrpcChannelCache(job.job_id, job.host_ports, channel_func)); in NewGrpcChannelCache()
|
| D | grpc_testlib_server.cc | 55 const std::vector<string> host_ports = str_util::Split(spec, ';'); in FillServerDef() local
56 uint32 tasks_per_replica = host_ports.size(); in FillServerDef()
57 for (size_t i = 0; i < host_ports.size(); ++i) { in FillServerDef()
58 (*job_def->mutable_tasks())[i] = host_ports[i]; in FillServerDef()
64 << str_util::Join(host_ports, ", ") << "}"; in FillServerDef()
|
| D | grpc_server_lib.cc | 285 std::map<int, string> host_ports; in ParseChannelSpec() local
287 string& host_port = host_ports[task.first]; in ParseChannelSpec()
300 TF_RETURN_IF_ERROR(channel_spec->AddHostPortsJob(job.name(), host_ports)); in ParseChannelSpec()
|