Method NewRequest

library/cpp/par/par_remote.cpp:318–334

    }

    void TRemoteQueryProcessor::TInitCmd::NewRequest(TRemoteQueryProcessor* p, TNetworkRequest* req) {
        CHROMIUM_TRACE_FUNCTION();

        if (!p->BaseSearcherAddrs.empty()) {
            ERROR_LOG << "Init called twice" << Endl;
            abort();
        }
        THostInitData initData;
        SerializeFromMem(&req->Data, initData);
        p->CompId = initData.CompId;
        p->MasterAddress = initData.MasterAddress;
        p->BaseSearcherAddrs = initData.BaseSearcherAddrs;
        p->LastCounts.resize(p->BaseSearcherAddrs.ysize(), TAtomicWrap(0));

        p->SendReply(req->ReqId, nullptr);
        PAR_DEBUG_LOG << "CompId " << p->CompId << " initialized" << Endl;
    }

    void TRemoteQueryProcessor::TPingCmd::NewRequest(TRemoteQueryProcessor* p, TNetworkRequest* req) {
        p->SendReply(req->ReqId, nullptr);