From: Varsha Rao Date: Wed, 30 Oct 2019 11:24:11 +0000 (+0530) Subject: mds: Reorganize class members in MDSTableServer header X-Git-Tag: v15.1.0~299^2 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=5c81db6c56036471e3aef287556e94d53360cbc2;p=ceph-ci.git mds: Reorganize class members in MDSTableServer header Fixes: https://tracker.ceph.com/issues/42563 Signed-off-by: Varsha Rao --- diff --git a/src/mds/MDSTableServer.h b/src/mds/MDSTableServer.h index dfd88ae3034..84dc5b87d24 100644 --- a/src/mds/MDSTableServer.h +++ b/src/mds/MDSTableServer.h @@ -21,41 +21,13 @@ #include "messages/MMDSTableRequest.h" class MDSTableServer : public MDSTable { -protected: - int table; - bool recovered; - set active_clients; -private: - map pending_for_mds; // ** child should encode this! ** - set committing_tids; - - struct notify_info_t { - set notify_ack_gather; - mds_rank_t mds; - ref_t reply; - MDSContext *onfinish; - notify_info_t() : reply(NULL), onfinish(NULL) {} - }; - map pending_notifies; - - void handle_prepare(const cref_t &m); - void _prepare_logged(const cref_t &m, version_t tid); - friend class C_Prepare; - - void handle_commit(const cref_t &m); - void _commit_logged(const cref_t &m); - friend class C_Commit; - - void handle_rollback(const cref_t &m); - void _rollback_logged(const cref_t &m); - friend class C_Rollback; - - void _server_update_logged(bufferlist& bl); - friend class C_ServerUpdate; +public: + friend class C_ServerRecovery; - void handle_notify_ack(const cref_t &m); + MDSTableServer(MDSRank *m, int tab) : + MDSTable(m, get_mdstable_name(tab), false), table(tab) {} + ~MDSTableServer() override {} -public: virtual void handle_query(const cref_t &m) = 0; virtual void _prepare(const bufferlist &bl, uint64_t reqid, mds_rank_t bymds, bufferlist& out) = 0; virtual void _get_reply_buffer(version_t tid, bufferlist *pbl) const = 0; @@ -90,10 +62,6 @@ public: projected_version = version; } - MDSTableServer(MDSRank *m, int tab) : - MDSTable(m, get_mdstable_name(tab), false), table(tab), recovered(false) {} - ~MDSTableServer() override {} - void reset_state() override { pending_for_mds.clear(); ++version; @@ -117,10 +85,43 @@ public: // recovery void finish_recovery(set& active); void _do_server_recovery(); - friend class C_ServerRecovery; void handle_mds_recovery(mds_rank_t who); void handle_mds_failure_or_stop(mds_rank_t who); -}; +protected: + int table; + bool recovered = false; + set active_clients; +private: + struct notify_info_t { + notify_info_t() {} + set notify_ack_gather; + mds_rank_t mds; + ref_t reply = NULL; + MDSContext *onfinish = nullptr; + }; + + friend class C_Prepare; + friend class C_Commit; + friend class C_Rollback; + friend class C_ServerUpdate; + + void handle_prepare(const cref_t &m); + void _prepare_logged(const cref_t &m, version_t tid); + + void handle_commit(const cref_t &m); + void _commit_logged(const cref_t &m); + void handle_rollback(const cref_t &m); + void _rollback_logged(const cref_t &m); + + void _server_update_logged(bufferlist& bl); + + void handle_notify_ack(const cref_t &m); + + map pending_for_mds; // ** child should encode this! ** + set committing_tids; + + map pending_notifies; +}; #endif