]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
common/WorkQueue: allow start() after stop() 891/head
authorSage Weil <sage@inktank.com>
Tue, 3 Dec 2013 20:26:43 +0000 (12:26 -0800)
committerSage Weil <sage@inktank.com>
Tue, 3 Dec 2013 20:27:14 +0000 (12:27 -0800)
Signed-off-by: Sage Weil <sage@inktank.com>
src/common/WorkQueue.cc

index 6b648a780215f12d303e812e4aea9ff358e2049a..f47435bf3abc680e7c21b470331be7dcb44f70ce 100644 (file)
@@ -210,6 +210,7 @@ void ThreadPool::stop(bool clear_after)
   _lock.Lock();
   for (unsigned i=0; i<work_queues.size(); i++)
     work_queues[i]->_clear();
+  _stop = false;
   _lock.Unlock();    
   ldout(cct,15) << "stopped" << dendl;
 }