From 6949d9caf812b1a5b277e3f530f4e6b8b80ee273 Mon Sep 17 00:00:00 2001
From: Takatoshi Kondo <redboltz@gmail.com>
Date: Tue, 19 Nov 2024 00:08:15 +0900
Subject: [PATCH] more2

---
 include/async_mqtt/impl/endpoint_recv.hpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/include/async_mqtt/impl/endpoint_recv.hpp b/include/async_mqtt/impl/endpoint_recv.hpp
index e371bc35..8794ee50 100644
--- a/include/async_mqtt/impl/endpoint_recv.hpp
+++ b/include/async_mqtt/impl/endpoint_recv.hpp
@@ -204,6 +204,7 @@ recv_op {
             }
         } break;
         case read: {
+            std::cout << __FILE__ << ":" << __LINE__ << ":" << &a_ep << std::endl;
             state = protocol_read;
             a_ep.mbs_ = a_ep.read_buf_.prepare(a_ep.read_buffer_size_);
             a_ep.stream_.async_read_some(
@@ -215,6 +216,7 @@ recv_op {
             auto b = as::buffers_iterator<as::streambuf::mutable_buffers_type>::begin(a_ep.mbs_);
             auto e = std::next(b, std::ptrdiff_t(bytes_transferred));
             auto events{a_ep.con_.recv(b, e)};
+            std::cout << __FILE__ << ":" << __LINE__ << ":" << &a_ep << ":" << events.size() << std::endl;
             std::move(events.begin(), events.end(), std::back_inserter(a_ep.recv_events_));
             a_ep.read_buf_.commit(bytes_transferred);
             if (a_ep.recv_events_.empty()) {