must be called only from asio thread
| 871 | |
| 872 | //must be called only from asio thread |
| 873 | void OnSend(TRequestId reqId, const TErrorCode& ec, size_t amount, IHandlingContext&) { |
| 874 | Y_UNUSED(amount); |
| 875 | if (Y_UNLIKELY(ec)) { |
| 876 | OnErrorCode(ec); |
| 877 | } else { |
| 878 | if (Y_LIKELY(reqId)) { |
| 879 | DBGOUT("Client::OnSend(" << reqId << ")"); |
| 880 | LastSendedReqId_.store(reqId, std::memory_order_release); |
| 881 | } |
| 882 | //output already aquired, used asio thread |
| 883 | OutputBuffers_.Clear(); |
| 884 | SendMessages(true); |
| 885 | } |
| 886 | } |
| 887 | |
| 888 | //must be called only from asio thread |
| 889 | void OnCanRead(const TErrorCode& ec, IHandlingContext& ctx) { |