Method DoSend

library/cpp/par/par_context.cpp:50–147

        }
    };
    void TContextDistributor::DoSend() {
        CHROMIUM_TRACE_FUNCTION();

        if (QueryProc.Get() == nullptr)
            return;

        TVector<TCtxTransferSrc> srcHolder;
        TVector<TRequiredTransfer> xferList;
        srcHolder.reserve(100);

        bool allComplete = true;
        for (THashMap<int, TFullCtxInfo>::iterator i = EnvId2Info.begin(); i != EnvId2Info.end(); ++i) {
            TFullCtxInfo& info = i->second;
            for (int hostId = 0; hostId < info.HostId2Computer.ysize(); ++hostId) {
                bool& isFullyDistributed = info.IsFullyDistributed[hostId];
                if (isFullyDistributed)
                    continue;

                isFullyDistributed = true;
                const TVector<int>& compList = info.HostId2Computer[hostId];
                int partCount = info.Data[hostId].GetPartCount();
                for (int part = 0; part < partCount; ++part) {
                    int srcCount = 0;
                    int srcGroupId = srcHolder.ysize();
                    TCtxTransferSrc& src = srcHolder.emplace_back();
                    TVector<int> target;
                    if (info.Data[hostId].Info.Get())
                        src.SrcComps.push_back(-1);
                    for (int z = 0; z < compList.ysize(); ++z) {
                        int compId = compList[z];
                        if (info.ReadyMask[compId][part]) {
                            ++srcCount;
                            if (ComputerSendCount[compId] < MAX_SIMULTANEOUS_SENDS) {
                                src.SrcComps.push_back(compId);
                            }
                        } else {
                            isFullyDistributed = false;
                            allComplete = false;
                            if (!info.CopyInitiated[compId][part]) {
                                target.push_back(compId);
                            }
                        }
                    }
                    if (!target.empty() && !src.SrcComps.empty()) {
                        Shuffle(src.SrcComps.begin(), src.SrcComps.end());
                        for (int z = 0; z < target.ysize(); ++z) {
                            TRequiredTransfer xfer;
                            xfer.EnvId = i->first;
                            xfer.HostId = hostId;
                            xfer.Part = part;
                            xfer.SrcGroupId = srcGroupId;
                            xfer.DstComp = target[z];
                            xfer.SrcCount = srcCount;
                            xferList.push_back(xfer);
                        }
                    }
                }
            }