AsyncMessenger: Don't need to join thread if not started

Signed-off-by: Haomai Wang <[email protected]>
bitfehler · Apr 24, 2015 · 8a7e58e · 8a7e58e
1 parent b05d144
commit 8a7e58e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/msg/async/AsyncMessenger.cc b/src/msg/async/AsyncMessenger.cc
@@ -339,8 +339,10 @@ WorkerPool::WorkerPool(CephContext *c): cct(c), seq(0), started(false),
 WorkerPool::~WorkerPool()
 {
   for (uint64_t i = 0; i < workers.size(); ++i) {
-    workers[i]->stop();
-    workers[i]->join();
+    if (workers[i]->is_started()) {
+      workers[i]->stop();
+      workers[i]->join();
+    }
     delete workers[i];
   }
 }