Method TNehRequester

library/cpp/par/par_network.cpp:57–86

        };

        explicit TNehRequester(
            int port,
            TProcessQueryCancelCallback queryCancelCallback,
            TProcessQueryCallback queryCallback,
            TProcessReplyCallback replyCallback)
            : QueryCancelCallback(std::move(queryCancelCallback))
            , QueryCallback(std::move(queryCallback))
            , ReplyCallback(std::move(replyCallback))
        {
            NNeh::SetProtocolOption("tcp2/ServerOutputDeadline", "600s");
            MultiClient = NNeh::CreateMultiClient();
            MultiClientThread = SystemThreadFactory()->Run([this]() {
                MultiClientThreadLoopFunction();
            });
            ReceiverServices = NNeh::CreateLoop();
            if (port == 0) {
                ListenPort = GetFreeTcpPort();
            } else {
                ListenPort = port;
            }
            TNetworkAddress serverAddr("*", ListenPort);
            PAR_DEBUG_LOG << "Listening as " << serverAddr.GetNehAddr() << Endl;
            ReceiverServices->Add(serverAddr.GetNehAddr(), [this](const NNeh::IRequestRef& req) {
                NehServiceQueryCallback(req);
            });
            ReceiverServices->ForkLoop(5);
            PingerThread = SystemThreadFactory()->Run([this]() {
                PingerThreadFunction();
            });
        }

        int GetListenPort() const override {
            return ListenPort;