From b4c5ce91007cb16dde46e173d648800ae3c99d88 Mon Sep 17 00:00:00 2001
From: Kenneth Anthony Giusti <kgiusti@apache.org>
Date: Thu, 2 Sep 2010 20:47:51 +0000
Subject: 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
---
 extras/qmf/src/py/qmf/console.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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()
 
-- 
cgit v1.2.1