common/WorkQueue: add wait()

Signed-off-by: Sage Weil <sage@redhat.com>

diff --git a/src/common/WorkQueue.h b/src/common/WorkQueue.h
index 77ee6d1ab607c1aa1eb07f8706cc6c8d86834dcc..cf78b2dc30294371b437d9371c4bfb39ee5d7171 100644 (file)
--- a/src/common/WorkQueue.h
+++ b/src/common/WorkQueue.h
@@ -336,6 +336,9 @@ public:
     void _wake() {
       pool->_wake();
     }
+    void _wait() {
+      pool->_wait();
+    }
     void drain() {
       pool->drain(this);
     }
@@ -415,6 +418,9 @@ public:
     Mutex::Locker l(_lock);
     _cond.Signal();
   }
+  void _wait() {
+    _cond.Wait(_lock);
+  }
 
   /// start thread pool thread
   void start();