From c91fdee8e845a2eccbc680c2d88748b2ac95a407 Mon Sep 17 00:00:00 2001 From: Determinant Date: Wed, 27 Mar 2019 11:05:12 -0400 Subject: ... --- include/salticidae/network.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'include/salticidae/network.h') diff --git a/include/salticidae/network.h b/include/salticidae/network.h index b36cbe3..7814d56 100644 --- a/include/salticidae/network.h +++ b/include/salticidae/network.h @@ -447,8 +447,8 @@ void MsgNetwork::Conn::on_read() { return; } #endif - mn->incoming_msgs.enqueue( - std::make_pair(std::move(msg), static_pointer_cast(self()))); + auto conn = static_pointer_cast(self()); + while (!mn->incoming_msgs.try_enqueue(std::make_pair(msg, conn))); } } } -- cgit v1.2.3