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/10 01:54:53 UTC
svn commit: r932652 - /qpid/trunk/qpid/python/qpid/messaging/driver.py
Author: rhs
Date: Fri Apr 9 23:54:53 2010
New Revision: 932652
URL: http://svn.apache.org/viewvc?rev=932652&view=rev
Log:
candidate fix for testReconnect
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=932652&r1=932651&r2=932652&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/driver.py Fri Apr 9 23:54:53 2010
@@ -779,7 +779,7 @@ class Engine:
sst = self._attachments.get(lnk.session)
_lnk = self._attachments.get(lnk)
- if _lnk is None and not lnk.closing and not lnk.closed:
+ if _lnk is None and not lnk.closed:
_lnk = Attachment(lnk)
_lnk.closing = False
dir.init_link(sst, lnk, _lnk)
@@ -812,7 +812,7 @@ class Engine:
dir.do_unlink(sst, lnk, _lnk, unlinked)
_lnk.closing = True
elif not lnk.linked and lnk.closing and not lnk.closed:
- lnk.closed = True
+ if lnk.error: lnk.closed = True
def parse_address(self, lnk, dir, addr):
if addr is None:
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org