MCPcopy Create free account
hub / github.com/catboost/catboost / ~TUdpHttp

Method ~TUdpHttp

library/cpp/netliba/v12/udp_http.cpp:1118–1131  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1116 return nullptr;
1117 }
1118 ~TUdpHttp() override {
1119 if (std::uncaught_exceptions()) {
1120 TUdpHttp::StopNoWait();
1121 AtomicSwap(&AbortTransactions, 1);
1122 }
1123
1124 if (UdpHttpThread.Running()) {
1125 AtomicSwap(&KeepRunning, 0);
1126 UdpHttpThread.Join();
1127 }
1128 for (TIntrusivePtr<TStatsRequest> req; StatsReqList.Dequeue(&req);) {
1129 req->Complete.Signal();
1130 }
1131 }
1132
1133 public:
1134 TUdpHttp()

Callers

nothing calls this directly

Calls 6

uncaught_exceptionsFunction · 0.85
AtomicSwapFunction · 0.50
RunningMethod · 0.45
JoinMethod · 0.45
DequeueMethod · 0.45
SignalMethod · 0.45

Tested by

no test coverage detected