generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-19 08:46:44 +01:00
Code Issues Projects Releases Wiki Activity

Merge branch '46_device_robustness'

Browse Source
This commit is contained in:
Pieter Hintjens 2010-08-20 01:06:34 +02:00
commit 87612be91d
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/xrep.cpp
View File

@ -143,8 +143,11 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_)
if (!more_out) {
zmq_assert (!current_out);
// There's no such thing as prefix with no subsequent message.
zmq_assert (msg_->flags & ZMQ_MSG_MORE);
// If we have malformed message (prefix with no subsequent message)
// then just silently drop the message.
if ((msg_->flags & ZMQ_MSG_MORE) == 0)
return 0;
more_out = true;
// Find the pipe associated with the identity stored in the prefix.
@ -154,7 +157,7 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_)
outpipes_t::iterator it = outpipes.find (identity);
if (it == outpipes.end ())
return 0;
// Remember the outgoing pipe.
current_out = it->second.writer;