diff options
Diffstat (limited to 'include')
| -rw-r--r-- | include/kvm_websocket.hpp | 8 | ||||
| -rw-r--r-- | include/nbd_proxy.hpp | 6 | ||||
| -rw-r--r-- | include/vm_websocket.hpp | 7 |
3 files changed, 11 insertions, 10 deletions
diff --git a/include/kvm_websocket.hpp b/include/kvm_websocket.hpp index 0089ae375b..df13a67461 100644 --- a/include/kvm_websocket.hpp +++ b/include/kvm_websocket.hpp @@ -52,11 +52,11 @@ class KvmSession : public std::enable_shared_from_this<KvmSession> BMCWEB_LOG_DEBUG("conn:{}, Read {} bytes from websocket", logPtr(&conn), data.size()); - boost::asio::buffer_copy(inputBuffer.prepare(data.size()), - boost::asio::buffer(data)); + size_t copied = boost::asio::buffer_copy( + inputBuffer.prepare(data.size()), boost::asio::buffer(data)); BMCWEB_LOG_DEBUG("conn:{}, Committing {} bytes from websocket", - logPtr(&conn), data.size()); - inputBuffer.commit(data.size()); + logPtr(&conn), copied); + inputBuffer.commit(copied); BMCWEB_LOG_DEBUG("conn:{}, inputbuffer size {}", logPtr(&conn), inputBuffer.size()); diff --git a/include/nbd_proxy.hpp b/include/nbd_proxy.hpp index 17d57b4c15..838e7a1d2c 100644 --- a/include/nbd_proxy.hpp +++ b/include/nbd_proxy.hpp @@ -125,9 +125,9 @@ struct NbdProxyServer : std::enable_shared_from_this<NbdProxyServer> void send(std::string_view buffer, std::function<void()>&& onDone) { - boost::asio::buffer_copy(ws2uxBuf.prepare(buffer.size()), - boost::asio::buffer(buffer)); - ws2uxBuf.commit(buffer.size()); + size_t copied = boost::asio::buffer_copy( + ws2uxBuf.prepare(buffer.size()), boost::asio::buffer(buffer)); + ws2uxBuf.commit(copied); doWrite(std::move(onDone)); } diff --git a/include/vm_websocket.hpp b/include/vm_websocket.hpp index 13bbdc6b23..19054a6d97 100644 --- a/include/vm_websocket.hpp +++ b/include/vm_websocket.hpp @@ -215,9 +215,10 @@ inline void requestRoutes(App& app) return; } - boost::asio::buffer_copy(handler->inputBuffer->prepare(data.size()), - boost::asio::buffer(data)); - handler->inputBuffer->commit(data.size()); + size_t copied = + boost::asio::buffer_copy(handler->inputBuffer->prepare(data.size()), + boost::asio::buffer(data)); + handler->inputBuffer->commit(copied); handler->doWrite(); }); } |