February 17, 2018 
< | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14 | 15 | 16 | 17 | 18 | 19 | 20 | 21 | 22 | 23 | 24 | 25 | 26 | 27 | 28 | >
February 17, 2018 [00:46:58] *** u19809 <u19809!5365053b@gateway/web/freenode/ip.83.101.5.59> has joined #zeromq[00:48:20] <u19809> hi all I have a problem with zmq_poll. when I cannot multiple REP clients at the same time to a ROUTER socket I do get the first message and see that all other clients have sent there messages but the poll does not seem to detect those and hence after the first message it blocks[00:49:04] <u19809> Should zmq_poll return immediately with the next pending request or should I read all pending requests once zmq_poll returns for the first message[00:57:50] <bluca> you should in any case, as it's a good and easy optimisation to do[01:03:48] <u19809> I tried with reading a message with ZMQ_NOBLOCK but that does not work for all socket types (e.g for a REP it does not)[01:04:34] <u19809> So should I really check for the socket type before reading all pending messages ? why cant poll do that more transparently ?[01:08:22] <bluca> what do you mean?[01:08:33] <bluca> poll will tell you excatly which sockets are ready to read from[01:10:16] <bluca> item[i].revents & ZMQ_POLLIN will be true if the i socket can be read from[01:10:53] <u19809> ok perhaps I need to rephrase. say poll returns POLLIN ready on socket A. In fact suppose 2 messages are available. So I read a message with zmq_msg_recv and process it. should I read the second message immediately after I processed the first or should I poll again and will poll return POLLIN again for the same socket A[01:12:03] <bluca> you can but poll is expensive so you can skip it if you want to optimise the data path[01:13:22] <u19809> Hmm. In my program I notice that when multiple clients send a message to a ROUTER socket, that ROUTER socket only finds the first pending message but poll blocks when I call it immediately after I processed that first message.[01:14:00] <u19809> I also tried queuing messages (using zmq_msg_recv with ZMQ_NOBLOCK flag) but that does not work for all socket types (e.g when REP is used it fails with an exception)[01:15:21] <u19809> will send a pastebin of my poller loop[01:16:38] <u19809> here you are https://pastebin.com/Gf3GBC8p[01:19:37] <bluca> mh you are using that c++ binding[01:19:43] <bluca> sorry I'm not really familiar with it[01:20:06] <u19809> ok[01:21:50] *** u19809 <u19809!5365053b@gateway/web/freenode/ip.83.101.5.59> has quit IRC (Quit: Page closed)[01:27:09] <bluca> what I can tell you is that doing non-blocking recv with rep sockets works just fine[01:27:18] <bluca> the flag is ZMQ_DONTWAIT[01:28:09] <bluca> well it's an alias of noblock[01:28:36] <bluca> of course you need to make sure that it's in the receive phase, otherwise it is a breach of the state machine[01:56:33] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has quit IRC (Quit: Leaving.)[02:03:29] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has quit IRC (Ping timeout: 248 seconds)[02:54:22] *** blf <blf!~blf@cpe-24-209-80-126.cinci.res.rr.com> has joined #zeromq[03:05:59] *** blf <blf!~blf@cpe-24-209-80-126.cinci.res.rr.com> has left #zeromq ("Textual IRC Client: www.textualapp.com")[03:09:22] *** Su-Shee <Su-Shee!~Susanne@p5B3757E9.dip0.t-ipconnect.de> has quit IRC (Disconnected by services)[03:09:30] *** Su-Shee <Su-Shee!~Susanne@p5B374448.dip0.t-ipconnect.de> has joined #zeromq[03:47:36] *** svm_invictvs <svm_invictvs!~svm_invic@unaffiliated/svminvictvs/x-938456> has quit IRC (Quit: My MacBook has gone to sleep. ZZZzzz…)[07:56:36] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[08:09:21] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 248 seconds)[08:11:13] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[08:17:35] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 240 seconds)[08:26:28] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[08:32:37] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 260 seconds)[08:41:36] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[08:47:41] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 255 seconds)[08:56:37] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[09:02:41] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 248 seconds)[09:11:37] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[09:17:50] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 276 seconds)[10:32:28] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[10:47:00] *** veegee <veegee!~veegee@CPE9050cac64033-CM9050cac64030.cpe.net.cable.rogers.com> has quit IRC (Read error: Connection reset by peer)[10:48:01] *** veegee <veegee!~veegee@CPE9050cac64033-CM9050cac64030.cpe.net.cable.rogers.com> has joined #zeromq[10:49:47] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 268 seconds)[11:24:30] *** asdsa <asdsa!27203131@gateway/web/freenode/ip.39.32.49.49> has joined #zeromq[11:24:32] <asdsa> test[11:24:59] *** asdsa <asdsa!27203131@gateway/web/freenode/ip.39.32.49.49> has quit IRC (Client Quit)[12:02:00] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has joined #zeromq[12:16:05] *** phx_ <phx_!~phoemix@marvin.harmless.hu> has joined #zeromq[12:16:22] *** phx <phx!~phoemix@freebsd/op/phx> has quit IRC (Read error: Connection reset by peer)[12:40:29] *** blazeme8` <blazeme8`!~blazeme8@downtime.rocks> has joined #zeromq[12:41:17] *** blazeme8 <blazeme8!~blazeme8@downtime.rocks> has quit IRC (Excess Flood)[12:41:17] *** awygle <awygle!~quassel@138.197.210.163> has quit IRC (Quit: No Ping reply in 180 seconds.)[12:41:17] *** R2ZER0 <R2ZER0!~quassel@46.43.8.105> has quit IRC (Remote host closed the connection)[12:41:35] *** awygle <awygle!~quassel@2604:a880:2:d0::5380:3001> has joined #zeromq[12:41:37] *** blazeme8` is now known as blazeme8[12:41:52] *** R2ZER0 <R2ZER0!~quassel@46.43.8.105> has joined #zeromq[12:45:22] *** strike_ <strike_!~strike@2.27.123.231> has quit IRC (Remote host closed the connection)[12:45:48] *** strike_ <strike_!~strike@2.27.123.231> has joined #zeromq[12:55:00] *** zoobab_ <zoobab_!zoobab@vic.ffii.org> has joined #zeromq[12:55:16] *** pfalleno1 <pfalleno1!~pfallenop@188.164.131.220> has joined #zeromq[12:56:15] *** desertje- <desertje-!~djf@outpost.cgx.org.uk> has joined #zeromq[12:58:52] *** strike_ <strike_!~strike@2.27.123.231> has quit IRC (Read error: Connection reset by peer)[12:58:53] *** Vaelatern_ <Vaelatern_!~Vaelatern@cpe-70-122-180-155.tx.res.rr.com> has joined #zeromq[12:59:20] *** strike_ <strike_!~strike@2.27.123.231> has joined #zeromq[13:00:07] *** kosm <kosm!~orybalch@unaffiliated/kosm> has quit IRC (*.net *.split)[13:00:07] *** Vaelatern <Vaelatern!~Vaelatern@cpe-70-122-180-155.tx.res.rr.com> has quit IRC (*.net *.split)[13:00:08] *** desertjellyfish <desertjellyfish!~djf@outpost.cgx.org.uk> has quit IRC (*.net *.split)[13:00:08] *** pfallenop <pfallenop!~pfallenop@unaffiliated/contempt> has quit IRC (*.net *.split)[13:00:08] *** zoobab <zoobab!zoobab@vic.ffii.org> has quit IRC (*.net *.split)[13:00:09] *** stutter <stutter!~stutter@50.16.91.24> has quit IRC (*.net *.split)[13:03:22] *** strike_ <strike_!~strike@2.27.123.231> has quit IRC (Remote host closed the connection)[13:03:53] *** strike_ <strike_!~strike@2.27.123.231> has joined #zeromq[13:06:20] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[13:06:56] *** kosm <kosm!~orybalch@unaffiliated/kosm> has joined #zeromq[13:09:36] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has joined #zeromq[13:12:57] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 264 seconds)[13:21:37] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[13:25:18] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has quit IRC (Quit: courrier)[13:27:40] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 240 seconds)[13:35:11] *** shinnya <shinnya!~shinnya@106.93.102.121.dy.bbexcite.jp> has quit IRC (Ping timeout: 248 seconds)[13:36:36] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[13:43:01] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 265 seconds)[13:45:57] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has quit IRC (Quit: Leaving.)[13:49:13] *** Perry_ <Perry_!dc880e76@gateway/web/freenode/ip.220.136.14.118> has joined #zeromq[13:50:11] *** Perry_ <Perry_!dc880e76@gateway/web/freenode/ip.220.136.14.118> has quit IRC (Client Quit)[13:51:36] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[13:53:27] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has joined #zeromq[13:54:26] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has quit IRC (Client Quit)[13:54:42] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has joined #zeromq[13:57:05] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 248 seconds)[14:06:25] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[14:12:10] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 240 seconds)[14:21:28] *** dha0378 <dha0378!~dha0378@46.140.182.18> has joined #zeromq[14:27:21] *** dha0378 <dha0378!~dha0378@46.140.182.18> has quit IRC (Ping timeout: 264 seconds)[14:50:04] *** shinnya <shinnya!~shinnya@106.93.102.121.dy.bbexcite.jp> has joined #zeromq[14:59:22] *** stutter <stutter!~stutter@50.16.91.24> has joined #zeromq[15:10:25] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has joined #zeromq[15:17:05] *** shinnya <shinnya!~shinnya@106.93.102.121.dy.bbexcite.jp> has quit IRC (Ping timeout: 240 seconds)[16:21:28] *** opedroso <opedroso!~opedroso@97.80.224.163> has joined #zeromq[16:38:33] *** opedroso <opedroso!~opedroso@97.80.224.163> has left #zeromq[16:39:06] *** opedroso <opedroso!~opedroso@97.80.224.163> has joined #zeromq[16:39:28] *** opedroso <opedroso!~opedroso@97.80.224.163> has left #zeromq[18:11:33] *** strike_ <strike_!~strike@2.27.123.231> has quit IRC (Quit: Konversation terminated!)[18:12:04] *** listenmore <listenmore!~strike@2.27.123.231> has joined #zeromq[19:10:01] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has quit IRC (Quit: Leaving.)[19:48:58] *** desertje- is now known as wuestenqualle[20:27:00] *** shinnya <shinnya!~shinnya@106.93.102.121.dy.bbexcite.jp> has joined #zeromq[20:45:57] *** markos_ <markos_!~markos@static062038151250.dsl.hol.gr> has quit IRC (Ping timeout: 264 seconds)[21:51:09] *** svm_invictvs <svm_invictvs!~svm_invic@unaffiliated/svminvictvs/x-938456> has joined #zeromq[22:11:47] *** Su-Shee <Su-Shee!~Susanne@p5B374448.dip0.t-ipconnect.de> has quit IRC (Disconnected by services)[22:11:55] *** Su-Shee <Su-Shee!~Susanne@p5B374A18.dip0.t-ipconnect.de> has joined #zeromq[22:19:12] *** svm_invictvs <svm_invictvs!~svm_invic@unaffiliated/svminvictvs/x-938456> has quit IRC (Quit: My MacBook has gone to sleep. ZZZzzz…)[22:35:35] *** svm_invictvs <svm_invictvs!~svm_invic@unaffiliated/svminvictvs/x-938456> has joined #zeromq[22:38:42] *** svm_invictvs <svm_invictvs!~svm_invic@unaffiliated/svminvictvs/x-938456> has quit IRC (Client Quit)[22:58:40] *** courrier <courrier!~yoan@119.135.185.81.rev.sfr.net> has quit IRC (Remote host closed the connection)[22:58:53] *** courrier <courrier!~yoan@81.185.135.119> has joined #zeromq[23:03:20] *** shinnya <shinnya!~shinnya@106.93.102.121.dy.bbexcite.jp> has quit IRC (Ping timeout: 276 seconds)[23:23:30] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has joined #zeromq[23:48:14] *** courrier_ <courrier_!~yoan@119.135.185.81.rev.sfr.net> has joined #zeromq[23:52:39] *** courrier <courrier!~yoan@81.185.135.119> has quit IRC (Ping timeout: 260 seconds)[23:54:08] *** bluca <bluca!~bluca@2a00:23c5:be85:1400:6930:196b:56ac:33db> has quit IRC (Ping timeout: 276 seconds)