You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2015/10/19 15:18:30 UTC
qpid-proton git commit: PROTON-1023: fix handling of detach following
attach for BlockingConnection
Repository: qpid-proton
Updated Branches:
refs/heads/master 52dd42d83 -> ea52a2742
PROTON-1023: fix handling of detach following attach for BlockingConnection
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/ea52a274
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/ea52a274
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/ea52a274
Branch: refs/heads/master
Commit: ea52a2742e9e2e1607dcb1090e52a6a49bef8aa1
Parents: 52dd42d
Author: Gordon Sim <gs...@redhat.com>
Authored: Mon Oct 19 13:54:35 2015 +0100
Committer: Gordon Sim <gs...@redhat.com>
Committed: Mon Oct 19 13:55:11 2015 +0100
----------------------------------------------------------------------
proton-c/bindings/python/proton/utils.py | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ea52a274/proton-c/bindings/python/proton/utils.py
----------------------------------------------------------------------
diff --git a/proton-c/bindings/python/proton/utils.py b/proton-c/bindings/python/proton/utils.py
index acc4c34..3682455 100644
--- a/proton-c/bindings/python/proton/utils.py
+++ b/proton-c/bindings/python/proton/utils.py
@@ -32,10 +32,12 @@ class BlockingLink(object):
msg="Opening link %s" % link.name)
self._checkClosed()
- def _waitForClosed(self, timeout=1):
- self.connection.wait(lambda: self.link.state & Endpoint.REMOTE_CLOSED,
- timeout=timeout,
- msg="Opening link %s" % self.link.name)
+ def _waitForClose(self, timeout=1):
+ try:
+ self.connection.wait(lambda: self.link.state & Endpoint.REMOTE_CLOSED,
+ timeout=timeout,
+ msg="Opening link %s" % self.link.name)
+ except Timeout as e: pass
self._checkClosed()
def _checkClosed(self):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org