Method SetContextData

library/cpp/par/par_context.cpp:261–284

    }

    void TContextDistributor::SetContextData(int envId, int hostId, const IObjectBase* data, EKeepDataFlags keepContextRawData) {
        CHROMIUM_TRACE_FUNCTION();
        bool keepRemoteRawData = keepContextRawData & (KEEP_CONTEXT_RAW_DATA & ~KEEP_CONTEXT_ON_MASTER);
        {
            TGuard<TMutex> g(Sync);
            Y_ASSERT(EnvId2Info.find(envId) != EnvId2Info.end());
            TFullCtxInfo& dst = EnvId2Info[envId];
            TCtxDataPart& part = dst.Data[hostId];
            if (part.Version >= dst.MaxVersion) {
                ++part.Version;
                dst.MaxVersion = part.Version;
            } else {
                part.Version = dst.MaxVersion;
            }
            AssignData(&part, dst, data);
            part.KeepRawData = keepRemoteRawData;
            dst.ResetHostIdReady(hostId, part.GetPartCount());

            DoSend();
        }
        if (!keepRemoteRawData) {
            DeleteContextRawData(envId, hostId, keepContextRawData & KEEP_CONTEXT_ON_MASTER);
        }
    }

    void TContextDistributor::SetContextData(int envId, const TVector<int>& compIds, const TVector<i64>& dataIds, EKeepDataFlags keepContextRawData) {
        CHROMIUM_TRACE_FUNCTION();