Skip to content

Commit

Permalink
more dp
Browse files Browse the repository at this point in the history
  • Loading branch information
redboltz committed Nov 18, 2024
1 parent 2af4fdf commit 09fe4c7
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions include/async_mqtt/impl/endpoint_recv.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ recv_op {
[&](basic_event_send<PacketIdBytes>& ev) {
state = sent;
auto ep_copy{ep};
std::cout << __FILE__ << ":" << __LINE__ << ":" << &a_ep << std::endl;
async_send(
force_move(ep_copy),
force_move(ev.get()),
Expand All @@ -60,6 +61,7 @@ recv_op {
},
[&](basic_event_packet_received<PacketIdBytes> ev) {
if (recv_packet) {
std::cout << __FILE__ << ":" << __LINE__ << ":" << &a_ep << std::endl;
// rest events would be processed the next async_recv call
// back the event to the recv_events_ for the next async_recv
a_ep.recv_events_.push_front(force_move(event));
Expand All @@ -71,6 +73,7 @@ recv_op {
return false;
}
else {
std::cout << __FILE__ << ":" << __LINE__ << ":" << &a_ep << std::endl;
recv_packet.emplace(force_move(ev.get()));
}
return true;
Expand Down

0 comments on commit 09fe4c7

Please # to comment.