Method LaunchRequest

library/cpp/par/par_mr.cpp:159–168

            CancelCallback.Detach();
        }
        void LaunchRequest(TContextReplica* context) {
            if (context->GetContextState(AllJobs->EnvId2Version, &ContextData)) {
                UserContext = new TUserContext(QueryProc.Get(), AllJobs.Get(), &ContextData, context->GetWriteBuffer());
                int localCompId = QueryProc->GetCompId();
                TMRCommandExec::Launch(AllJobs.Get(), QueryProc.Get(), localCompId, UserContext.Get(), this);
            } else {
                PAR_DEBUG_LOG << "Get context state failed" << Endl;
                MRCommandComplete(true, nullptr);
            }
        }
        void MRCommandComplete(bool isCanceled, TVector<TVector<char>>* res) override {
            CHROMIUM_TRACE_FUNCTION();
            TJobRequestReply reply;