Method LocalExec

library/cpp/par/par_remote.cpp:348–372

    }

    void TRemoteQueryProcessor::TRunPingCmd::LocalExec(int) {
        CHROMIUM_TRACE_FUNCTION();
        auto* requester = QueryProc->Requester.Get();
        TAllPingResults stats;
        float totalTime = 0;
        for (int i = 0; i < BaseSearcherAddrs.ysize() * 10; ++i) {
            int compId = RandomNumber(BaseSearcherAddrs.size());
            TVector<char> pingPkt;
            pingPkt.resize(100 * 1000);
            const TNetworkAddress& addr = BaseSearcherAddrs[compId];
            NHPTimer::STime tStart;
            NHPTimer::GetTime(&tStart);
            TAutoPtr<TNetworkResponse> answer = requester->Request(addr, "ping", &pingPkt);
            float ping = (float)NHPTimer::GetTimePassed(&tStart);
            stats.PingResults.push_back(TPingResult(compId, ping));

            totalTime += ping;
            if (totalTime > PING_ITERATION_TIME)
                break;
        }
        TVector<char> responseData;
        SerializeToMem(&responseData, stats);
        QueryProc->SendReply(ReqId, &responseData);
        QueryProc = nullptr;
    }
    void NPar::TRemoteQueryProcessor::TGatherStatsCmd::NewRequest(TRemoteQueryProcessor* p, TNetworkRequest* req) {
        TVector<char> tmp;
        SerializeToMem(&tmp, *Singleton<TParHostStats>());