Will this work? The comment around that code states that LWM must be less than HWM. Probably should just enforce that HWM > 1 ? Cheers, Brian
On Fri, Jul 23, 2010 at 6:20 PM, Matt Weinstein <[email protected]> wrote: > Yes, rounding up would probably be better :-) > > LWM = (HWM + 1) / 2 > > Best, > > Matt > > On Jul 23, 2010, at 12:03 PM, Brian Murphy wrote: > >> Looking at the code it seems that the LWN is calculated as HWM/2 if is >> less than 500. Thus in this case LWM gets set to zero. >> ( pipe.cpp:319 ) >> Probably a bug but as you said not really important because HWM of 1 >> is not a very useful value, I'm not sure what a valid value of LWM >> would be in this case. >> Cheers, >> Brian >> >> On Fri, Jul 23, 2010 at 4:50 PM, ilejncs <[email protected]> wrote: >>> Hello, >>> 0mq people. >>> >>> It looks like '1' is a special HWM value. >>> >>> If it is set for DOWNSTREAM socket, >>> it is never possible to send second message (assuming server side >>> is Ok) via such socket. >>> >>> The behavior is consistent: application blocks on the second send >>> or on poll in case of NONBLOCK mode. >>> >>> I assume the roots of the issue are somewhere near ypipe_t::flush, >>> though not sure. >>> >>> If it is a bug, it is not really important because '1' is rather >>> strange queue length. >>> If it is a feature, the description is appreciated. >>> >>> Thanks. >>> >>> == >>> Best regards and nice weekend, >>> Ilja Golshtein. >>> _______________________________________________ >>> zeromq-dev mailing list >>> [email protected] >>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev >>> >> _______________________________________________ >> zeromq-dev mailing list >> [email protected] >> http://lists.zeromq.org/mailman/listinfo/zeromq-dev > > _______________________________________________ > zeromq-dev mailing list > [email protected] > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > _______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
