generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-13 02:42:58 +01:00
Code Issues Projects Releases Wiki Activity

Return -1 when failed to publish message

Browse Source
This commit is contained in:
Martin Hurton 2014-08-12 10:51:27 +02:00
parent 228426ac44
commit 214553972d
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/xpub.cpp
View File

@ -131,8 +131,10 @@ int zmq::xpub_t::xsend (msg_t *msg_)
subscriptions.match ((unsigned char*) msg_->data (), msg_->size (), subscriptions.match ((unsigned char*) msg_->data (), msg_->size (),
mark_as_matching, this); mark_as_matching, this);
if (nodrop && !dist.check_hwm ()) if (nodrop && !dist.check_hwm ()) {
return EAGAIN; errno = EAGAIN;
return -1;
}
// Send the message to all the pipes that were marked as matching // Send the message to all the pipes that were marked as matching
// in the previous step. // in the previous step.