DispatchQueue: make sure no pending message in queue

Signed-off-by: Haomai Wang <haomai@xsky.com>

diff --git a/src/msg/DispatchQueue.h b/src/msg/DispatchQueue.h
index 57de4ea3e9626984ea7c8837d24f88c7c7ca5770..da035a45a4c10b7d14528b783b9fe09a4906cf05 100644 (file)
--- a/src/msg/DispatchQueue.h
+++ b/src/msg/DispatchQueue.h
@@ -215,6 +215,11 @@ class DispatchQueue {
                          cct->_conf->ms_dispatch_throttle_bytes),
       stop(false)
     {}
+  ~DispatchQueue() {
+    assert(mqueue.empty());
+    assert(marrival.empty());
+    assert(local_messages.empty());
+  }
 };
 
 #endif