[zeromq-dev] HWM in 2.1
MinRK
benjaminrk at gmail.com
Mon Jan 10 04:46:25 CET 2011
I don't see this behavior with current git HEAD of pyzmq and zeromq. Can
you provide details about exact revision of each?
-MinRK
On Sun, Jan 9, 2011 at 14:23, Koert Kuipers
<Koert.Kuipers at diamondnotch.com>wrote:
> I do not see same behavior in Java. Does it have something to do with
> python bindings for 2.1.0 (pyzmq-2.1.0dev)?
>
>
>
> ********** Test.java **********
>
> import org.zeromq.ZMQ;
>
>
>
> public class Test {
>
> public static void main(String[] args) {
>
> final ZMQ.Context context = ZMQ.context(1);
>
> final ZMQ.Socket socket = context.socket(ZMQ.PUSH);
>
> socket.setHWM(100);
>
> socket.connect("tcp://localhost:5051");
>
> for (int i=0; i <1000; i++) {
>
> socket.send(new byte[0], 0);
>
> System.out.println(i);
>
> }
>
> }
>
> }
>
>
>
> *From:* zeromq-dev-bounces at lists.zeromq.org [mailto:
> zeromq-dev-bounces at lists.zeromq.org] *On Behalf Of *Koert Kuipers
> *Sent:* Sunday, January 09, 2011 4:50 PM
> *To:* ZeroMQ development list
> *Subject:* [zeromq-dev] HWM in 2.1
>
>
>
> The little python program below connects to a socket where nobody is
> listening. With zmq 2.0.10 it would halt after 100 messages. However with
> zmq 2.1.0 it keeps going all the way to 1000 messages. Why is this? I see
> this behavior both under Linux and Windows.
>
> Koert
>
>
>
> ********** test.py **********
>
> import zmq
>
> context = zmq.Context()
>
> socket = context.socket(zmq.PUSH)
>
> socket.setsockopt(zmq.HWM, 100)
>
> socket.connect("tcp://localhost:5051")
>
> for i in range(1, 1000):
>
> socket.send('')
>
> print i
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110109/040f1234/attachment.htm>
More information about the zeromq-dev
mailing list