> -----Message d'origine----- > De : Martin Sustrik [mailto:sust...@250bpm.com] > Envoyé : 9 mai 2011 01:19 > À : Fabien Ninoles; ZeroMQ development list > Objet : Re: [zeromq-dev] Feedback on new PATCH socket > > If what you meant was propagating an "END" message gradually through > the topology, there's still problem of dead/misbehaving nodes. If a > node receives a request and never sends an END message, it'll deadlock > the whole topology.
I think we talking almost about the same thing here. As I said previously, I made a small prototype which behave quite nicely for what I test. It has both a timeout that it propagates down the stream, and also propagate an end message upstream after it consider everything is finish. I used only XREP/XREQ sockets for this but that's only because that's the only way I know to access individual downstream connection. It is still in early stage and probably can be better done. It's the first time I used a ROUTER/ROUTER device out of an LRU queue, so I've certainly overseen some issues, especially in regards to message queues on timeout/error. But the code is here: http://www.tzone.org/~fabien/hg/collector/ Fabien _______________________________________________ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev
