Function LoadRequestData

library/cpp/netliba/v12/udp_http.cpp:1240–1286

    }

    static void LoadRequestData(TUdpHttpRequest* res) {
        if (!res)
            return;
        {
            TBlockChainIterator reqData(res->DataHolder->Data->GetChain());
            char pktType;
            reqData.Read(&pktType, 1);

            TGUID reqId;
            reqData.Read(&reqId, sizeof(reqId));
            Y_ASSERT(reqId == res->ReqId);

            TVector<char> flags;
            ReadYArr(&reqData, &flags);
            Y_ASSERT(!reqData.HasFailed());

            if (flags.size() >= 8 + 2) {
                res->Colors.SetResponseDataTos((i16&)flags[0]);
                res->Colors.SetResponseAckTos((i16&)flags[2]);
                res->Colors.SetRequestDataTos((i16&)flags[4]);
                res->Colors.SetRequestAckTos((i16&)flags[6]);
                res->Colors.SetNetlibaRequestColor((ui8&)flags[8]);
                res->Colors.SetNetlibaResponseColor((ui8&)flags[9]);
            }

            if (flags.size() >= 8 + 2 + 1) {
                if (flags[10] & HF_HP_QUEUE) {
                    res->Colors.SetPriority(PP_HIGH);
                }
            }

            ReadArr(&reqData, &res->Url);

            if (pktType == PKT_REQUEST) {
                ReadYArr(&reqData, &res->Data);
            } else if (pktType == PKT_LOCAL_REQUEST) {
                ReadShm(res->DataHolder->Data->GetSharedData(), &res->Data);
            } else
                Y_ASSERT(0);
            if (reqData.HasFailed()) {
                Y_ASSERT(0 && "wrong format, memory corruption suspected");
                res->Url = "";
                res->Data.clear();
            }
        }
        res->DataHolder.Reset(nullptr);
    }

    static void LoadResponseData(TUdpHttpResponse* res) {
        if (!res || res->DataHolder.Get() == nullptr)