diff options
| author | Gordon Sim <gsim@apache.org> | 2007-09-19 14:47:48 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-09-19 14:47:48 +0000 |
| commit | 194e615b3561ee4ad210eab89cd91773fda75ad4 (patch) | |
| tree | d3e541a7867d54ea2d481adab5f2dceaa8e4e442 /python/qpid/peer.py | |
| parent | 94aac9400a3e4e941e1d1a982bcbe6f97b1b4fe9 (diff) | |
| download | qpid-python-194e615b3561ee4ad210eab89cd91773fda75ad4.tar.gz | |
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
Diffstat (limited to 'python/qpid/peer.py')
| -rw-r--r-- | python/qpid/peer.py | 4 |
1 files changed, 2 insertions, 2 deletions
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() |