summaryrefslogtreecommitdiff
path: root/python/qmf/console.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/qmf/console.py')
-rw-r--r--python/qmf/console.py15
1 files changed, 11 insertions, 4 deletions
diff --git a/python/qmf/console.py b/python/qmf/console.py
index fe329db289..739ccb6b6b 100644
--- a/python/qmf/console.py
+++ b/python/qmf/console.py
@@ -1191,9 +1191,16 @@ class ManagedConnection(Thread):
delay = self.DELAY_MIN
finally:
self.cv.release()
- except:
+ except socket.error:
+ if delay < self.DELAY_MAX:
+ delay *= self.DELAY_FACTOR
+ except SessionDetached:
if delay < self.DELAY_MAX:
delay *= self.DELAY_FACTOR
+ except Closed:
+ if delay < self.DELAY_MAX:
+ delay *= self.DELAY_FACTOR
+
try:
self.cv.acquire()
self.cv.wait(delay)
@@ -1332,13 +1339,13 @@ class Broker:
except socket.error, e:
self.error = "Socket Error %s - %s" % (e[0], e[1])
- raise Exception(self.error)
+ raise
except Closed, e:
self.error = "Connect Failed %d - %s" % (e[0], e[1])
- raise Exception(self.error)
+ raise
except ConnectionFailed, e:
self.error = "Connect Failed %d - %s" % (e[0], e[1])
- raise Exception(self.error)
+ raise
def _updateAgent(self, obj):
bankKey = (obj.brokerBank, obj.agentBank)