From 73202655fab7a29140cd08e784a8e8ca9fefc951 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 9 Apr 2010 11:50:01 +0000 Subject: clean up pipes from driver side in case nobody is waiting for the error git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@932368 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/messaging/driver.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) (limited to 'python') diff --git a/python/qpid/messaging/driver.py b/python/qpid/messaging/driver.py index cf8498794b..5cf41eb455 100644 --- a/python/qpid/messaging/driver.py +++ b/python/qpid/messaging/driver.py @@ -380,6 +380,11 @@ class Driver: self.update_status() + self._notify() + + def _notify(self): + if self.connection.error: + self.connection._condition.gc() self.connection._waiter.notifyAll() def close_engine(self, e=None): @@ -434,12 +439,12 @@ class Driver: notify = True if self.update_status() or notify: - self.connection._waiter.notifyAll() + self._notify() @synchronized def timeout(self): self.dispatch() - self.connection._waiter.notifyAll() + self._notify() def dispatch(self): try: -- cgit v1.2.1