Method StopSlaves

library/cpp/par/par_remote.cpp:259–310

    }

    void TRemoteQueryProcessor::StopSlaves() {
        TIntrusivePtr<TMetaRequester> mr(new TMetaRequester(this));
        DEBUG_LOG << "Stopping slaves" << Endl;
        fflush(nullptr);
        int searcherCount = GetSlaveCount();
        TVector<bool> chkStopRes;
        chkStopRes.resize(searcherCount, false);
        for (bool canStop = false; !canStop;) {
            for (int i = 0; i < searcherCount; ++i) {
                if (!chkStopRes[i]) {
                    mr->AddQuery(i, "check_stop", nullptr);
                }
            }
            TVector<TVector<char>> res;
            mr->GetResults(&res);
            canStop = true;
            for (int i = 0; i < res.ysize(); ++i) {
                if (chkStopRes[i]) {
                    continue;
                }
                bool resVal = (res[i][0] != 0);
                chkStopRes[i] = resVal;
                canStop &= resVal;
            }
        }
        DEBUG_LOG << "Gathering debug stats from slaves" << Endl;
        for (int i = 0; i < searcherCount; ++i) {
            mr->AddQuery(i, "gather_stats", nullptr);
        }
        auto& masterTimings = Singleton<TParHostStats>()->ParTimings;
        TVector<TVector<char>> res;
        mr->GetResults(&res);
        Y_ABORT_UNLESS(
            res.ysize() == searcherCount,
            "res.ysize()=%d, searcherCount=%d",
            res.ysize(), searcherCount);
        for (int i = 0; i < searcherCount; ++i) {
            TParHostStats tmpStats;
            SerializeFromMem(&res.at(i), tmpStats);
            for (size_t j = 0; j < static_cast<size_t>(ETimingTag::TimingsCount); ++j) {
                *masterTimings.Timings[j] += *tmpStats.ParTimings.Timings[j];
            }
        }
        DEBUG_LOG << "Cumulative timings: " << Endl;
        for (size_t i = 0; i < static_cast<size_t>(ETimingTag::TimingsCount); ++i) {
            Cout << static_cast<ETimingTag>(i) << ": " << static_cast<double>(*masterTimings.Timings[i]) << Endl;
        }
        for (int i = 0; i < searcherCount; ++i) {
            mr->AddQuery(i, "stop", nullptr);
        }
        mr->GetResults(nullptr);
    }

    void TRemoteQueryProcessor::IncLastCount(int compId) {
        Y_ASSERT(compId >= 0 && compId < LastCounts.ysize());