MCPcopy Create free account
hub / github.com/catboost/catboost / MRCommandComplete

Method MRCommandComplete

library/cpp/par/par_exec.h:441–455  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

439 DoneRemoteMapTask();
440 }
441 void MRCommandComplete(bool isCanceled, TVector<TVector<char>>* res) override {
442 if (isCanceled) {
443 Cancel();
444 return;
445 }
446 if (!NeedResult())
447 return;
448 CopyRemoteTaskResults(LocalPartId, res);
449 if (AtomicGet(RemoteJobCount) > 0) {
450 // completed local part, lets try to execute all the rest map jobs locally
451 // "local-remote balance"
452 TryToExecAllMapsLocally();
453 }
454 DoneRemoteMapTask();
455 }
456 TGUID GetMasterQueryId() override {
457 return MasterGuid;
458 }

Callers 5

DoneReduceTaskMethod · 0.45
CancelMethod · 0.45
CancelMethod · 0.45
CancelMethod · 0.45
CancelLaunchMethod · 0.45

Calls 2

CancelFunction · 0.50
AtomicGetFunction · 0.50

Tested by

no test coverage detected