Method Run

library/cpp/par/par_wb.cpp:48–74

                Ready.Signal();
        }
        void Run(TLocalDataBuffer* writeBuffer, TRemoteQueryProcessor* queryProc,
                 TVector<TVector<char>>* result) {
            CHROMIUM_TRACE_FUNCTION();
            Ready.Reset();

            int localCompId = queryProc ? queryProc->GetCompId() : -1;
            AtomicAdd(ReqCount, 1);
            for (THashMap<int, TWBCopyCompInfo>::iterator i = RequestHash.begin(); i != RequestHash.end(); ++i) {
                TWBCopyCompInfo& info = i->second;
                int compId = i->first;
                if (compId == localCompId) {
                    for (int j = 0; j < info.Data.ysize(); ++j) {
                        writeBuffer->GetData(info.Data[j], &Result[info.OriginalPlace[j]], TLocalDataBuffer::DO_COPY);
                    }
                } else {
                    TVector<char> buf;
                    SerializeToMem(&buf, info.Data);
                    AtomicAdd(ReqCount, 1);
                    queryProc->SendQuery(compId, "wb_copy", &buf, this, compId);
                }
            }
            if (AtomicAdd(ReqCount, -1) == 0)
                Ready.Signal();
            Ready.Wait();

            result->swap(Result);
        }
    };

    void CollectData(const TVector<TDataLocation>& data, TVector<TVector<char>>* res,