Method Launch

library/cpp/par/par_exec.h:753–775

    public:
        static void Launch(TJobRequest* jobRequest,
                           TRemoteQueryProcessor* queryProc, IUserContext* userContext,
                           IMRCommandCompleteNotify* mrNotify) {
            for (;;) {
                IUserContext::EDataDistrState ds = userContext->UpdateDataDistrState(&jobRequest->HostId2Computer);
                if (ds == IUserContext::DATA_UNAVAILABLE) {
                    CancelLaunch(mrNotify, userContext);
                    return;
                }
                if (ds != IUserContext::DATA_COMPLETE && jobRequest->Descr.ExecList.ysize() > FIRST_BLOCK_LEN * 2) {
                    TIntrusivePtr<TSplitMRExec> op = new TSplitMRExec(jobRequest, queryProc, mrNotify, userContext);
                    op->StartNextBlock();
                    op->StartNextBlock();
                    return;
                } else {
                    bool chk = LaunchJobRequest(jobRequest, queryProc, userContext, mrNotify);
                    if (chk)
                        return;
                    // can not execute have to wait somehow
                    ThreadYield();
                }
            }
        }
    };
}