| 975 | } |
| 976 | |
| 977 | void SafeOnError() { |
| 978 | TRequest* reqPtr; |
| 979 | |
| 980 | while (Reqs_.Dequeue(&reqPtr)) { |
| 981 | TRequestRef req(reqPtr); |
| 982 | reqPtr->UnRef(); |
| 983 | //DBGOUT("err queue(" << AS_.Native() << "):" << size_t(reqPtr)); |
| 984 | req->OnError(Error_, SystemCode_); |
| 985 | } |
| 986 | |
| 987 | while (ReqsInFlyQueue_.Dequeue(&reqPtr)) { |
| 988 | TRequestRef req(reqPtr); |
| 989 | reqPtr->UnRef(); |
| 990 | //DBGOUT("err fly queue(" << AS_.Native() << "):" << size_t(reqPtr)); |
| 991 | req->OnError(Error_, SystemCode_); |
| 992 | } |
| 993 | } |
| 994 | |
| 995 | //must be called only from asio thread |
| 996 | void OnReceiveMessage() { |