Method CreateNehMessage

library/cpp/par/par_network.cpp:300–322

        }

        NNeh::TMessage CreateNehMessage(const TNetworkAddress& address, const TGUID& requestId, const TString& url, TVector<char>* data) {
            CHROMIUM_TRACE_FUNCTION();

            NNeh::TMessage msg;
            msg.Addr = address.GetNehAddr();
            TStringOutput messageStream(msg.Data);
            messageStream << GetGuidAsString(requestId) << '\xff';
            messageStream << url << '\xff';
            if (data) {
                const size_t origLen = data->size();
                QuickLZCompress(data);
                const size_t compressedLen = data->size();
                auto val = Crc32c(data->data(), data->size());
                messageStream << val << '\xff';
                msg.Data.AppendNoAlias(data->data(), data->size());

                TVector<char>().swap(*data);
                PAR_DEBUG_LOG << "From " << GetHostAndPort() << " sending request " << GetGuidAsString(requestId) << " to " << address.GetNehAddr() << " service " << url << " data len: " << origLen << " (compressed: " << compressedLen << ")" << Endl;
            } else {
                PAR_DEBUG_LOG << "From " << GetHostAndPort() << " sending empty request " << GetGuidAsString(requestId) << " to " << address.GetNehAddr() << " service " << url << Endl;
            }
            return msg;
        }
        template <class TAddr = TSockAddrInetStream, class TSock = TInetStreamSocket>
        static int GetFreeFamilyPort(const char* ip) {
            TSock servSock;