[zeromq-dev] Blocking after 2000 sent messages

Garrett Smith g at rre.tt
Thu Dec 19 00:09:52 CET 2013


I omitted these details, I actually have this brutally set:

    zsocket_set_sndhwm(output, 0);
    zsocket_set_rcvhwm(output, 0);
    zsocket_set_sndhwm(input, 0);
    zsocket_set_rcvhwm(input, 0);

The output ends at "2000" (blocking send) - same as when the HWMs aren't set.

On Wed, Dec 18, 2013 at 4:03 PM, KIU Shueng Chuan <nixchuan at gmail.com> wrote:
> For inproc, the effective hwm is the sum of the send and recv hwm. Default
> of 1000 per side gives 2000.
>
> To set hwm to unlimited, you would need to set both send and recv hwm to 0.
> You didn't say at which number it blocks after you set only the send hwm to
> 0.
>
> On Dec 19, 2013 5:20 AM, "Garrett Smith" <g at rre.tt> wrote:
>>
>> I'm using czmq. This code:
>>
>>     zctx_t *ctx = zctx_new ();
>>
>>     void *output = zsocket_new (ctx, ZMQ_PAIR);
>>     zsocket_bind (output, "inproc://zstr.test");
>>     void *input = zsocket_new (ctx, ZMQ_PAIR);
>>     zsocket_connect (input, "inproc://zstr.test");
>>
>>     int i;
>>     for (i = 0; i < 3000; i++) {
>>         fprintf (stderr, " %i", i);
>>         zstr_send (output, "this is string %d", i);
>>     }
>>
>> will print up to "2000" and then block.
>>
>> As this behavior is (seems to be) governed by sndhwm - I set it to 0
>> to on output disable it:
>>
>>     zsocket_set_sndhwm (output, 0);
>>
>> But I'm seeing the same behavior.
>>
>> I've read The Guide, bought Pieter's book, given presentations on 0MQ
>> at conferences and *even* read the API docs. Now I'm trying crowd
>> sourcing -- is there an obvious explanation to someone?
>>
>> Garrett
>> _______________________________________________
>> zeromq-dev mailing list
>> zeromq-dev at lists.zeromq.org
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>



More information about the zeromq-dev mailing list