Method TRemoteMRCommandExec

library/cpp/par/par_mr.cpp:145–155

    public:
        TRemoteMRCommandExec(TNetworkRequest* req, TRemoteQueryProcessor* queryProc)
            : QueryProc(queryProc)
            , IsQueryCanceled(false)
        {
            CHROMIUM_TRACE_FUNCTION();
            ReqId = req->ReqId;
            AllJobs = new TJobRequest;
            SerializeFromMem(&req->Data, *AllJobs);
            AllJobs->IsLowPriority = req->Url == "mr_low";
            CancelCallback.Attach(this, queryProc, ReqId);
        }
        ~TRemoteMRCommandExec() override {
            CancelCallback.Detach();
        }