Method Request

library/cpp/par/par_network.cpp:275–287

        }

        TAutoPtr<TNetworkResponse> Request(const TNetworkAddress& address, const TString& url, TVector<char>* data) override {
            CHROMIUM_TRACE_FUNCTION();
            TIntrusivePtr<TSyncRequestsInfo> reqInfo = new TSyncRequestsInfo;
            TGUID reqId;
            CreateGuid(&reqId);
            DirectRequestsInfo.EmplaceValue(reqId, reqInfo);
            RequestsInfo.EmplaceValue(reqId, address);
            PAR_DEBUG_LOG << "From " << GetHostAndPort() << " sending request " << GetGuidAsString(reqId) << " url: " << url << " data len: " << (data ? data->size() : 0) << Endl;
            InternalSendQuery(address, reqId, url + "@" + ToString(ListenPort), data);
            reqInfo->Event.WaitI();
            Y_ABORT_UNLESS(DirectRequestsInfo.EraseValueIfPresent(reqId));
            return std::move(reqInfo->Response);
        }

    private:
        void InternalSendQuery(const TNetworkAddress& address, const TGUID& requestId, const TString& url, TVector<char>* data) {