AsyncMessenger: Avoid join when worker thread not started

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>

diff --git a/src/msg/AsyncMessenger.cc b/src/msg/AsyncMessenger.cc
index 0a7f82b8068828e375e3dbf8f63197b91f5fde61..ed8f04fcaaa672d497bfc125888285a97ded77ea 100644 (file)
--- a/src/msg/AsyncMessenger.cc
+++ b/src/msg/AsyncMessenger.cc
@@ -375,7 +375,8 @@ int AsyncMessenger::rebind(const set<int>& avoid_ports)
   assert(did_bind);
   for (vector<Worker*>::iterator it = workers.begin(); it != workers.end(); ++it) {
     (*it)->stop();
-    (*it)->join();
+    if ((*it)->is_started())
+      (*it)->join();
   }
 
   processor.stop();