From d636223b299412a710c4807119426d3cedc56b43 Mon Sep 17 00:00:00 2001
From: Henry C Chang <henry_c_chang@tcloudcomputing.com>
Date: Sun, 22 Aug 2010 21:39:35 -0700
Subject: [PATCH] msgr: release dispatch_throttle on reset connection

Signed-off-by: Henry C Chang <henry_c_chang@tcloudcomputing.com>
Signed-off-by: Sage Weil <sage@newdream.net>
---
 src/msg/SimpleMessenger.cc | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 14053a261a717..56f4f0fa50555 100644
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -1258,8 +1258,10 @@ void SimpleMessenger::Pipe::discard_queue()
       (*r)->put();
   out_q.clear();
   for (map<int,list<Message*> >::iterator p = in_q.begin(); p != in_q.end(); p++)
-    for (list<Message*>::iterator r = p->second.begin(); r != p->second.end(); r++)
+    for (list<Message*>::iterator r = p->second.begin(); r != p->second.end(); r++) {
+      messenger->dispatch_throttle_release((*r)->get_dispatch_throttle_size());
       (*r)->put();
+    }
   in_q.clear();
   in_qlen = 0;
 }
-- 
2.39.5