Method ReceiveLoopFunc

library/cpp/par/par_network.cpp:412–437

    private:
        void ReceiveLoopFunc() {
            while (!Stopped) {
                THolder<NNetliba_v12::TUdpHttpRequest> nlReq(Requester->GetRequest());
                if (nlReq) {
                    QuickLZDecompress(&nlReq->Data);
                    PAR_DEBUG_LOG << "Got request " << nlReq->Url.data() << Endl;
                    TAutoPtr<TNetworkRequest> netReq = new TNetworkRequest;
                    netReq->ReqId = nlReq->ReqId;
                    netReq->Url = nlReq->Url;
                    netReq->Data = std::move(nlReq->Data);
                    QueryCallback(netReq);
                }
                TAutoPtr<NNetliba_v12::TUdpHttpResponse> answer = Requester->GetResponse();
                if (answer) {
                    TAutoPtr<TNetworkResponse> response = new TNetworkResponse;
                    ProcessUdpHttpResponse(answer, response);

                    ReplyCallback(response);
                }
                TGUID canceledReq;
                if (Requester->GetRequestCancel(&canceledReq)) {
                    QueryCancelCallback(canceledReq);
                }
                Requester->GetAsyncEvent().Wait();
            }
        }

        void ProcessUdpHttpResponse(TAutoPtr<NNetliba_v12::TUdpHttpResponse>& answer, TAutoPtr<TNetworkResponse>& response) {
            NNetliba_v12::AbortOnFailedRequest(answer.Get()); //LEGACY