Saturday January 15, 2011

[Time] NameMessage
[00:34] mvolkov I am the first day 0MQ user and after going through docs I understand that 0MQ has capability of doing multiplexing between a few sockets with zmq_poll() function
[00:35] mvolkov however, I can't seems to find how one define a list of resources/items in Python
[00:37] mvolkov Can anyone please give me a hint? Or white paper or doc link?
[00:37] mvolkov on this topic?
[11:16] mikko mvolkov: there should be examples of poll under pyzmq github
[11:40] CIA-21 zeromq2: 03Martin Sustrik 07sub-forward * rbe94000 10/ (5 files):
[11:40] CIA-21 zeromq2: Forwarding subscriptions up the stream implemented
[11:40] CIA-21 zeromq2: Signed-off-by: Martin Sustrik <> -
[11:40] CIA-21 zeromq2: 03Martin Sustrik 07sub-forward * r706296d 10/ (src/trie.cpp src/trie.hpp src/xsub.cpp src/xsub.hpp):
[11:40] CIA-21 zeromq2: Subscriptions from XSUB socketare sent to each new peer.
[11:40] CIA-21 zeromq2: Signed-off-by: Martin Sustrik <> -
[11:40] CIA-21 zeromq2: 03Martin Sustrik 07sub-forward * r3d26c3d 10/ (5 files):
[11:40] CIA-21 zeromq2: econnection should now trigger subscription re-sending
[11:40] CIA-21 zeromq2: Signed-off-by: Martin Sustrik <> -
[11:47] CIA-21 zeromq2: 03Martin Sustrik 07sub-forward * rbb605e0 10/ src/pub.cpp :
[11:47] CIA-21 zeromq2: Print out subscriptions in PUB socket (for testing purposes)
[11:47] CIA-21 zeromq2: Signed-off-by: Martin Sustrik <> -
[11:47] mikko sustrik: busy morning!
[11:47] sustrik mikko: morning
[11:48] sustrik i finally found some time to spent on subscription forwarding
[11:50] mikko sustrik: did you see my paste from yesterday?
[11:50] sustrik no
[11:50] sustrik let me see
[11:50] mikko
[11:51] sustrik hm, hard to say
[11:51] sustrik it depends much on the timing
[11:51] sustrik zmq_close is async
[11:51] sustrik so the socket may actually still exist at the time you are sending second message
[11:52] sustrik so it gets the message and terminates
[11:52] mikko i tried adding sleep(5); before the second message
[11:52] mikko but that didn't work
[11:52] sustrik same thing?
[11:52] sustrik that it looks like a bug imo
[11:52] sustrik can you fill in a ticket?
[11:52] mikko this is actually one of the test cases i've been preparing
[11:53] sustrik great
[11:53] mikko HWM and identity
[11:53] mikko testing with sleep 20 now
[11:53] mikko just in case
[11:54] mikko hmm, i could also try running the subscriber in it's own thread
[11:59] sustrik mikko: i assume it's a bug
[11:59] sustrik the test looks ok
[12:01] mikko i'll open issue
[12:09] mikko issue #150
[12:10] mikko the HWM test-case is in
[12:14] sustrik thanks
[12:41] jugg sustrik, such a minor single word change to warrant a patch... The pull request was just so it got noticed, not so I got credit... but anyway.
[12:57] sustrik jugg: as you wish
[12:57] sustrik let me fix it
[12:58] sustrik jugg: have you sent the patch or not?
[12:59] jugg I did...
[12:59] sustrik haven't got it yet
[13:00] jugg I use gmane, sometimes it moves slowly.
[13:00] sustrik np
[13:00] jugg anyway, if it doesn't show up, feel free to make the change on your own.
[13:00] sustrik sure
[13:01] sustrik it's kind of strange following the process for trivial changes like this one
[13:01] sustrik but it's hard to set a boundary between trivial and non-trivial
[14:04] gancient hi all, i am trying to implement a distributed matrix multiplication algorithm in python using zmq , what would be the best approach ? (I am new to zmq , so any suggestions / comments are useful )
[15:29] mvolkov mikko: Thank you for the answer. The issue is the not all zguide tutorial examples are translated to Python, however, I found examples at - hopefully they'll work.
[15:29] mikko mvolkov:
[15:30] mvolkov oh... then we are talking about the same thing. Thank you
[18:31] mikko sustrik: seems like msvc build files are out of date (?)
[19:07] sustrik mikko: right
[19:07] sustrik let me fix it
[19:15] CIA-21 zeromq2: 03Martin Sustrik 07master * ra249d15 10/ builds/msvc/libzmq/libzmq.vcproj :
[19:15] CIA-21 zeromq2: Fix MSVC build
[19:15] CIA-21 zeromq2: Signed-off-by: Martin Sustrik <> -
[19:17] sustrik mikko: ok, done
[21:13] mikko sustrik_: thanks
[23:13] mvolkov Q: is there a way in 0MQ to know whether socked is busy doing something so message is not sent until it is ready?
[23:15] mvolkov or in 0MQ terminology how this "check and wait" behavior would be called?
[23:15] mvolkov appreciate any input
[23:22] mikko mvolkov: there are different kind of behaviors with different socket types
[23:22] mikko mvolkov: for example PUB socket drops the message if there are no subscribers
[23:23] mikko mvolkov: im not sure whether this answers your question as i am not sure what "socket is busy doing something" means
[23:54] Skaag mikko: is this channel logged somewhere?