| 114 | } // namespace |
| 115 | |
| 116 | OneFlowEnv::OneFlowEnv() { |
| 117 | of::EnvProto env_proto; |
| 118 | CompleteEnvProto(env_proto); |
| 119 | |
| 120 | env_ctx_ = std::make_shared<of::EnvGlobalObjectsScope>(env_proto); |
| 121 | |
| 122 | of::ConfigProto config_proto; |
| 123 | config_proto.mutable_resource()->set_cpu_device_num(1); // useless, will be set in TryInit |
| 124 | const int64_t session_id = of::NewSessionId(); |
| 125 | config_proto.set_session_id(session_id); |
| 126 | CHECK(of::RegsterSessionId(session_id)); |
| 127 | session_ctx_ = std::make_shared<of::MultiClientSessionContext>(env_ctx_); |
| 128 | CHECK_JUST(session_ctx_->TryInit(config_proto)); |
| 129 | } |
| 130 | |
| 131 | OneFlowEnv::~OneFlowEnv() { |
| 132 | session_ctx_.reset(); |
nothing calls this directly
no test coverage detected