generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-02-25 07:41:10 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #325 from hurtonm/update_comment_in_device_plus_whitespace_fixes

Browse Source 
Mention limitation of the device implementation
This commit is contained in:
Ian Barber 2012-04-25 01:52:06 -07:00
commit 648e31994d
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/device.cpp
View File

@ -35,9 +35,12 @@ int zmq::device (class socket_base_t *insocket_,
if (rc != 0)
return -1;
// The algorithm below assumes ratio of request and replies processed
// The algorithm below assumes ratio of requests and replies processed
// under full load to be 1:1.
// TODO: The current implementation drops messages when
// any of the pipes becomes full.
int more;
size_t moresz;
zmq_pollitem_t items [] = {
@ -56,12 +59,12 @@ int zmq::device (class socket_base_t *insocket_,
rc = insocket_->recv (&msg, 0);
if (unlikely (rc < 0))
return -1;
moresz = sizeof (more);
moresz = sizeof more;
rc = insocket_->getsockopt (ZMQ_RCVMORE, &more, &moresz);
if (unlikely (rc < 0))
return -1;
rc = outsocket_->send (&msg, more? ZMQ_SNDMORE: 0);
if (unlikely (rc < 0))
return -1;
@ -75,12 +78,12 @@ int zmq::device (class socket_base_t *insocket_,
rc = outsocket_->recv (&msg, 0);
if (unlikely (rc < 0))
return -1;
moresz = sizeof (more);
moresz = sizeof more;
rc = outsocket_->getsockopt (ZMQ_RCVMORE, &more, &moresz);
if (unlikely (rc < 0))
return -1;
rc = insocket_->send (&msg, more? ZMQ_SNDMORE: 0);
if (unlikely (rc < 0))
return -1;