mds: add mds_lock asserts for journal flush

Signed-off-by: Patrick Donnelly <[email protected]>

Author: batrick

src/mds/MDSRank.cc

@@ -71,7 +71,7 @@ class C_Flush_Journal : public MDSInternalContext {
   }
 
   void send() {
-    ceph_assert(ceph_mutex_is_locked(mds->mds_lock));
+    ceph_assert(ceph_mutex_is_locked_by_me(mds->mds_lock));
 
     dout(20) << __func__ << dendl;
 
@@ -112,6 +112,7 @@ class C_Flush_Journal : public MDSInternalContext {
   }
 
   void handle_clear_mdlog(int r) {
+    ceph_assert(ceph_mutex_is_locked_by_me(mds->mds_lock));
     dout(20) << __func__ << ": r=" << r << dendl;
 
     if (r != 0) {
@@ -181,6 +182,7 @@ class C_Flush_Journal : public MDSInternalContext {
   }
 
   void trim_expired_segments() {
+    ceph_assert(ceph_mutex_is_locked_by_me(mds->mds_lock));
     dout(5) << __func__ << ": expiry complete, expire_pos/trim_pos is now "
             << std::hex << mdlog->get_journaler()->get_expire_pos() << "/"
             << mdlog->get_journaler()->get_trimmed_pos() << dendl;
@@ -218,6 +220,7 @@ class C_Flush_Journal : public MDSInternalContext {
   }
 
   void finish(int r) override {
+    ceph_assert(!ceph_mutex_is_locked_by_me(mds->mds_lock));
     dout(20) << __func__ << ": r=" << r << dendl;
     on_finish->complete(r);
   }