Method TryToExecAllMapsLocally

library/cpp/par/par_exec.h:331–360

                CancelAllRemoteQueries();
        }
        void TryToExecAllMapsLocally() {
            CHROMIUM_TRACE_FUNCTION();

            // check if we have hostId data
            THashMap<int, bool> hostIdSet;
            int mapJobCount = JobRequest->Descr.ExecList.ysize();
            for (int i = 0; i < mapJobCount; ++i) {
                int hostId = JobRequest->Descr.ExecList[i].HostId;
                if (hostId == TJobDescription::ANYWHERE_HOST_ID) {
                    int hostIdCount = LocalUserContext->GetHostIdCount();
                    for (int h = 0; h < hostIdCount; ++h)
                        hostIdSet[h];
                    break;
                } else {
                    hostIdSet[hostId];
                }
            }

            if (LocalUserContext->HasHostIds(hostIdSet) && AtomicGet(MapResult) == nullptr) {
                Y_ASSERT(LocalMapReqCount == 0);
                LocalMapReqCount = 1;
                for (int i = 0; i < mapJobCount; ++i) {
                    int cmdId = JobRequest->Descr.ExecList[i].CmdId;
                    Cmds.Check(cmdId);
                }
                AtomicAdd(LocalMapReqCount, mapJobCount);
                LocalExecutor().ExecRange(this, 0, mapJobCount, TLocalExecutor::LOW_PRIORITY);
                DoneLocalMapTask();
            }
        }
        void Cancel() {
            CHROMIUM_TRACE_FUNCTION();
            // can cancel op if reduce has not started yet