Method GetRequest

library/cpp/netliba/v12/udp_http.cpp:1334–1345

///////////////////////////////////////////////////////////////////// TRequesterUserQueues

    //////////////////////////////////////////////////////////////////////////
    // TRequesterUserQueues
    TUdpHttpRequest* TRequesterUserQueues::GetRequest() {
        TLockFreeQueue<TUdpHttpRequest*>& rl = RequestListHighPiority.IsEmpty() ? RequestList : RequestListHighPiority;
        TUdpHttpRequest* res = nullptr;
        rl.Dequeue(&res);
        if (res) {
            AtomicAdd(QueueSizes->ReqCount, -1);
            AtomicAdd(QueueSizes->ReqQueueSize, -GetTransferSize(res->DataHolder.Get()));
        }
        UpdateAsyncSignalState();
        LoadRequestData(res);
        return res;
    }

    TUdpHttpResponse* TRequesterUserQueues::GetResponse() {
        TLockFreeQueue<TUdpHttpResponse*>& rl = ResponseListHighPiority.IsEmpty() ? ResponseList : ResponseListHighPiority;