Method lockFreeDoSend

valdi/src/valdi/runtime/Debugger/TCPConnectionImpl.cpp:65–87

}

void TCPConnectionImpl::lockFreeDoSend() {
    if (_pendingPackets.empty()) {
        return;
    }

    auto bytes = _pendingPackets.front();

    boost::asio::async_write(_socket,
                             boost::asio::buffer(bytes.data(), bytes.size()),
                             [strongSelf = strongSmallRef(this)](boost::system::error_code ec, std::size_t /*length*/) {
                                 if (ec.failed()) {
                                     strongSelf->close(errorFromBoostError(ec));
                                     return;
                                 }

                                 std::lock_guard<Mutex> guard(strongSelf->_mutex);
                                 if (strongSelf->_closed) {
                                     return;
                                 }
                                 strongSelf->_pendingPackets.pop_front();
                                 strongSelf->lockFreeDoSend();
                             });
}

void TCPConnectionImpl::close(const Error& error) {
    Shared<ITCPConnectionDisconnectListener> listener;