diff options
| author | Determinant <ted.sybil@gmail.com> | 2019-03-27 11:05:12 -0400 |
|---|---|---|
| committer | Determinant <ted.sybil@gmail.com> | 2019-03-27 11:05:12 -0400 |
| commit | c91fdee8e845a2eccbc680c2d88748b2ac95a407 (patch) | |
| tree | 4a03e9c2d5ea752517d6811b5ec193268a39e361 /include/salticidae/network.h | |
| parent | a4015bde81371a8b998361ccfb56d5fd714e3ec6 (diff) | |
...
Diffstat (limited to 'include/salticidae/network.h')
| -rw-r--r-- | include/salticidae/network.h | 4 |
1 files changed, 2 insertions, 2 deletions
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<OpcodeType>::Conn::on_read() { return; } #endif - mn->incoming_msgs.enqueue( - std::make_pair(std::move(msg), static_pointer_cast<Conn>(self()))); + auto conn = static_pointer_cast<Conn>(self()); + while (!mn->incoming_msgs.try_enqueue(std::make_pair(msg, conn))); } } } |