WorkQueue: Removed the unused in_process variable

Signed-off-by: Somnath Roy <somnath.roy@sandisk.com>

diff --git a/src/common/WorkQueue.cc b/src/common/WorkQueue.cc
index d3815c40f109ceda99b8518a751883795196a457..52508324dd9ab732dffcebd116a972753dbb2f0c 100644 (file)
--- a/src/common/WorkQueue.cc
+++ b/src/common/WorkQueue.cc
@@ -257,7 +257,7 @@ void ThreadPool::drain(WorkQueue_* wq)
 
 ShardedThreadPool::ShardedThreadPool(CephContext *pcct_, string nm, uint32_t pnum_threads):
   cct(pcct_), name(nm), lockname(nm + "::lock"), shardedpool_lock(lockname.c_str()), num_threads(pnum_threads), 
-  stop_threads(0), pause_threads(0),drain_threads(0), in_process(0), num_paused(0), num_drained(0), wq(NULL) {}
+  stop_threads(0), pause_threads(0),drain_threads(0), num_paused(0), num_drained(0), wq(NULL) {}
 
 void ShardedThreadPool::shardedthreadpool_worker(uint32_t thread_index)
 {

diff --git a/src/common/WorkQueue.h b/src/common/WorkQueue.h
index 352ed5ea1b610bad3a514c047dabbc27aacd754d..b27ff847895ca7af78151261407148d3a014c280 100644 (file)
--- a/src/common/WorkQueue.h
+++ b/src/common/WorkQueue.h
@@ -441,7 +441,6 @@ class ShardedThreadPool {
   atomic_t stop_threads;
   atomic_t pause_threads;
   atomic_t drain_threads;
-  atomic_t in_process; 
   uint32_t num_paused;
   uint32_t num_drained;