Method TRootEnvironment

library/cpp/par/par_host.cpp:34–53

/////////////////////////////////////////////////////////////////////

    //////////////////////////////////////////////////////////////////////////
    TRootEnvironment::TRootEnvironment(const char* hostsFileName, int defaultSlavePort, int masterPort, int debugPort) {
        Y_UNUSED(debugPort);
        TVector<TNetworkAddress> baseSearcherAddrs;
        {
            TFileInput queryFile(hostsFileName);
            TString host;
            while (queryFile.ReadLine(host)) {
                if (host.empty())
                    continue;
                baseSearcherAddrs.push_back(CreateAddress(host, defaultSlavePort));
            }
        }

        QueryProc = new TRemoteQueryProcessor();
        WriteBuffer = new TWriteBufferHandler(QueryProc.Get());
        QueryProc->RunMaster(baseSearcherAddrs, masterPort);

        ContextMaster = new TContextDistributor(QueryProc.Get(), WriteBuffer->GetWriteBuffer());
        Master = new TMaster(QueryProc.Get(), ContextMaster.Get());
    }

    TRootEnvironment::TRootEnvironment(TLocal) {
        WriteBuffer = new TWriteBufferHandler(nullptr);