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

Method StopNoWait

library/cpp/neh/netliba_udp_http.cpp:332–341  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

330 }
331
332 void StopNoWait() override {
333 AbortTransactions_ = true;
334 AtomicSet(KeepRunning_, 0);
335 // calcel all outgoing requests
336 TGuard<TSpinLock> lock(Spn_);
337 while (!OutRequests_.empty()) {
338 // cancel without informing peer that we are cancelling the request
339 FinishRequest(OutRequests_.begin(), TUdpHttpResponse::CANCELED, nullptr, "request canceled: inside TUdpHttp::StopNoWait()");
340 }
341 }
342
343 private:
344 void FinishRequest(TOutRequestHash::iterator i, TUdpHttpResponse::EResult ok, TRequestPtr data, const char* error = nullptr) {

Callers 2

~TClientThreadMethod · 0.45
ShutdownMethod · 0.45

Calls 3

AtomicSetFunction · 0.50
emptyMethod · 0.45
beginMethod · 0.45

Tested by

no test coverage detected