| 653 | }; |
| 654 | |
| 655 | void Cancel() { |
| 656 | if (AtomicCas(&IsCanceledFlag, (void*)this, (void*)nullptr)) { |
| 657 | PAR_DEBUG_LOG << "SplitMRExec canceled" << Endl; |
| 658 | if (CompleteNotify.Get()) |
| 659 | CompleteNotify->MRCommandComplete(true, nullptr); |
| 660 | CompleteNotify = nullptr; |
| 661 | } |
| 662 | } |
| 663 | void StartNextBlock() { |
| 664 | IUserContext::EDataDistrState ds = UserContext->UpdateDataDistrState(nullptr); |
| 665 | if (ds == IUserContext::DATA_UNAVAILABLE) { |
nothing calls this directly
no test coverage detected