Method ParseChannelSpec

tensorflow/contrib/star/star_server_base_lib.cc:311–355

}

Status StarServerBase::ParseChannelSpec(
    const WorkerCacheFactoryOptions& options,
    StarChannelSpec* channel_spec) {
  for (const auto& job : options.cluster_def->job()) {
    std::map<int, string> host_ports;
    for (const auto& task : job.tasks()) {
      string& host_port = host_ports[task.first];
      if (!host_port.empty()) {
        return errors::InvalidArgument(
            "[Distributed] JobDef for job \"",
            job.name(), "\" specified two addresses for task \"",
            task.first, "\": ", host_port, " and ", task.second);
      }
      if (job.name() == *options.job_name &&
          task.first == options.task_index) {
        host_port = strings::StrCat("localhost:", star_bound_port_);
      } else {
        host_port = task.second;
        std::string star_host_port;
        int grpc_port = -1;
        const auto& vec = str_util::Split(host_port, ':');
        if (vec.size() != 2 ||
            !strings::safe_strto32(vec[1], &grpc_port)) {
          LOG(ERROR) << "[Distributed] Error host port schema "
                     << host_port;
          return errors::Cancelled(
              "[Distributed] error host port schema ",
              host_port);
        }

        star_host_port = star_port_mgr_->GetStarIpPort(
            job.name(), task.first);
        LOG(INFO) << "[Distributed] host port: "
                  << host_port << ", remote star host port: "
                  << star_host_port;
        host_port = star_host_port;
      }
    }

    TF_RETURN_IF_ERROR(
        channel_spec->AddHostPortsJob(job.name(), host_ports));
  }

  return Status::OK();
}

size_t StarServerBase::ParseServers(
    const WorkerCacheFactoryOptions& options) {