Method PerformSend

library/cpp/par/par_context.cpp:149–160

    }

    void TContextDistributor::PerformSend(int srcComp, int dstComp,
                                          int queryComp, const char* cmd,
                                          TFullCtxInfo& fullCtx, int envId, int hostId, int part, int dataVersion,
                                          TVector<char>* buf) {
        CHROMIUM_TRACE_FUNCTION();
        ++ComputerSendCount[srcComp + 1];
        ++QueryId;
        TransferInfos[QueryId] = TTransferInfo(envId, hostId, part, srcComp, dstComp, dataVersion);
        fullCtx.CopyInitiated[dstComp][part] = true;
        AtomicAdd(ActiveReqCount, 1);
        QueryProc->SendQuery(queryComp, cmd, buf, this, QueryId);
    }

    void TContextDistributor::GotResponse(int id, TVector<char>*) {
        CHROMIUM_TRACE_FUNCTION();