update sources to v12.1.1

[ceph.git] / ceph / src / common / WorkQueue.h

diff --git a/ceph/src/common/WorkQueue.h b/ceph/src/common/WorkQueue.h
index c817e74ec0920201ef88199ff42750b284823f17..d3eff47bdf844e61139a0de11df33d159c79a447 100644 (file)
--- a/ceph/src/common/WorkQueue.h
+++ b/ceph/src/common/WorkQueue.h
@@ -373,6 +373,9 @@ public:
     PointerWQ(string n, time_t ti, time_t sti, ThreadPool* p)
       : WorkQueue_(std::move(n), ti, sti), m_pool(p), m_processing(0) {
     }
+    void register_work_queue() {
+      m_pool->add_work_queue(this);
+    }
     void _clear() override {
       assert(m_pool->_lock.is_locked());
       m_items.clear();
@@ -576,7 +579,7 @@ public:
   ContextWQ(const string &name, time_t ti, ThreadPool *tp)
     : ThreadPool::PointerWQ<Context>(name, ti, 0, tp),
       m_lock("ContextWQ::m_lock") {
-    tp->add_work_queue(this);
+    this->register_work_queue();
   }
 
   void queue(Context *ctx, int result = 0) {