Method TContextDistributor

library/cpp/par/par_context.cpp:184–193

    }

    TContextDistributor::TContextDistributor(TRemoteQueryProcessor* queryProc, TLocalDataBuffer* writeBuffer)
        : QueryProc(queryProc)
        , DistributionIsComplete(true)
        , QueryId(0)
        , ActiveReqCount(0)
        , WriteBuffer(writeBuffer)
    {
        SlaveCount = QueryProc.Get() ? QueryProc->GetSlaveCount() : 1;
        ComputerSendCount.resize(SlaveCount + 1, 0);
    }

    TContextDistributor::~TContextDistributor() {
        while (AtomicGet(ActiveReqCount))