Method Create

tensorflow/c/experimental/network.cc:34–59

static */

namespace tensorflow {

/* static */ Status CGrpcServer::Create(
    const ServerDef& server_def,
    void* (*init_function)(const TF_GrpcServer*, TF_Status*),
    void (*start_function)(const TF_GrpcServer*, void*, TF_Status*),
    void (*stop_function)(const TF_GrpcServer*, void*, TF_Status*),
    void (*join_function)(const TF_GrpcServer*, void*, TF_Status*),
    void (*delete_function)(void*),
    TF_RemoteRendezvousBuilder* rendezvous_builder,
    std::unique_ptr<ServerInterface>* out_server) {
  auto* grpc_server = new CGrpcServer(server_def, start_function, stop_function,
                                      join_function, delete_function);

  GrpcServerOptions options;
  options.rendezvous_mgr_func = [rendezvous_builder](const WorkerEnv* env) {
    return new CRendezvousMgr(env, rendezvous_builder);
  };
  TF_RETURN_IF_ERROR(grpc_server->Init(options));
  TF_Status* tf_status = TF_NewStatus();
  grpc_server->SetContext(init_function(
      reinterpret_cast<const TF_GrpcServer*>(grpc_server), tf_status));
  TF_RETURN_IF_ERROR(tf_status->status);
  TF_DeleteStatus(tf_status);

  out_server->reset(grpc_server);
  return Status::OK();
}

Status CGrpcServer::Start() {
  Status status = GrpcServer::Start();