| 146 | } |
| 147 | |
| 148 | void TGlobalUserContext::Run(TJobDescription* descr, IMRCommandCompleteNotify* completeNotify) { |
| 149 | // copy is needed to handle UpdateDistrState() correctly |
| 150 | // UpdateDistrState() is not thread safe and different contexts can have different HostId2Computer |
| 151 | TIntrusivePtr<TGlobalUserContext> ctx = new TGlobalUserContext(*this); |
| 152 | AsyncStartGroupRequest(descr, QueryProc.Get(), ctx.Get(), completeNotify); |
| 153 | } |
| 154 | |
| 155 | void TGlobalUserContext::RunLocalOnly(TJobDescription* descr, IMRCommandCompleteNotify* completeNotify) { |
| 156 | // copy is needed to handle UpdateDistrState() correctly |
nothing calls this directly
no test coverage detected