Method TMasterContext

catboost/private/libs/distributed/master.cpp:41–56

};

TMasterContext::TMasterContext(const NCatboostOptions::TSystemOptions& systemOptions) {
    Y_ASSERT(systemOptions.IsMaster());
    const ui32 unusedNodePort = NCatboostOptions::TSystemOptions::GetUnusedNodePort();

    // avoid Netliba
    NPar::TParNetworkSettings::GetRef().RequesterType = NPar::TParNetworkSettings::ERequesterType::NEH;
    TMasterEnvironment::GetRef().RootEnvironment = NPar::RunMaster(
        systemOptions.NodePort,
        systemOptions.NumThreads,
        systemOptions.FileWithHosts->c_str(),
        unusedNodePort,
        unusedNodePort);
    const int workerCount = TMasterEnvironment::GetRef().RootEnvironment->GetSlaveCount();
    const auto& workerMapping = TMasterEnvironment::GetRef().RootEnvironment->MakeHostIdMapping(workerCount);
    TMasterEnvironment::GetRef().SharedTrainData = TMasterEnvironment::GetRef().RootEnvironment->CreateEnvironment(SHARED_ID_TRAIN_DATA, workerMapping);
}

TMasterContext::~TMasterContext() {
    if (TMasterEnvironment::GetRef().RootEnvironment != nullptr) {