| 694 | } |
| 695 | |
| 696 | void ProcessOutputCancelsQueue() { |
| 697 | if (OutputLock_.TryAcquire()) { |
| 698 | AS_.GetIOService().Post(std::bind(&TConnection::SendMessages, TConnectionRef(this), true)); |
| 699 | return; |
| 700 | } |
| 701 | } |
| 702 | |
| 703 | //must be called only from asio thread |
| 704 | void ProcessReqsInFlyQueue() { |
nothing calls this directly
no test coverage detected