generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2025-05-02 15:41:40 +02:00
Code Issues Projects Releases Wiki Activity

Update to 3.0 API

Browse Source 
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
This commit is contained in:
Martin Sustrik 2011-05-25 18:44:58 +02:00
parent 38bbe08168
commit 9da2598aa0
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
zmq.hpp
View File

@ -270,20 +270,20 @@ namespace zmq
inline bool send (message_t &msg_, int flags_ = 0) inline bool send (message_t &msg_, int flags_ = 0)
{ {
int rc = zmq_send (ptr, &msg_, flags_); int nbytes = zmq_sendmsg (ptr, &msg_, flags_);
if (rc == 0) if (nbytes >= 0)
return true; return true;
if (rc == -1 && zmq_errno () == EAGAIN) if (zmq_errno () == EAGAIN)
return false; return false;
throw error_t (); throw error_t ();
} }
inline bool recv (message_t *msg_, int flags_ = 0) inline bool recv (message_t *msg_, int flags_ = 0)
{ {
int rc = zmq_recv (ptr, msg_, flags_); int nbytes = zmq_recvmsg (ptr, msg_, flags_);
if (rc == 0) if (nbytes >= 0)
return true; return true;
if (rc == -1 && zmq_errno () == EAGAIN) if (zmq_errno () == EAGAIN)
return false; return false;
throw error_t (); throw error_t ();
} }