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/01/16 23:26:43 UTC
qpid-proton git commit: fix link closing on BlockingConnection
Repository: qpid-proton
Updated Branches:
refs/heads/master 51c59f7d5 -> c7079a957
fix link closing on 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/c7079a95
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/c7079a95
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/c7079a95
Branch: refs/heads/master
Commit: c7079a957777ced12bae233432df8da13bb702c4
Parents: 51c59f7
Author: Gordon Sim <gs...@redhat.com>
Authored: Fri Jan 16 22:27:37 2015 +0000
Committer: Gordon Sim <gs...@redhat.com>
Committed: Fri Jan 16 22:27:37 2015 +0000
----------------------------------------------------------------------
proton-c/bindings/python/proton/utils.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/c7079a95/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 4e5d4b9..bd8059a 100644
--- a/proton-c/bindings/python/proton/utils.py
+++ b/proton-c/bindings/python/proton/utils.py
@@ -29,8 +29,9 @@ class BlockingLink(object):
msg="Opening link %s" % link.name)
def close(self):
- self.connection.wait(not (self.link.state & Endpoint.REMOTE_ACTIVE),
- msg="Closing link %s" % link.name)
+ self.link.close()
+ self.connection.wait(lambda: not (self.link.state & Endpoint.REMOTE_ACTIVE),
+ msg="Closing link %s" % self.link.name)
# Access to other link attributes.
def __getattr__(self, name): return getattr(self.link, name)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org