[zeromq-dev] HWM in 2.1

Koert Kuipers Koert.Kuipers at diamondnotch.com
Tue Jan 11 01:34:52 CET 2011


Sure. On 2010-01-05 I downloaded zeromq-2.1.0.tar.gz (released on 2010/12/01 it says) and pyzmq-dev.tar.gz (from the available downloads on the git page). I still have the files…. Can mail them if that helps.
Best,
Koert


From: zeromq-dev-bounces at lists.zeromq.org [mailto:zeromq-dev-bounces at lists.zeromq.org] On Behalf Of MinRK
Sent: Sunday, January 09, 2011 10:46 PM
To: ZeroMQ development list
Subject: Re: [zeromq-dev] HWM in 2.1

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<mailto: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> [mailto: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<mailto: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/20110110/f79e7dd5/attachment.htm>


More information about the zeromq-dev mailing list