issue 11 - Assertion failed: it != peers.end () (pgm_receiver.cpp:161)

1 files changed, 8 insertions, 7 deletions

diff --git a/src/pgm_receiver.cpp b/src/pgm_receiver.cpp
index 88b59d3..048c529 100644
--- a/src/pgm_receiver.cpp
+++ b/src/pgm_receiver.cpp
@@ -146,13 +146,14 @@ void zmq::pgm_receiver_t::in_event ()
 
         //  Data loss. Delete decoder and mark the peer as disjoint.
         if (received == -1) {
-            zmq_assert (it != peers.end ());
-            it->second.joined = false;
-            if (it->second.decoder == mru_decoder)
-                mru_decoder = NULL;
-            if (it->second.decoder != NULL) {
-                delete it->second.decoder;
-                it->second.decoder = NULL;
+            if (it != peers.end ()) {
+                it->second.joined = false;
+                if (it->second.decoder == mru_decoder)
+                    mru_decoder = NULL;
+                if (it->second.decoder != NULL) {
+                    delete it->second.decoder;
+                    it->second.decoder = NULL;
+                }
             }
             break;
         }