Re: [zeromq-dev] about using ZMQ_FD in an external select loop

2012-09-06 Thread diffuser78
. At least I don't see a reason why zmq would > want to > bother the app about this. That said, even if ZMQ_FD gets indicated as > readable more often than necessary, you should simply get the resulting > ZMQ_EVENTS and act on them. > > On Thursday, September 06, 2012 04:24:43

Re: [zeromq-dev] about using ZMQ_FD in an external select loop

2012-09-06 Thread diffuser78
until new bytes are available for reading on this fd? What is ZMQ behavior in this case. Any help is greatly appreciated. Thanks. On Wed, Sep 5, 2012 at 5:41 PM, diffuser78 wrote: > Hi, > > I am using a ZMQ FD in an external select() loop, that is, a ZMQ FD is > added to the se

[zeromq-dev] about zmq_poll implementation

2012-09-05 Thread diffuser78
Hi, I am using a ZMQ FD in an external select() loop, that is, a ZMQ FD is added to the set of fds (regular unix fds) in an external select loop. Consider a situation, for a given message (in a router dealer pattern), only a few bytes are received at the receiver end and not the complete message,

Re: [zeromq-dev] quick question regarding getting EAGAIN

2012-08-08 Thread diffuser78
I wanted this on the router socket in my implementation. Thanks. On Wed, Aug 8, 2012 at 1:01 PM, Ian Barber wrote: > On Wed, Aug 8, 2012 at 7:13 PM, diffuser78 wrote: > > I did a git pull and then git grep'd for this but I can't find this in > the > > 3.x tree ? &g

Re: [zeromq-dev] quick question regarding getting EAGAIN

2012-08-08 Thread diffuser78
> On 08/08/2012 12:23 PM, diffuser78 wrote: > > Can someone please let me know their thoughts on it ? > > > > On Tue, Aug 7, 2012 at 1:55 PM, diffuser78 > <mailto:diffuse...@gmail.com>> wrote: > > > > Hi, > > My app is using a dealer socket

Re: [zeromq-dev] quick question regarding getting EAGAIN

2012-08-08 Thread diffuser78
Can someone please let me know their thoughts on it ? On Tue, Aug 7, 2012 at 1:55 PM, diffuser78 wrote: > Hi, > > My app is using a dealer socket, while the remote app is router > socket.From my knowledg after reading zguide is that ZMQ buffers the > message even if the remote a

[zeromq-dev] quick question regarding getting EAGAIN

2012-08-07 Thread diffuser78
Hi, My app is using a dealer socket, while the remote app is router socket.From my knowledg after reading zguide is that ZMQ buffers the message even if the remote app is not bound. Can I change this behavior in Dealer socket to return me EAGAIN immediately if the remote app is not bound ? Is this

Re: [zeromq-dev] question about integrating zmq socket fd in external select() loop

2012-08-06 Thread diffuser78
Can someone plz share their experiences around this problem ? On Fri, Aug 3, 2012 at 3:38 PM, diffuser78 wrote: > Hi, > > I am writing a lib that uses zmq. This lib is going to be used in an app > that already has an external select() loop. Can I use fd's retrieved f

[zeromq-dev] question about integrating zmq socket fd in external select() loop

2012-08-03 Thread diffuser78
Hi, I am writing a lib that uses zmq. This lib is going to be used in an app that already has an external select() loop. Can I use fd's retrieved from ZMQ_FD from zmq_getsockopt() in that select loop successfully ? Are there examples already that tell you how to do it ? Are there any things that

[zeromq-dev] How to get reliability in pub-sub pattern

2012-07-30 Thread diffuser78
Hi, >From ZMQ guide I see that pub-sub pattern does not offer reliability, i.e. publisher doesn't know if the subscriber has been consuming messages. What other pattern would you recommend in pub-sub scenario where a publisher must know the details of subscribers and how many messages subscribers

Re: [zeromq-dev] looking inside ZMQ queue

2012-07-30 Thread diffuser78
lent . Queues also help in knowing if the other side has received > it. > > Ben > > > > On Sat, Jul 28, 2012 at 2:27 AM, diffuser78 wrote: > >> Sorry about my ignorance and laziness. I read this on the FAQ page: >> >> >> *How do I determine how many

Re: [zeromq-dev] looking inside ZMQ queue

2012-07-27 Thread diffuser78
can create a patch for it and send for review. Any thoughts are greatly appreciated. DJ On Fri, Jul 27, 2012 at 11:16 AM, Ian Barber wrote: > On Fri, Jul 27, 2012 at 6:26 PM, diffuser78 wrote: > > What I want to know is that, ZMQ might have returned success upon > buffering >

[zeromq-dev] looking inside ZMQ queue

2012-07-27 Thread diffuser78
Hi All, I read the zguide and couldn't find the answer to it. I wanted to know if there is a deterministic way to find out if a message that I sent has actually reached the other end. Let me explain the scenario in detail. I am writing a lib (wrapped around ZMQ) for my app. App sends a message M

[zeromq-dev] Quick question on usage of patterns

2012-07-12 Thread Diffuser78
Hello All, I need some suggestion on my design and ways in which it can be done using ZMQ sockets. I have an app App1 on Box1. It sends a message M1 (128K) to an app App2 on Box2. App2 will do some processing on M1 before sending an ACK back. In my application, I also want to send an ACK back t

Re: [zeromq-dev] Design Suggestion for simple app using zmq

2012-07-06 Thread Diffuser78
hanks. On Thu, Jul 5, 2012 at 7:52 PM, Joshua Foster wrote: > Are the ACK's async? If they are not, you can use the REQ socket instead. > Are you using multiple threads? > > Joshua > > On Jul 5, 2012, at 7:58 PM, Diffuser78 wrote: > > Anyone ? > > On Thu, J

Re: [zeromq-dev] Design Suggestion for simple app using zmq

2012-07-05 Thread Diffuser78
Anyone ? On Thu, Jul 5, 2012 at 8:23 AM, Diffuser78 wrote: > I have a client and a server app. Client needs to send 1000 lightweight > (5KBs) messages per second to the server. Client also wants an ACK from > server that server got the msg that client sent. > > Here is what

[zeromq-dev] Design Suggestion for simple app using zmq

2012-07-05 Thread Diffuser78
I have a client and a server app. Client needs to send 1000 lightweight (5KBs) messages per second to the server. Client also wants an ACK from server that server got the msg that client sent. Here is what I have designed. Please let me know your thought in case you see incorrect usage of the patt

Re: [zeromq-dev] question about HWM

2012-06-22 Thread Diffuser78
to DEALER/ROUTER that needs to be followed. I am still reading zguide but since its quite exhaustive, I am yet to reach to the messaging patterns. Thanks. On Thu, Jun 21, 2012 at 5:48 PM, Chuck Remes wrote: > On Jun 21, 2012, at 6:23 PM, Diffuser78 wrote: > > > Thanks, Chuck, fo

Re: [zeromq-dev] question about HWM

2012-06-21 Thread Diffuser78
AM, Diffuser78 wrote: > > Hi, > > I just started playing with zmq, and I had a question about HWM. > > If my socket type is of ZMQ_REP, and if this socket enters an exceptional > state due to HWM reached, I read in the guide that it will drop the reply > message being sent to the clie

[zeromq-dev] question about HWM

2012-06-21 Thread Diffuser78
Hi, I just started playing with zmq, and I had a question about HWM. If my socket type is of ZMQ_REP, and if this socket enters an exceptional state due to HWM reached, I read in the guide that it will drop the reply message being sent to the client. *My questions is: would it retry again ? Can I

Re: [zeromq-dev] How to compile a C or C++ program written using ZMQ

2012-06-20 Thread Diffuser78
you get ZeroMQ installed? Are you sure you passed -lzmq to gcc when you got >> this error? >> >> >> On Wed, Jun 20, 2012 at 10:24 AM, Diffuser78 wrote: >> >>> It says the following: >>> >>> "undefined reference to `zmq_msg_init'"

Re: [zeromq-dev] How to compile a C or C++ program written using ZMQ

2012-06-20 Thread Diffuser78
uot;? Are you getting any output from gcc? > > On Wed, Jun 20, 2012 at 9:48 AM, Diffuser78 wrote: > >> Hi, >> >> I am a newbie so pardon my ignorance. I wrote very simple client and >> server program using zmq by looking the guide. >> >> There are no inst

[zeromq-dev] How to compile a C or C++ program written using ZMQ

2012-06-20 Thread Diffuser78
Hi, I am a newbie so pardon my ignorance. I wrote very simple client and server program using zmq by looking the guide. There are no instructions to compile and run the same. I have tried the following, but it does not work. I downloaded the tar ball, built it using the instructions given on the