generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-14 11:06:59 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #399 from hurtonm/master

Browse Source 
Small cleanup
This commit is contained in:
Pieter Hintjens 2012-07-11 08:02:01 -07:00
commit 0533fb1ce1
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/router.cpp
View File

@ -117,15 +117,14 @@ void zmq::router_t::xread_activated (pipe_t *pipe_)
void zmq::router_t::xwrite_activated (pipe_t *pipe_) void zmq::router_t::xwrite_activated (pipe_t *pipe_)
{ {
for (outpipes_t::iterator it = outpipes.begin (); outpipes_t::iterator it;
it != outpipes.end (); ++it) { for (it = outpipes.begin (); it != outpipes.end (); ++it)
if (it->second.pipe == pipe_) { if (it->second.pipe == pipe_)
zmq_assert (!it->second.active); break;
it->second.active = true;
return; zmq_assert (it != outpipes.end ());
} zmq_assert (!it->second.active);
} it->second.active = true;
zmq_assert (false);
} }
int zmq::router_t::xsend (msg_t *msg_, int flags_) int zmq::router_t::xsend (msg_t *msg_, int flags_)