Method Cancel

library/cpp/par/par_exec.h:361–373

            }
        }
        void Cancel() {
            CHROMIUM_TRACE_FUNCTION();
            // can cancel op if reduce has not started yet
            if (AtomicCas(&MapResult, (TMapResultBuffer*)-1, (TMapResultBuffer*)nullptr)) {
                PAR_DEBUG_LOG << "MRExec canceled" << Endl;
                CancelAllRemoteQueries();
                if (CompleteNotify.Get()) {
                    CompleteNotify->MRCommandComplete(true, nullptr);
                    CompleteNotify = nullptr;
                } else
                    Y_ASSERT(0 && "Notify ptr is lost");
            }
        }
        void ReschedulePartRequest(int partId) {
            CHROMIUM_TRACE_FUNCTION();
            TRemoteMapInfo* part = &MapParts[partId];