summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-04-08 11:07:22 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-04-08 11:07:22 +0200
commit77cbd18e9c0480a6c26fd29de5d70569762108be (patch)
tree6a952bb3b67ebcf8e6dd12a79868727c0843014d /src
parent38e9103e0c82bcbb61a9c23ed3a4ace1c7420f95 (diff)
issue 11 - Assertion failed: it != peers.end () (pgm_receiver.cpp:161)
Diffstat (limited to 'src')
-rw-r--r--src/pgm_receiver.cpp15
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;
}