summaryrefslogtreecommitdiffstats
path: root/xlators/cluster/afr/src/afr-self-heal-common.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/cluster/afr/src/afr-self-heal-common.c')
-rw-r--r--xlators/cluster/afr/src/afr-self-heal-common.c40
1 files changed, 2 insertions, 38 deletions
diff --git a/xlators/cluster/afr/src/afr-self-heal-common.c b/xlators/cluster/afr/src/afr-self-heal-common.c
index 781437bf74e..f06f7e603a0 100644
--- a/xlators/cluster/afr/src/afr-self-heal-common.c
+++ b/xlators/cluster/afr/src/afr-self-heal-common.c
@@ -1831,34 +1831,6 @@ afr_selfheal_unlocked_lookup_on(call_frame_t *frame, inode_t *parent,
return inode;
}
-static int
-afr_set_multi_dom_lock_count_request(xlator_t *this, dict_t *dict)
-{
- int ret = 0;
- afr_private_t *priv = NULL;
- char *key = NULL;
-
- priv = this->private;
- key = alloca0(strlen(GLUSTERFS_INODELK_DOM_PREFIX) + 2 +
- strlen(priv->sh_domain));
-
- ret = dict_set_uint32(dict, GLUSTERFS_MULTIPLE_DOM_LK_CNT_REQUESTS, 1);
- if (ret)
- return ret;
-
- sprintf(key, "%s:%s", GLUSTERFS_INODELK_DOM_PREFIX, this->name);
- ret = dict_set_uint32(dict, key, 1);
- if (ret)
- return ret;
-
- sprintf(key, "%s:%s", GLUSTERFS_INODELK_DOM_PREFIX, priv->sh_domain);
- ret = dict_set_uint32(dict, key, 1);
- if (ret)
- return ret;
-
- return 0;
-}
-
int
afr_selfheal_unlocked_discover_on(call_frame_t *frame, inode_t *inode,
uuid_t gfid, struct afr_reply *replies,
@@ -1885,11 +1857,6 @@ afr_selfheal_unlocked_discover_on(call_frame_t *frame, inode_t *inode,
return -ENOMEM;
}
- if (afr_set_multi_dom_lock_count_request(frame->this, xattr_req)) {
- dict_unref(xattr_req);
- return -1;
- }
-
loc.inode = inode_ref(inode);
gf_uuid_copy(loc.gfid, gfid);
@@ -2285,8 +2252,7 @@ int
afr_selfheal_unlocked_inspect(call_frame_t *frame, xlator_t *this, uuid_t gfid,
inode_t **link_inode, gf_boolean_t *data_selfheal,
gf_boolean_t *metadata_selfheal,
- gf_boolean_t *entry_selfheal,
- struct afr_reply *replies_dst)
+ gf_boolean_t *entry_selfheal)
{
afr_private_t *priv = NULL;
inode_t *inode = NULL;
@@ -2422,8 +2388,6 @@ afr_selfheal_unlocked_inspect(call_frame_t *frame, xlator_t *this, uuid_t gfid,
ret = 0;
out:
- if (replies && replies_dst)
- afr_replies_copy(replies_dst, replies, priv->child_count);
if (inode)
inode_unref(inode);
if (replies)
@@ -2543,7 +2507,7 @@ afr_selfheal_do(call_frame_t *frame, xlator_t *this, uuid_t gfid)
ret = afr_selfheal_unlocked_inspect(frame, this, gfid, &inode,
&data_selfheal, &metadata_selfheal,
- &entry_selfheal, NULL);
+ &entry_selfheal);
if (ret)
goto out;