osd: update mClock.*Queue to incorporate the changes on dmclock

Signed-off-by: Kefu Chai <kchai@redhat.com>
ceph · Oct 19, 2017 · 4cbce34 · 4cbce34
1 parent 5e370e1
commit 4cbce34
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 16 deletions.
diff --git a/src/osd/mClockClientQueue.cc b/src/osd/mClockClientQueue.cc
@@ -58,24 +58,24 @@ namespace ceph {
   }
 
 
-  dmc::ClientInfo
+  const dmc::ClientInfo*
   mClockClientQueue::op_class_client_info_f(
     const mClockClientQueue::InnerClient& client)
   {
     switch(client.second) {
     case osd_op_type_t::client_op:
-      return mclock_op_tags->client_op;
+      return &mclock_op_tags->client_op;
     case osd_op_type_t::osd_subop:
-      return mclock_op_tags->osd_subop;
+      return &mclock_op_tags->osd_subop;
     case osd_op_type_t::bg_snaptrim:
-      return mclock_op_tags->snaptrim;
+      return &mclock_op_tags->snaptrim;
     case osd_op_type_t::bg_recovery:
-      return mclock_op_tags->recov;
+      return &mclock_op_tags->recov;
     case osd_op_type_t::bg_scrub:
-      return mclock_op_tags->scrub;
+      return &mclock_op_tags->scrub;
     default:
       assert(0);
-      return dmc::ClientInfo(-1, -1, -1);
+      return nullptr;
     }
   }
 

diff --git a/src/osd/mClockClientQueue.h b/src/osd/mClockClientQueue.h
@@ -62,7 +62,7 @@ namespace ceph {
 
     mClockClientQueue(CephContext *cct);
 
-    static crimson::dmclock::ClientInfo
+    static const crimson::dmclock::ClientInfo*
     op_class_client_info_f(const InnerClient& client);
 
     inline unsigned length() const override final {

diff --git a/src/osd/mClockOpClassQueue.cc b/src/osd/mClockOpClassQueue.cc
@@ -58,22 +58,22 @@ namespace ceph {
   }
 
 
-  dmc::ClientInfo
+  const dmc::ClientInfo*
   mClockOpClassQueue::op_class_client_info_f(const osd_op_type_t& op_type) {
     switch(op_type) {
     case osd_op_type_t::client_op:
-      return mclock_op_tags->client_op;
+      return &mclock_op_tags->client_op;
     case osd_op_type_t::osd_subop:
-      return mclock_op_tags->osd_subop;
+      return &mclock_op_tags->osd_subop;
     case osd_op_type_t::bg_snaptrim:
-      return mclock_op_tags->snaptrim;
+      return &mclock_op_tags->snaptrim;
     case osd_op_type_t::bg_recovery:
-      return mclock_op_tags->recov;
+      return &mclock_op_tags->recov;
     case osd_op_type_t::bg_scrub:
-      return mclock_op_tags->scrub;
+      return &mclock_op_tags->scrub;
     default:
       assert(0);
-      return dmc::ClientInfo(-1, -1, -1);
+      return nullptr;
     }
   }
 

diff --git a/src/osd/mClockOpClassQueue.h b/src/osd/mClockOpClassQueue.h
@@ -60,7 +60,7 @@ namespace ceph {
 
     mClockOpClassQueue(CephContext *cct);
 
-    static crimson::dmclock::ClientInfo
+    static const crimson::dmclock::ClientInfo*
     op_class_client_info_f(const osd_op_type_t& op_type);
 
     inline unsigned length() const override final {