Method Start

tensorflow/contrib/elastic_grpc_server/elastic_grpc_server_lib.cc:221–242

}

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

Status ElasticGrpcServer::Join() {
  GrpcServer::Join();