From 63efdd56c4ae85e47dd69a9bc45071971162a670 Mon Sep 17 00:00:00 2001 From: MinRK Date: Mon, 30 Sep 2013 12:30:57 -0700 Subject: [PATCH] don't use zero-copy message tracker for blocking behavior closes #1 --- py/zero/__init__.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/py/zero/__init__.py b/py/zero/__init__.py index 36ad261..cad3d4d 100644 --- a/py/zero/__init__.py +++ b/py/zero/__init__.py @@ -437,9 +437,10 @@ def send(self, obj): self.setup.debug('Sending %s to %s', msg, self.setup.point) sleep(self.naptime) # TODO: Find out how to tell when it is connected self.naptime = 0 - tracker = self.sock.send(msg, copy=False, track=True) - if self.setup.block: - tracker.wait() + flags = 0 + if not self.setup.block: + flags |= zmq.NOBLOCK + self.sock.send(msg, flags) @property def active(self):