- ZMQ crashes on connect and bind if it cannot resolve the hostname g…

…iven. Maybe these try/excepts will help
jbruce12000 · Jun 11, 2012 · e948013 · e948013
1 parent 515f246
commit e948013
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git 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
@@ -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)