| 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) { |
no test coverage detected