Method DeleteContextRawData

library/cpp/par/par_context.cpp:360–392

    };

    void TContextDistributor::DeleteContextRawData(int envId, int hostId, bool keepContextOnMaster) {
        CHROMIUM_TRACE_FUNCTION();
        WaitAllDistributionActivity(); // can wait more fine grained, but delay should not be much higher

        Y_ASSERT(EnvId2Info.find(envId) != EnvId2Info.end());
        TFullCtxInfo& dst = EnvId2Info[envId];

        // free mem on slaves
        if (QueryProc.Get()) {
            TVector<char> cmd;
            {
                TContextFreeCmd freeCmd;
                freeCmd.EnvId = envId;
                SerializeToMem(&cmd, freeCmd);
            }

            const TVector<int>& compList = dst.HostId2Computer[hostId];
            TIntrusivePtr<TFreeMemWait> fmw = new TFreeMemWait(compList.ysize());
            for (int i = 0; i < compList.ysize(); ++i) {
                int compId = compList[i];
                TVector<char> tmp = cmd;
                QueryProc->SendQuery(compId, "ctx_free", &tmp, fmw.Get(), i);
            }
            fmw->Wait();
        }

        // free mem on master
        TCtxDataPart& part = dst.Data[hostId];
        TVector<TVector<char>>().swap(part.BinData);
        if (!keepContextOnMaster) {
            part.Info = nullptr;
        }
    }

    void TContextDistributor::GetVersions(int envId, int* hostIdCount, THashMap<int, int>* envId2version) {
        CHROMIUM_TRACE_FUNCTION();