Method PingerThreadFunction

library/cpp/par/par_network.cpp:216–233

        }

        void PingerThreadFunction() {
            while (Running) {
                THashSet<TNetworkAddress> requestedHosts;
                auto collectHosts = [&requestedHosts](const TGUID&, TNetworkAddress& addr) {
                    requestedHosts.insert(addr);
                };
                RequestsInfo.LockedIterateValues(collectHosts);
                if (requestedHosts) {
                    TGUID pingGuid;
                    CreateGuid(&pingGuid);
                    PAR_DEBUG_LOG << "From " << GetHostAndPort() << "Pinging " << requestedHosts.size() << " hosts" << Endl;
                    for (const auto& addr : requestedHosts) {
                        InternalSendQuery(addr, pingGuid, "_ping_", nullptr);
                    }
                }
                Sleep(TDuration::Seconds(2));
            }
        }

        ~TNehRequester() override {
            Running = false;