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

Method OnError

library/cpp/neh/tcp.cpp:529–539  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

527 }
528
529 void OnError(const TString& errText) {
530 for (auto& it : InFly) {
531 it.second->OnError(errText);
532 }
533 InFly.clear();
534
535 TRequestPtr req;
536 while (P->Q.TryDequeue(req)) {
537 req->OnError(errText);
538 }
539 }
540
541 TChannel* P;
542 TSocketHolder S;

Callers

nothing calls this directly

Calls 3

TryDequeueMethod · 0.80
OnErrorMethod · 0.45
clearMethod · 0.45

Tested by

no test coverage detected