| 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(); |
nothing calls this directly
no test coverage detected