| 892 | } |
| 893 | |
| 894 | void V1Transport::MarkBytesSent(size_t bytes_sent) noexcept |
| 895 | { |
| 896 | AssertLockNotHeld(m_send_mutex); |
| 897 | LOCK(m_send_mutex); |
| 898 | m_bytes_sent += bytes_sent; |
| 899 | if (m_sending_header && m_bytes_sent == m_header_to_send.size()) { |
| 900 | // We're done sending a message's header. Switch to sending its data bytes. |
| 901 | m_sending_header = false; |
| 902 | m_bytes_sent = 0; |
| 903 | } else if (!m_sending_header && m_bytes_sent == m_message_to_send.data.size()) { |
| 904 | // We're done sending a message's data. Wipe the data vector to reduce memory consumption. |
| 905 | ClearShrink(m_message_to_send.data); |
| 906 | m_bytes_sent = 0; |
| 907 | } |
| 908 | } |
| 909 | |
| 910 | size_t V1Transport::GetSendMemoryUsage() const noexcept |
| 911 | { |