Method SendRequestImpl

library/cpp/netliba/v12/udp_http.cpp:908–954

    public:
        void SendRequestImpl(const TConnectionAddress& addr, const TString& url, TVector<char>* data, const TGUID& reqId,
                             TWaitResponse* wr, TRequesterUserQueues* userQueues) {
            if (data && data->size() > MAX_PACKET_SIZE) {
                Y_ABORT_UNLESS(0, "data size is too large");
            }
            //printf("SendRequest(%s)\n", url.c_str());
            if (wr)
                wr->SetReqId(reqId);

            TVector<char> flags(4 * 2 + 2 + 1);
            (i16&)flags[0] = (i16)addr.GetResponseDataTos();
            (i16&)flags[2] = (i16)addr.GetResponseAckTos();
            (i16&)flags[4] = (i16)addr.GetRequestDataTos();
            (i16&)flags[6] = (i16)addr.GetRequestAckTos();
            (ui8&)flags[8] = addr.GetNetlibaRequestColor();
            (ui8&)flags[9] = addr.GetNetlibaResponseColor();
            if (addr.GetPriority() == PP_HIGH) {
                (ui8&)flags[10] = HF_HP_QUEUE;
            }

            TAutoPtr<TRopeDataPacket> ms = new TRopeDataPacket;
            if (data && data->ysize() > MIN_SHARED_MEM_PACKET && Host->IsLocal(addr.GetAddress())) {
                int dataSize = data->ysize();
                TIntrusivePtr<TPosixSharedMemory> shm = new TPosixSharedMemory;
                if (shm->Create(dataSize)) {
                    ms->Write((char)PKT_LOCAL_REQUEST);
                    ms->Write(reqId);
                    ms->WriteDestructive(&flags);
                    ms->WriteStroka(url);
                    memcpy(shm->GetPtr(), &(*data)[0], dataSize);
                    TVector<char> empty;
                    data->swap(empty);
                    ms->AttachSharedData(shm);
                }
            }

            if (ms->GetSharedData() == nullptr) {
                ms->Write((char)PKT_REQUEST);
                ms->Write(reqId);
                ms->WriteDestructive(&flags);
                ms->WriteStroka(url);
                ms->WriteDestructive(data);
            }

            SendReqList.Enqueue(new TSendRequest(addr, &ms, reqId, wr, userQueues));
            Host->CancelWait();
        }

        void SendRequest(const TConnectionAddress& addr, const TString& url, TVector<char>* data, const TGUID& reqId) override {
            SendRequestImpl(addr, url, data, reqId, nullptr, UserQueues.Get());