diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-03-24 16:47:33 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-03-24 16:47:33 +0100 |
commit | bc4a1ce3345f4e5904e4b13c618f90def21256a5 (patch) | |
tree | 0e95c952f0a5464f5edb515e7d16644e76515a85 /tests | |
parent | 507718ee1a56e376c06389c513de3868297fec35 (diff) |
ZMQ_HWM split into ZMQ_SNDHWM and ZMQ_RCVHWM
These new options allow to control the maximum size of the
inbound and outbound message pipe separately.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'tests')
-rw-r--r-- | tests/test_hwm.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tests/test_hwm.cpp b/tests/test_hwm.cpp index a96193d..9f3aac1 100644 --- a/tests/test_hwm.cpp +++ b/tests/test_hwm.cpp @@ -33,14 +33,14 @@ int main (int argc, char *argv []) void *sb = zmq_socket (ctx, ZMQ_PULL); assert (sb); int hwm = 2; - int rc = zmq_setsockopt (sb, ZMQ_HWM, &hwm, sizeof (hwm)); + int rc = zmq_setsockopt (sb, ZMQ_RCVHWM, &hwm, sizeof (hwm)); assert (rc == 0); rc = zmq_bind (sb, "inproc://a"); assert (rc == 0); void *sc = zmq_socket (ctx, ZMQ_PUSH); assert (sc); - rc = zmq_setsockopt (sc, ZMQ_HWM, &hwm, sizeof (hwm)); + rc = zmq_setsockopt (sc, ZMQ_SNDHWM, &hwm, sizeof (hwm)); assert (rc == 0); rc = zmq_connect (sc, "inproc://a"); assert (rc == 0); |