Function TEST

oneflow/core/control/ctrl_test.cpp:58–82

#ifdef RPC_BACKEND_GRPC
TEST(CtrlServer, new_delete) {
  int port = CtrlUtil().FindAvailablePort();
  if (port == -1) { return; }
  EnvProto env_proto = GetEnvProto(port);
  Singleton<EnvDesc>::New(env_proto);
  Singleton<CtrlServer>::New();
  Singleton<ProcessCtx>::New();
  CHECK_JUST(
      HostListCtrlBootstrap(*Singleton<EnvDesc>::Get())
          .InitProcessCtx(Singleton<CtrlServer>::Get()->port(), Singleton<ProcessCtx>::Get()));
  auto* client = new GrpcCtrlClient(*Singleton<ProcessCtx>::Get());
  Singleton<CtrlClient>::SetAllocated(client);
  Singleton<ResourceDesc, ForEnv>::New(GetResource(), GlobalProcessCtx::NumOfProcessPerNode());
  Singleton<ResourceDesc, ForSession>::New(GetResource(), GlobalProcessCtx::NumOfProcessPerNode());

  // do test
  // OF_ENV_BARRIER();

  Singleton<ResourceDesc, ForSession>::Delete();
  Singleton<ResourceDesc, ForEnv>::Delete();
  Singleton<CtrlClient>::Delete();
  Singleton<ProcessCtx>::Delete();
  Singleton<CtrlServer>::Delete();
  Singleton<EnvDesc>::Delete();
}
#endif  // RPC_BACKEND_GRPC

}  // namespace oneflow