Method Start

tensorflow/contrib/star/star_server_base_lib.cc:366–389

}

Status StarServerBase::Start() {
  mutex_lock l(mu_);
  switch (state_) {
    case NEW: {
      master_thread_.reset(
          env_->StartThread(ThreadOptions(), "TF_master_service",
                            [this] { master_service_->HandleRPCsLoop(); }));
      state_ = STARTED;
      LOG(INFO) << "[Distributed] Started server with target: "
                << target();
      return Status::OK();
    }
    case STARTED:
      LOG(INFO) << "[Distributed] Server already started (target: "
                << target() << ")";
      return Status::OK();
    case STOPPED:
      return errors::FailedPrecondition(
          "[Distributed] Server has stopped.");
    default:
      LOG(FATAL);
  }
  return Status::OK();
}

Status StarServerBase::Stop() {
  mutex_lock l(mu_);