]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
mds: avoid acquiring the wrlock twice for a single request
authorXiubo Li <xiubli@redhat.com>
Mon, 8 Jul 2024 07:53:28 +0000 (15:53 +0800)
committerVenky Shankar <vshankar@redhat.com>
Mon, 17 Feb 2025 07:30:48 +0000 (13:00 +0530)
In case the current request has lock cache attached and then the
lock cache must have already acquired the wrlock of filelock. So
currently the path_traverse() will acquire the wrlock twice and
possibly caused deadlock by itself.

Fixes: https://tracker.ceph.com/issues/65607
Signed-off-by: Xiubo Li <xiubli@redhat.com>
Signed-off-by: Sunnatillo <sunnat.samadov@est.tech>
(cherry picked from commit 276b81a55d391b52f9772fc76b86b845eb3854a6)

Conflicts:
    src/mds/MDSRank.cc

This commit moves around the config `mds_allow_async_dirops` in
the tracked keys which caused the conflict - avoid the move.

src/mds/MDCache.cc

index f00e588c7a2e3644cb21d8f5feffcee394785c25..ead3868520e2dbfe16729473e54c09bf5ff39d31 100644 (file)
@@ -8509,8 +8509,11 @@ int MDCache::path_traverse(const MDRequestRef& mdr, MDSContextFactory& cf,
          lov.add_xlock(&dn->lock);
        } else {
          // force client to flush async dir operation if necessary
-         if (cur->filelock.is_cached())
+         if (cur->filelock.is_cached() &&
+             !(mdr->lock_cache &&
+               static_cast<const MutationImpl*>(mdr->lock_cache)->is_wrlocked(&cur->filelock))) {
            lov.add_wrlock(&cur->filelock);
+         }
          lov.add_rdlock(&dn->lock);
        }
        if (!mds->locker->acquire_locks(mdr, lov)) {
@@ -8630,8 +8633,11 @@ int MDCache::path_traverse(const MDRequestRef& mdr, MDSContextFactory& cf,
                lov.add_xlock(&dn->lock);
              } else {
                // force client to flush async dir operation if necessary
-               if (cur->filelock.is_cached())
+               if (cur->filelock.is_cached() &&
+                   !(mdr->lock_cache &&
+                     static_cast<const MutationImpl*>(mdr->lock_cache)->is_wrlocked(&cur->filelock))) {
                  lov.add_wrlock(&cur->filelock);
+               }
                lov.add_rdlock(&dn->lock);
              }
              if (!mds->locker->acquire_locks(mdr, lov)) {