[zeromq-dev] HWM in 2.1

MinRK benjaminrk at gmail.com
Tue Jan 11 01:40:10 CET 2011


Can I ask when you downloaded pyzmq-dev?  That's a manual snapshot of pyzmq
master, and we didn't update it for a while.  If it was more than a few days
ago, can you download the current file and try again?

You can check that HWM is working by ensuring that the roundtrip value is
correct:

    s.setsockopt(zmq.HWM, 10)
    print s.getsockopt(zmq.HWM)

-MinRK


On Mon, Jan 10, 2011 at 16:34, Koert Kuipers <Koert.Kuipers at diamondnotch.com
> wrote:

>  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> 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
>
>
>
> _______________________________________________
> 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/20110110/fd536920/attachment.htm>


More information about the zeromq-dev mailing list