Method doRead

valdi/src/valdi/runtime/Debugger/TCPConnectionImpl.cpp:155–177

}

void TCPConnectionImpl::doRead() {
    auto buffer = Valdi::makeShared<Buffer>();
    _socket.async_read_some(
        boost::asio::buffer(buffer->data(), buffer->size()),
        [buffer, strongSelf = strongSmallRef(this)](boost::system::error_code ec, std::size_t length) {
            if (ec.failed()) {
                strongSelf->close(errorFromBoostError(ec));
            } else {
                {
                    std::lock_guard<Mutex> guard(strongSelf->_mutex);
                    if (strongSelf->_closed) {
                        return;
                    }
                    strongSelf->doRead();
                }

                auto listener = strongSelf->getDataListener();
                if (listener != nullptr) {
                    listener->onDataReceived(strongSelf, BytesView(buffer, buffer->data(), length));
                }
            }
        });
}

void TCPConnectionImpl::onReady() {
    _address = resolveAddress();