ZMQ_LINGER not work
Description
Environment
None
Activity
Show:
PieterP May 5, 2012 at 8:22 AM
Duplicate of LIBZMQ-264, closing.
kris wang May 3, 2012 at 11:14 AM
one thread:
while(1)
s_send(sender, "test");
another thread:
context = zmq_init(1);
void *sender = zmq_socket(context, ZMQ_PUSH);
uint64_t hwm = 10;
zmq_setsockopt( sender , ZMQ_HWM, &hwm, sizeof(hwm));
uint64_t linger = 0;
zmq_setsockopt( sender , ZMQ_LINGER, &linger, sizeof(linger));
zmq_connect(sender, tcp://10.11.18.41:6666 );:
sleep(10);
zmq_close(sender);
sender = zmq_socket(context, ZMQ_PUSH);
uint64_t hwm = 10;
zmq_setsockopt( sender , ZMQ_HWM, &hwm, sizeof(hwm));
uint64_t linger = 0;
zmq_setsockopt( sender , ZMQ_LINGER, &linger, sizeof(linger));
zmq_connect(sender, tcp://10.11.18.42:6666 );:
2012/5/3 Ian Barber (JIRA) <jira@zeromq.jira.com>
Ian Barber May 3, 2012 at 9:37 AM
Can you attach a code example of the problem so we can try and reproduce?
Hi,
I use push-pull,
set ZMQ_LINGER to 0,
zmq_close(mySocket), then
pending messages do not be discarded immediately, but until the pending messages reach ZMQ_HWM and then block.
So the ZMQ_LINGER seems not work.
Thank you very much.