[zeromq-dev] How to make recv() non blocking

Ronald Swain proj_symbian at live.com
Tue Apr 3 11:35:03 CEST 2012


Hello Antonio,

thanks a lot for quickest reply :-)

I got your way of using NOBLOCK, but can you brief me more about how i can use zmq.poll here using the POLLIN and POLLOUT events.

Regards
Ronald

Date: Tue, 3 Apr 2012 09:27:24 +0000
From: eagle.antonio at gmail.com
To: zeromq-dev at lists.zeromq.org
Subject: Re: [zeromq-dev] How to make recv() non blocking

Hello Ronald.

This works for me :)

recevSock.recv(flags=zmq.NOBLOCK)
This will rase and exception you will have to handle it :)
so

try:
   recevSock.recv(flags=zmq.NOBLOCK)
except zmq.core.error.ZMQError,e:


if str(Resource temporarily unavailable) in e:
  # Socket not ready
  return None
else:
  # Oopsy other error re-raise
  raise

You can also use zmq.poll to handle the POLLIN POLLOUT Events :)



2012/4/3 Ronald Swain <proj_symbian at live.com>





Hello All,

After a long time i have a question and it seems to be the simple one.

I am using following code to receive something using PyZMQ:

import zmq
zmqContext = zmq.Context()
recevSock = zmqContext.socket(zmq.SUB)

recevSock.connect('address')
recevSock.setsockopts(zmq.SUBSCRIBE.' ')
recevSock.recv()

But the call to recv is blocking my code, so what is the best routine to make that non blocking, i read the docs and they say that i have to set a FLAG NOBLOCK in the method, but when i do so :


recevSock.recv(flags=1)

it throws exception: zmq.core.error.ZMQError: Resource temporarily unavailable

Can any body please help me to move forward.

Regards,
Ronald
 		 	   		  

_______________________________________________

zeromq-dev mailing list

zeromq-dev at lists.zeromq.org

http://lists.zeromq.org/mailman/listinfo/zeromq-dev





_______________________________________________
zeromq-dev mailing list
zeromq-dev at lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev 		 	   		  
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20120403/5d80d9c1/attachment.htm>


More information about the zeromq-dev mailing list