]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mds: Reorganize class members in RecoveryQueue header 31635/head
authorVarsha Rao <varao@redhat.com>
Thu, 14 Nov 2019 14:23:50 +0000 (19:53 +0530)
committerVarsha Rao <varao@redhat.com>
Thu, 14 Nov 2019 14:27:26 +0000 (19:57 +0530)
Fixes: https://tracker.ceph.com/issues/42813
Signed-off-by: Varsha Rao <varao@redhat.com>
src/mds/RecoveryQueue.cc
src/mds/RecoveryQueue.h

index e02de3671bae88be07d2fa625dfb0e42389e80ea..2a101a21262002d2167a04abf21d877c0faf1acf 100644 (file)
 #define dout_prefix *_dout << "mds." << mds->get_nodeid() << " RecoveryQueue::" << __func__ << " "
 
 class C_MDC_Recover : public MDSIOContextBase {
+public:
+  C_MDC_Recover(RecoveryQueue *rq_, CInode *i) :
+    MDSIOContextBase(false), rq(rq_), in(i) {
+    ceph_assert(rq != NULL);
+  }
+  void print(ostream& out) const override {
+    out << "file_recover(" << in->ino() << ")";
+  }
+
+  uint64_t size = 0;
+  utime_t mtime;
 protected:
-  RecoveryQueue *rq;
-  CInode *in;
   void finish(int r) override {
     rq->_recovered(in, r, size, mtime);
   }
@@ -37,27 +46,16 @@ protected:
     return rq->mds;
   }
 
-public:
-  uint64_t size;
-  utime_t mtime;
-
-  C_MDC_Recover(RecoveryQueue *rq_, CInode *i) :
-    MDSIOContextBase(false), rq(rq_), in(i), size(0) {
-    ceph_assert(rq != NULL);
-  }
-  void print(ostream& out) const override {
-    out << "file_recover(" << in->ino() << ")";
-  }
+  RecoveryQueue *rq;
+  CInode *in;
 };
 
-
 RecoveryQueue::RecoveryQueue(MDSRank *mds_) :
   file_recover_queue(member_offset(CInode, item_dirty_dirfrag_dir)),
   file_recover_queue_front(member_offset(CInode, item_dirty_dirfrag_nest)),
-  mds(mds_), logger(NULL), filer(mds_->objecter, mds_->finisher)
+  mds(mds_), filer(mds_->objecter, mds_->finisher)
 { }
 
-
 /**
  * Progress the queue.  Call this after enqueuing something or on
  * completion of something.
index a1e6ac487cf6139a694512ce1a5c442779395f1b..cc2c69c905e5f0d37f2d4a8240f0c5bad065c6f0 100644 (file)
@@ -27,14 +27,17 @@ class PerfCounters;
 
 class RecoveryQueue {
 public:
+  explicit RecoveryQueue(MDSRank *mds_);
+
   void enqueue(CInode *in);
   void advance();
   void prioritize(CInode *in);   ///< do this inode now/soon
-  explicit RecoveryQueue(MDSRank *mds_);
 
   void set_logger(PerfCounters *p) {logger=p;}
 
 private:
+  friend class C_MDC_Recover;
+
   void _start(CInode *in);  ///< start recovering this file
   void _recovered(CInode *in, int r, uint64_t size, utime_t mtime);
 
@@ -46,10 +49,8 @@ private:
   std::map<CInode*, bool> file_recovering; // inode -> need_restart
 
   MDSRank *mds;
-  PerfCounters *logger;
+  PerfCounters *logger = nullptr;
   Filer filer;
-
-  friend class C_MDC_Recover;
 };
 
 #endif // RECOVERY_QUEUE_H