From 194e615b3561ee4ad210eab89cd91773fda75ad4 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 19 Sep 2007 14:47:48 +0000 Subject: Fixed (il)logic in timeout management when waiting for completion. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577321 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/peer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'python/qpid') diff --git a/python/qpid/peer.py b/python/qpid/peer.py index b9dd4e466a..5cabf98236 100644 --- a/python/qpid/peer.py +++ b/python/qpid/peer.py @@ -434,8 +434,8 @@ class OutgoingCompletion: while not self.closed and point_of_interest > self.mark: #print "waiting for ", point_of_interest, " mark is currently at ", self.mark self.condition.wait(remaining) - if timeout: - if start_time + timeout > time(): break + if not self.closed and point_of_interest > self.mark and timeout: + if (start_time + timeout) < time(): break else: remaining = timeout - (time() - start_time) finally: self.condition.release() -- cgit v1.2.1