d2787b
From 8c366f34a279a5ab2a6301bfd93534fe746a23e8 Mon Sep 17 00:00:00 2001
d2787b
From: Ravishankar N <ravishankar@redhat.com>
d2787b
Date: Mon, 7 Dec 2020 09:53:27 +0530
d2787b
Subject: [PATCH 483/511] afr: more quorum checks in lookup and new entry
d2787b
 marking
d2787b
d2787b
Problem: See upstream github issue for details.
d2787b
d2787b
Fix:
d2787b
-In lookup if the entry exists in 2 out of 3 bricks, don't fail the
d2787b
lookup with ENOENT just because there is an entrylk on the parent.
d2787b
Consider quorum before deciding.
d2787b
d2787b
-If entry FOP does not succeed on quorum no. of bricks, do not perform
d2787b
new entry mark.
d2787b
d2787b
Upstream patch details:
d2787b
> Reviewed-on: https://review.gluster.org/#/c/glusterfs/+/24499/
d2787b
> Fixes: #1303
d2787b
> Change-Id: I56df8c89ad53b29fa450c7930a7b7ccec9f4a6c5
d2787b
> Signed-off-by: Ravishankar N <ravishankar@redhat.com>
d2787b
d2787b
BUG: 1821599
d2787b
Change-Id: If513e8a7d6088a676288927630d8e616269bf5d5
d2787b
Signed-off-by: Ravishankar N <ravishankar@redhat.com>
d2787b
Reviewed-on: https://code.engineering.redhat.com/gerrit/220363
d2787b
Tested-by: RHGS Build Bot <nigelb@redhat.com>
d2787b
Reviewed-by: Sunil Kumar Heggodu Gopala Acharya <sheggodu@redhat.com>
d2787b
---
d2787b
 ...20-mark-dirty-for-entry-txn-on-quorum-failure.t |  2 --
d2787b
 xlators/cluster/afr/src/afr-common.c               | 24 ++++++++++++----------
d2787b
 xlators/cluster/afr/src/afr-dir-write.c            |  8 ++++++++
d2787b
 xlators/cluster/afr/src/afr.h                      |  4 ++++
d2787b
 4 files changed, 25 insertions(+), 13 deletions(-)
d2787b
d2787b
diff --git a/tests/bugs/replicate/bug-1586020-mark-dirty-for-entry-txn-on-quorum-failure.t b/tests/bugs/replicate/bug-1586020-mark-dirty-for-entry-txn-on-quorum-failure.t
d2787b
index 26f9049..49c4dea 100644
d2787b
--- a/tests/bugs/replicate/bug-1586020-mark-dirty-for-entry-txn-on-quorum-failure.t
d2787b
+++ b/tests/bugs/replicate/bug-1586020-mark-dirty-for-entry-txn-on-quorum-failure.t
d2787b
@@ -53,8 +53,6 @@ TEST ! ls $B0/${V0}1/file$i
d2787b
 TEST ls $B0/${V0}2/file$i
d2787b
 dirty=$(get_hex_xattr trusted.afr.dirty $B0/${V0}2)
d2787b
 TEST [ "$dirty" != "000000000000000000000000" ]
d2787b
-EXPECT "000000010000000100000000" get_hex_xattr trusted.afr.$V0-client-0 $B0/${V0}2/file$i
d2787b
-EXPECT "000000010000000100000000" get_hex_xattr trusted.afr.$V0-client-1 $B0/${V0}2/file$i
d2787b
 
d2787b
 TEST $CLI volume set $V0 self-heal-daemon on
d2787b
 EXPECT_WITHIN $PROCESS_UP_TIMEOUT "Y" glustershd_up_status
d2787b
diff --git a/xlators/cluster/afr/src/afr-common.c b/xlators/cluster/afr/src/afr-common.c
d2787b
index 89e2483..851ccad 100644
d2787b
--- a/xlators/cluster/afr/src/afr-common.c
d2787b
+++ b/xlators/cluster/afr/src/afr-common.c
d2787b
@@ -1236,7 +1236,7 @@ refresh_done:
d2787b
     return 0;
d2787b
 }
d2787b
 
d2787b
-static void
d2787b
+void
d2787b
 afr_fill_success_replies(afr_local_t *local, afr_private_t *priv,
d2787b
                          unsigned char *replies)
d2787b
 {
d2787b
@@ -2290,6 +2290,7 @@ afr_lookup_done(call_frame_t *frame, xlator_t *this)
d2787b
         0,
d2787b
     };
d2787b
     gf_boolean_t locked_entry = _gf_false;
d2787b
+    gf_boolean_t in_flight_create = _gf_false;
d2787b
     gf_boolean_t can_interpret = _gf_true;
d2787b
     inode_t *parent = NULL;
d2787b
     ia_type_t ia_type = IA_INVAL;
d2787b
@@ -2333,17 +2334,12 @@ afr_lookup_done(call_frame_t *frame, xlator_t *this)
d2787b
         if (!replies[i].valid)
d2787b
             continue;
d2787b
 
d2787b
-        if (locked_entry && replies[i].op_ret == -1 &&
d2787b
-            replies[i].op_errno == ENOENT) {
d2787b
-            /* Second, check entry is still
d2787b
-               "underway" in creation */
d2787b
-            local->op_ret = -1;
d2787b
-            local->op_errno = ENOENT;
d2787b
-            goto error;
d2787b
-        }
d2787b
-
d2787b
-        if (replies[i].op_ret == -1)
d2787b
+        if (replies[i].op_ret == -1) {
d2787b
+            if (locked_entry && replies[i].op_errno == ENOENT) {
d2787b
+                in_flight_create = _gf_true;
d2787b
+            }
d2787b
             continue;
d2787b
+        }
d2787b
 
d2787b
         if (read_subvol == -1 || !readable[read_subvol]) {
d2787b
             read_subvol = i;
d2787b
@@ -2353,6 +2349,12 @@ afr_lookup_done(call_frame_t *frame, xlator_t *this)
d2787b
         }
d2787b
     }
d2787b
 
d2787b
+    if (in_flight_create && !afr_has_quorum(success_replies, this, NULL)) {
d2787b
+        local->op_ret = -1;
d2787b
+        local->op_errno = ENOENT;
d2787b
+        goto error;
d2787b
+    }
d2787b
+
d2787b
     if (read_subvol == -1)
d2787b
         goto error;
d2787b
     /* We now have a read_subvol, which is readable[] (if there
d2787b
diff --git a/xlators/cluster/afr/src/afr-dir-write.c b/xlators/cluster/afr/src/afr-dir-write.c
d2787b
index 84e2a34..416c19d 100644
d2787b
--- a/xlators/cluster/afr/src/afr-dir-write.c
d2787b
+++ b/xlators/cluster/afr/src/afr-dir-write.c
d2787b
@@ -349,6 +349,7 @@ afr_mark_entry_pending_changelog(call_frame_t *frame, xlator_t *this)
d2787b
     afr_private_t *priv = NULL;
d2787b
     int pre_op_count = 0;
d2787b
     int failed_count = 0;
d2787b
+    unsigned char *success_replies = NULL;
d2787b
 
d2787b
     local = frame->local;
d2787b
     priv = this->private;
d2787b
@@ -364,9 +365,16 @@ afr_mark_entry_pending_changelog(call_frame_t *frame, xlator_t *this)
d2787b
     failed_count = AFR_COUNT(local->transaction.failed_subvols,
d2787b
                              priv->child_count);
d2787b
 
d2787b
+    /* FOP succeeded on all bricks. */
d2787b
     if (pre_op_count == priv->child_count && !failed_count)
d2787b
         return;
d2787b
 
d2787b
+    /* FOP did not suceed on quorum no. of bricks. */
d2787b
+    success_replies = alloca0(priv->child_count);
d2787b
+    afr_fill_success_replies(local, priv, success_replies);
d2787b
+    if (!afr_has_quorum(success_replies, this, NULL))
d2787b
+        return;
d2787b
+
d2787b
     if (priv->thin_arbiter_count) {
d2787b
         /*Mark new entry using ta file*/
d2787b
         local->is_new_entry = _gf_true;
d2787b
diff --git a/xlators/cluster/afr/src/afr.h b/xlators/cluster/afr/src/afr.h
d2787b
index ff96246..ed5096e 100644
d2787b
--- a/xlators/cluster/afr/src/afr.h
d2787b
+++ b/xlators/cluster/afr/src/afr.h
d2787b
@@ -1334,4 +1334,8 @@ afr_mark_new_entry_changelog(call_frame_t *frame, xlator_t *this);
d2787b
 
d2787b
 void
d2787b
 afr_selfheal_childup(xlator_t *this, afr_private_t *priv);
d2787b
+
d2787b
+void
d2787b
+afr_fill_success_replies(afr_local_t *local, afr_private_t *priv,
d2787b
+                         unsigned char *replies);
d2787b
 #endif /* __AFR_H__ */
d2787b
-- 
d2787b
1.8.3.1
d2787b