diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-09-02 20:47:51 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-09-02 20:47:51 +0000 |
| commit | b4c5ce91007cb16dde46e173d648800ae3c99d88 (patch) | |
| tree | 9428810d45be087c07085cb03a6033f0109ea0a5 /extras | |
| parent | 9d1724de38882bbd0695d715a030140c6ac0727b (diff) | |
| download | qpid-python-b4c5ce91007cb16dde46e173d648800ae3c99d88.tar.gz | |
QPID-2846: release pending sequence numbers when cleaning up an agent.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992113 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'extras')
| -rw-r--r-- | extras/qmf/src/py/qmf/console.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/extras/qmf/src/py/qmf/console.py b/extras/qmf/src/py/qmf/console.py index 79e74d6198..80684de0d3 100644 --- a/extras/qmf/src/py/qmf/console.py +++ b/extras/qmf/src/py/qmf/console.py @@ -2945,6 +2945,7 @@ class Agent: for seq in copy: context = copy[seq] context.cancel("Agent disconnected") + self.seqMgr._release(seq) def __repr__(self): @@ -3052,7 +3053,10 @@ class Agent: def _clearContext(self, sequence): try: self.lock.acquire() - self.contextMap.pop(sequence) + try: + self.contextMap.pop(sequence) + except KeyError: + pass # @todo - shouldn't happen, log a warning. finally: self.lock.release() |