You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2010/04/09 13:50:01 UTC
svn commit: r932368 - /qpid/trunk/qpid/python/qpid/messaging/driver.py
Author: rhs
Date: Fri Apr 9 11:50:01 2010
New Revision: 932368
URL: http://svn.apache.org/viewvc?rev=932368&view=rev
Log:
clean up pipes from driver side in case nobody is waiting for the error
Modified:
qpid/trunk/qpid/python/qpid/messaging/driver.py
Modified: qpid/trunk/qpid/python/qpid/messaging/driver.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/driver.py?rev=932368&r1=932367&r2=932368&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/driver.py Fri Apr 9 11:50:01 2010
@@ -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:
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org