From 965503fc2d32d562c7956d4935f9c00768ed4e13 Mon Sep 17 00:00:00 2001
From: Pranith Kumar K <pkarampu@redhat.com>
Date: Tue, 11 Feb 2020 15:42:05 +0530
Subject: tests: Fix spurious self-heald.t failure

Problem:
heal-info code assumes that all indices in xattrop directory
definitely need heal. There is one corner case.
The very first xattrop on the file will lead to adding the
gfid to 'xattrop' index in fop path and in _cbk path it is
removed because the fop is zero-xattr xattrop in success case.
These gfids could be read by heal-info and shown as needing heal.

Fix:
Check the pending flag to see if the file definitely needs or
not instead of which index is being crawled at the moment.

fixes: bz#1802449
Change-Id: I79f00dc7366fedbbb25ec4bec838dba3b34c7ad5
Signed-off-by: Pranith Kumar K <pkarampu@redhat.com>
(cherry picked from commit d27df94016b5526c18ee964d4a47508326329dda)
---
 xlators/cluster/afr/src/afr-common.c | 38 ++++++++++++++----------------------
 1 file changed, 15 insertions(+), 23 deletions(-)

(limited to 'xlators')

diff --git a/xlators/cluster/afr/src/afr-common.c b/xlators/cluster/afr/src/afr-common.c
index 5e399ee98df..812bdc36767 100644
--- a/xlators/cluster/afr/src/afr-common.c
+++ b/xlators/cluster/afr/src/afr-common.c
@@ -6054,8 +6054,8 @@ afr_is_dirty_count_non_unary(xlator_t *this, struct afr_reply *replies,
 
 static int
 afr_update_heal_status(xlator_t *this, struct afr_reply *replies,
-                       char *index_vgfid, ia_type_t ia_type, gf_boolean_t *esh,
-                       gf_boolean_t *dsh, gf_boolean_t *msh)
+                       ia_type_t ia_type, gf_boolean_t *esh, gf_boolean_t *dsh,
+                       gf_boolean_t *msh, unsigned char pending)
 {
     int ret = -1;
     GF_UNUSED int ret1 = 0;
@@ -6085,14 +6085,7 @@ afr_update_heal_status(xlator_t *this, struct afr_reply *replies,
         }
     }
 
-    if (!strcmp(index_vgfid, GF_XATTROP_INDEX_GFID)) {
-        if (shd_domain_lk_count) {
-            ret = -EAGAIN; /*For 'possibly-healing'. */
-        } else {
-            ret = 0; /*needs heal. Just set a non -ve value so that it is
-                       assumed as the source index.*/
-        }
-    } else if (!strcmp(index_vgfid, GF_XATTROP_DIRTY_GFID)) {
+    if (!pending) {
         if ((afr_is_dirty_count_non_unary(this, replies, ia_type)) ||
             (!io_domain_lk_count)) {
             /* Needs heal. */
@@ -6101,6 +6094,13 @@ afr_update_heal_status(xlator_t *this, struct afr_reply *replies,
             /* No heal needed. */
             *dsh = *esh = *msh = 0;
         }
+    } else {
+        if (shd_domain_lk_count) {
+            ret = -EAGAIN; /*For 'possibly-healing'. */
+        } else {
+            ret = 0; /*needs heal. Just set a non -ve value so that it is
+                       assumed as the source index.*/
+        }
     }
     return ret;
 }
@@ -6108,8 +6108,8 @@ afr_update_heal_status(xlator_t *this, struct afr_reply *replies,
 /*return EIO, EAGAIN or pending*/
 int
 afr_lockless_inspect(call_frame_t *frame, xlator_t *this, uuid_t gfid,
-                     inode_t **inode, char *index_vgfid,
-                     gf_boolean_t *entry_selfheal, gf_boolean_t *data_selfheal,
+                     inode_t **inode, gf_boolean_t *entry_selfheal,
+                     gf_boolean_t *data_selfheal,
                      gf_boolean_t *metadata_selfheal, unsigned char *pending)
 {
     int ret = -1;
@@ -6168,8 +6168,8 @@ afr_lockless_inspect(call_frame_t *frame, xlator_t *this, uuid_t gfid,
             goto out;
     }
 
-    ret = afr_update_heal_status(this, replies, index_vgfid, (*inode)->ia_type,
-                                 &esh, &dsh, &msh);
+    ret = afr_update_heal_status(this, replies, (*inode)->ia_type, &esh, &dsh,
+                                 &msh, *pending);
 out:
     *data_selfheal = dsh;
     *entry_selfheal = esh;
@@ -6194,14 +6194,6 @@ afr_get_heal_info(call_frame_t *frame, xlator_t *this, loc_t *loc)
     char *status = NULL;
     call_frame_t *heal_frame = NULL;
     afr_local_t *heal_local = NULL;
-    afr_local_t *local = NULL;
-    char *index_vgfid = NULL;
-
-    local = frame->local;
-    if (dict_get_str(local->xdata_req, "index-vgfid", &index_vgfid)) {
-        ret = -1;
-        goto out;
-    }
 
     /*Use frame with lk-owner set*/
     heal_frame = afr_frame_create(frame->this, &op_errno);
@@ -6212,7 +6204,7 @@ afr_get_heal_info(call_frame_t *frame, xlator_t *this, loc_t *loc)
     heal_local = heal_frame->local;
     heal_frame->local = frame->local;
 
-    ret = afr_lockless_inspect(heal_frame, this, loc->gfid, &inode, index_vgfid,
+    ret = afr_lockless_inspect(heal_frame, this, loc->gfid, &inode,
                                &entry_selfheal, &data_selfheal,
                                &metadata_selfheal, &pending);
 
-- 
cgit