[zeromq-dev] zeromq-dev Digest, Vol 40, Issue 57

Sat Apr 16 20:49:24 CEST 2011

Unsubscribe
On Apr 16, 2011 2:48 PM, <zeromq-dev-request at lists.zeromq.org> wrote:
> Send zeromq-dev mailing list submissions to
> zeromq-dev at lists.zeromq.org
>
> To subscribe or unsubscribe via the World Wide Web, visit
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
> or, via email, send a message with subject or body 'help' to
> zeromq-dev-request at lists.zeromq.org
>
> You can reach the person managing the list at
> zeromq-dev-owner at lists.zeromq.org
>
> When replying, please edit your Subject line so it is more specific
> than "Re: Contents of zeromq-dev digest..."
>
>
> Today's Topics:
>
> 1. PGM subscriber assert failure (Advait Alai)
> 2. Re: PGM subscriber assert failure (Martin Sustrik)
> 3. Re: PGM subscriber assert failure (Advait Alai)
> 4. Re: PGM subscriber assert failure (Martin Sustrik)
> 5. Re: PGM subscriber assert failure (Martin Sustrik)
> 6. Re: PGM subscriber assert failure (Advait Alai)
> 7. Re: PGM subscriber assert failure (Martin Sustrik)
> 8. Re: libzutil - utility library (Paul Colomiets)
>
>
> ----------------------------------------------------------------------
>
> Message: 1
> Date: Sat, 16 Apr 2011 19:04:31 +0530
> From: Advait Alai <advaitalai at gmail.com>
> Subject: [zeromq-dev] PGM subscriber assert failure
> To: zeromq-dev at lists.zeromq.org
> Message-ID: <BANLkTima3AqcBVQqhmsQFO+RGGQmYqm2PA at mail.gmail.com>
> Content-Type: text/plain; charset="iso-8859-1"
>
> Hello,
>
> I'm getting the following error when I try to use the epgm protocol on a
> subscriber:
>
> Assertion failed: rc == 0 (connect_session.cpp:96)
> Aborted
>
> The publisher publishes messages using epgm without any problem
>
> What's wrong?
>
> =============
> Publisher Code (simply publishes messages every 0.1s):
> =============
>
> # ZMQ Context
>
>
> context = zmq.Context()
>
>
>
>
> # Socket to talk to clients
>
>
> socket = context.socket(zmq.PUB)
>
>
>
> # Localhost IP is 10.0.66.1
> socket.bind('epgm://10.0.66.1:5561')
>
>
>
> while True:
> msg_str = str(time.time())
>
> socket.send(msg_str)
>
>
> print "Published", msg_str
>
>
> cnt += 1
>
>
> time.sleep(0.1)
>
> =============
> Subscriber code:
> =============
>
> # Socket to talk to server
>
>
> context = zmq.Context()
>
>
> client_socket = context.socket(zmq.SUB)
>
>
>
>
>
> client_socket.setsockopt(zmq.SUBSCRIBE, "")
>
>
>
>
>
> # Remote publisher IP is 10.0.66.1
>
>
> client_socket.connect ("epgm://10.0.66.1:5561")
>
>
>
>
>
> # Process 5 updates
>
>
> while True:
>
>
> string = client_socket.recv() # Assert error here
>
>
> print string
> -------------- next part --------------
> An HTML attachment was scrubbed...
> URL:
http://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110416/f7dd4086/attachment-0001.htm
>
> ------------------------------
>
> Message: 2
> Date: Sat, 16 Apr 2011 17:13:27 +0200
> From: Martin Sustrik <sustrik at 250bpm.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Cc: Advait Alai <advaitalai at gmail.com>
> Message-ID: <4DA9B217.10704 at 250bpm.com>
> Content-Type: text/plain; charset=ISO-8859-1; format=flowed
>
> On 04/16/2011 03:34 PM, Advait Alai wrote:
>
>> # Localhost IP is 10.0.66.1
>> socket.bind('epgm://10.0.66.1:5561')
>
> There's address of the multicast group missing AFAICS.
>
> Martin
>
>
>
> ------------------------------
>
> Message: 3
> Date: Sat, 16 Apr 2011 21:46:10 +0530
> From: Advait Alai <advaitalai at gmail.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: Martin Sustrik <sustrik at 250bpm.com>
> Cc: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Message-ID: <BANLkTim-v7BN=5gdq5sscYf8GbAZUVeqZg at mail.gmail.com>
> Content-Type: text/plain; charset="iso-8859-1"
>
> Martin,
>
> Thanks for the reply.
>
> This is my first time using multicast with ZeroMQ. Following
> http://www.zeromq.org/whitepapers:design-v05, I set the multicast group as
> socket.bind('epgm://eth0;225.0.0.1:5555').
>
> Now I get an assertion error on the publisher, as
>
> Assertion failed: rc == 0 (connect_session.cpp:84)
> Aborted
>
> Does this have something to do with setting ZMQ_RATE? (
> http://www.mail-archive.com/zeromq-dev@lists.zeromq.org/msg07026.html)
>
> Also, how do I add the subscriber to the multicast group 255.0.0.1? Or
would
> the socket.connect('epgm://...') in the subscriber implicitely do that?
>
> Thanks
>
>
> On Sat, Apr 16, 2011 at 8:43 PM, Martin Sustrik <sustrik at 250bpm.com>
wrote:
>
>> On 04/16/2011 03:34 PM, Advait Alai wrote:
>>
>> # Localhost IP is 10.0.66.1
>>> socket.bind('epgm://10.0.66.1:5561')
>>>
>>
>> There's address of the multicast group missing AFAICS.
>>
>> Martin
>>
>>
> -------------- next part --------------
> An HTML attachment was scrubbed...
> URL:
http://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110416/50566042/attachment-0001.htm
>
> ------------------------------
>
> Message: 4
> Date: Sat, 16 Apr 2011 18:26:56 +0200
> From: Martin Sustrik <sustrik at 250bpm.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: Advait Alai <advaitalai at gmail.com>
> Cc: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Message-ID: <4DA9C350.7070206 at 250bpm.com>
> Content-Type: text/plain; charset=ISO-8859-1; format=flowed
>
> On 04/16/2011 06:16 PM, Advait Alai wrote:
>
>> This is my first time using multicast with ZeroMQ. Following
>> http://www.zeromq.org/whitepapers:design-v05,
>
> Note that the whitepaper is marked as deprecated.
>
> Use zmq_pgm(7) instead.
>
>> I set the multicast group as
>> socket.bind('epgm://eth0;225.0.0.1:5555').
>
> "In IPv4, addresses 224.0.0.0 through 239.255.255.255 are designated as
> multicast addresses."
>
> Anyway, the code should not assert, rather return an error. However, I
> don't have hardware infrastructure to test multicast. Others may help
here.
>
> Martin
>
>
>
> ------------------------------
>
> Message: 5
> Date: Sat, 16 Apr 2011 18:33:35 +0200
> From: Martin Sustrik <sustrik at 250bpm.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Cc: Advait Alai <advaitalai at gmail.com>
> Message-ID: <4DA9C4DF.6060302 at 250bpm.com>
> Content-Type: text/plain; charset=ISO-8859-1; format=flowed
>
> On 04/16/2011 06:26 PM, Martin Sustrik wrote:
>
>>> I set the multicast group as
>>> socket.bind('epgm://eth0;225.0.0.1:5555').
>>
>> "In IPv4, addresses 224.0.0.0 through 239.255.255.255 are designated as
>> multicast addresses."
>
> Ooops. It *is* in the range. I read 255.0.0.1. Sorry.
>
> Martin
>
>
> ------------------------------
>
> Message: 6
> Date: Sat, 16 Apr 2011 23:01:05 +0530
> From: Advait Alai <advaitalai at gmail.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: Martin Sustrik <sustrik at 250bpm.com>
> Cc: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Message-ID: <BANLkTiks_yyyN4xnDeHUCySia1cK1NCTzg at mail.gmail.com>
> Content-Type: text/plain; charset="iso-8859-1"
>
> Ah, okay, I got the publisher to work with socket.bind("epgm://10.0.66.1;
> 225.0.0.1:5555")
>
> But now, the subscriber does not receive messages from the publisher (The
> socket.recv call just blocks without printing any receive notifications).
I
> am using a similar call in the subscriber: socket.connect("epgm://
10.0.22.1;
> 225.0.0.1:5555"), where 10.0.22.1 is the address of the subscriber net
> interface.
>
> Is this because the routers en-route are not forwarding multicast packets?
> How do I make them do so?
>
>
>> Anyway, the code should not assert, rather return an error. However, I
>> don't have hardware infrastructure to test multicast. Others may help
here.
>>
>
> FWIW, I'm not using extra hardware either. The publisher and subscriber
are
> VMs connected by a simulated NS-3 router (all on the same machine)
> -------------- next part --------------
> An HTML attachment was scrubbed...
> URL:
http://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110416/45b8d658/attachment-0001.htm
>
> ------------------------------
>
> Message: 7
> Date: Sat, 16 Apr 2011 19:37:20 +0200
> From: Martin Sustrik <sustrik at 250bpm.com>
> Subject: Re: [zeromq-dev] PGM subscriber assert failure
> To: Advait Alai <advaitalai at gmail.com>
> Cc: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Message-ID: <4DA9D3D0.70407 at 250bpm.com>
> Content-Type: text/plain; charset=ISO-8859-1; format=flowed
>
> On 04/16/2011 07:31 PM, Advait Alai wrote:
>
>> Is this because the routers en-route are not forwarding multicast
>> packets? How do I make them do so?
>
> AFAIK the routers are configured by default not to forward multicast
> packets.
>
> However, I am not an expert in the area. Others may be able to give more
> detailed explanation.
>
> Martin
>
>
>
> ------------------------------
>
> Message: 8
> Date: Sat, 16 Apr 2011 21:47:56 +0300
> From: Paul Colomiets <tailhook at yandex.ua>
> Subject: Re: [zeromq-dev] libzutil - utility library
> To: ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> Message-ID: <358461302979676 at web124.yandex.ru>
> Content-Type: text/plain; charset=koi8-r
>
> Hi Peter,
>
> 15.04.2011, 19:38, "Pieter Hintjens" <ph at imatix.com>:
>> Hi all,
>>
>> I'd like to start the discussion of a utility library, libzutil. ?This
>> should be a thin layer on top of libzmq, wrapped by all bindings.
>> [.. snip ..]
>> * Provide a set of clock and timer functions (which aren't otherwise
portable).
>
> I think clock and timer functions should be contained in a library, which
has
> a main loop. Unless you need them for devices or other library functions,
> do you? You seems to have main loop in libzapi, not libzutil.
>
> BTW, whats relationship between libzapi and libzutil?
>
>> * Provide a thread creation API (which is otherwise not portable).
>>
> Most languages has their own thread creation API. Doesn't this would
> conflict with languages' threads on any platforms?
>
>> ++ Devices
>> * A //router// device that switches messages in and out of a front-end
>> ROUTER socket, switching addresses during each cross-over.
>
> I don't understand what this means. Is it LRU broker or some helper
> for building custom broker?
>
> --
> Paul
>
>
> ------------------------------
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
> End of zeromq-dev Digest, Vol 40, Issue 57
> ******************************************
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110416/3521a1b3/attachment.htm>