[Time] Name | Message |
[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 <sustrik@250bpm.com> - http://bit.ly/eLjdU0
|
[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 <sustrik@250bpm.com> - http://bit.ly/gAfivp
|
[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 <sustrik@250bpm.com> - http://bit.ly/gdt449
|
[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 <sustrik@250bpm.com> - http://bit.ly/eV0jas
|
[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
|
https://gist.github.com/cd0cd7d8407c30456c23
|
[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 http://valokuva.org/~mikko/0002-Added-test-for-HWM.patch
|
[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 http://nullege.com/ - hopefully they'll work.
|
[15:29] mikko
|
mvolkov: https://github.com/zeromq/pyzmq/tree/master/examples
|
[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 <sustrik@250bpm.com> - http://bit.ly/i0HCXP
|
[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?
|