| 527 | } |
| 528 | |
| 529 | void OnError(const TString& errText) { |
| 530 | for (auto& it : InFly) { |
| 531 | it.second->OnError(errText); |
| 532 | } |
| 533 | InFly.clear(); |
| 534 | |
| 535 | TRequestPtr req; |
| 536 | while (P->Q.TryDequeue(req)) { |
| 537 | req->OnError(errText); |
| 538 | } |
| 539 | } |
| 540 | |
| 541 | TChannel* P; |
| 542 | TSocketHolder S; |
nothing calls this directly
no test coverage detected