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

Method StopNoWait

library/cpp/netliba/v6/udp_http.cpp:915–925  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

913 return Socket.Get() ? Socket->GetPort() : 0;
914 }
915 void StopNoWait() override {
916 AbortTransactions = true;
917 KeepRunning = false;
918 UserQueues->AsyncSignal();
919 // calcel all outgoing requests
920 TGuard<TSpinLock> lock(cs);
921 while (!OutRequests.empty()) {
922 // cancel without informing peer that we are cancelling the request
923 FinishRequest(OutRequests.begin(), TUdpHttpResponse::CANCELED, nullptr, "request canceled: inside TUdpHttp::StopNoWait()");
924 }
925 }
926 void ExecStatsRequest(TIntrusivePtr<TStatsRequest> req) {
927 StatsReqList.Enqueue(req);
928 Host->CancelWait();

Callers

nothing calls this directly

Calls 3

AsyncSignalMethod · 0.45
emptyMethod · 0.45
beginMethod · 0.45

Tested by

no test coverage detected