Method IncomingQueryCallbackImpl

library/cpp/par/par_remote.cpp:427–433

    }

    void TRemoteQueryProcessor::IncomingQueryCallbackImpl(TAutoPtr<TNetworkRequest>& nlReq) {
        CHROMIUM_TRACE_FUNCTION();

        PAR_DEBUG_LOG << "At " << Requester->GetHostAndPort() << " Got request " << nlReq->Url << " " << GetGuidAsString(nlReq->ReqId) << Endl;
        NetworkEventsQueue.Enqueue(TNetworkEvent(nlReq.Release()));
        NetworkEvent.Signal();
    }

    void TRemoteQueryProcessor::ReplyCallback(TAutoPtr<TNetworkResponse> response) {
        WaitUntilRequesterIsSet();