SimpleMessenger.cc: Fixes a dispatch_throttler leak in queue_received

when the pipe has been halted.

Signed-off-by: Samuel Just <samuelj@hq.newdream.net>

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index bc40023daf76c85a0787ea69e5142fc0b6cc7c77..fd18a5461611efe9091269820286738f234f2e73 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -568,8 +568,10 @@ void SimpleMessenger::Pipe::queue_received(Message *m, int priority)
   // don't want to put local-delivery signals
   // this magic number should be larger than
   // the size of the D_CONNECT et al enum
-  if (m>(void *)5)
+  if (m>(void *)5) {
+    messenger->dispatch_throttle_release(m->get_dispatch_throttle_size());
     m->put();
+  }
 }