From e94801364ddd39a5c697a81750b1197d3a1c3700 Mon Sep 17 00:00:00 2001 From: Jason Bruce Date: Mon, 11 Jun 2012 09:08:32 -0400 Subject: [PATCH] - ZMQ crashes on connect and bind if it cannot resolve the hostname given. Maybe these try/excepts will help --- septic_tank/inputs.py | 6 +++++- septic_tank/outputs.py | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/septic_tank/inputs.py b/septic_tank/inputs.py index 79b311f..9e1d5af 100644 --- a/septic_tank/inputs.py +++ b/septic_tank/inputs.py @@ -29,7 +29,11 @@ def reconnect(self): self.context.term() self.context = zmq.Context() self.socket = self.context.socket(zmq.REP) - self.socket.bind(self.addr) + try: + self.socket.bind(self.addr) + except Exception, err: + logging.error('zeromq bind error: %s' % str(err)) + return None def output(self): try: diff --git a/septic_tank/outputs.py b/septic_tank/outputs.py index 7435014..61f3705 100644 --- a/septic_tank/outputs.py +++ b/septic_tank/outputs.py @@ -55,7 +55,11 @@ def reconnect(self): self.context.term() self.context = zmq.Context() self.socket = self.context.socket(zmq.REQ) - self.socket.connect(self.addr) + try: + self.socket.connect(self.addr) + except Exception, err: + logging.error('zeromq connect error: %s' % str(err)) + return None self.poller = zmq.Poller() self.poller.register(self.socket, zmq.POLLIN)