msg/simple: wait dispatch_queue until all pipes closed

Otherwise accepter may continue to accept new connection which may queue
new item.

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

src/msg/simple/SimpleMessenger.cc

@@ -527,13 +527,6 @@ void SimpleMessenger::wait()
   }
   lock.Unlock();
 
-  if (dispatch_queue.is_started()) {
-    ldout(cct,10) << "wait: waiting for dispatch queue" << dendl;
-    dispatch_queue.wait();
-    dispatch_queue.discard_local();
-    ldout(cct,10) << "wait: dispatch queue is stopped" << dendl;
-  }
-
   // done!  clean up.
   if (did_bind) {
     ldout(cct,20) << "wait: stopping accepter thread" << dendl;
@@ -575,6 +568,13 @@ void SimpleMessenger::wait()
   }
   lock.Unlock();
 
+  if (dispatch_queue.is_started()) {
+    ldout(cct,10) << "wait: waiting for dispatch queue" << dendl;
+    dispatch_queue.wait();
+    dispatch_queue.discard_local();
+    ldout(cct,10) << "wait: dispatch queue is stopped" << dendl;
+  }
+
   ldout(cct,10) << "wait: done." << dendl;
   ldout(cct,1) << "shutdown complete." << dendl;
   started = false;