From d68a2dbb3a4be89a4a45661310ae3f32542df20f Mon Sep 17 00:00:00 2001 From: Gaurav Kumar Garg Date: Mon, 13 Apr 2015 12:34:26 +0530 Subject: bitrot/glusterd: Bitrot scrub pause/resume should give proper error bitrot scrubber paused/resume command should give proper error messages if scrubber already pause/resume and user again try to perform same operation on a volume. Change-Id: I01ad69c80f03b177535a4e5f1c95ab7709a804b0 BUG: 1210684 Signed-off-by: Gaurav Kumar Garg Reviewed-on: http://review.gluster.org/10209 Reviewed-by: Atin Mukherjee Tested-by: Gluster Build System Reviewed-by: Kaushal M --- xlators/mgmt/glusterd/src/glusterd-bitrot.c | 46 +++++++++++++++++++++++++---- 1 file changed, 40 insertions(+), 6 deletions(-) (limited to 'xlators/mgmt/glusterd/src/glusterd-bitrot.c') diff --git a/xlators/mgmt/glusterd/src/glusterd-bitrot.c b/xlators/mgmt/glusterd/src/glusterd-bitrot.c index 5474f30626a..456e5e788ab 100644 --- a/xlators/mgmt/glusterd/src/glusterd-bitrot.c +++ b/xlators/mgmt/glusterd/src/glusterd-bitrot.c @@ -507,12 +507,15 @@ out: int glusterd_op_stage_bitrot (dict_t *dict, char **op_errstr, dict_t *rsp_dict) { - int ret = 0; - char *volname = NULL; - int type = 0; - xlator_t *this = NULL; - glusterd_conf_t *priv = NULL; - glusterd_volinfo_t *volinfo = NULL; + int ret = 0; + char *volname = NULL; + char *scrub_cmd = NULL; + char *scrub_cmd_from_dict = NULL; + char msg[2048] = {0,}; + int type = 0; + xlator_t *this = NULL; + glusterd_conf_t *priv = NULL; + glusterd_volinfo_t *volinfo = NULL; this = THIS; GF_ASSERT (this); @@ -560,6 +563,37 @@ glusterd_op_stage_bitrot (dict_t *dict, char **op_errstr, dict_t *rsp_dict) goto out; } + if ((GF_BITROT_OPTION_TYPE_SCRUB == type)) { + ret = dict_get_str (volinfo->dict, "features.scrub", + &scrub_cmd_from_dict); + if (!ret) { + ret = dict_get_str (dict, "scrub-value", &scrub_cmd); + if (ret) { + gf_log (this->name, GF_LOG_ERROR, "Unable to " + "get scrub-value"); + *op_errstr = gf_strdup ("Staging failed for " + "bitrot operation. " + "Please check log file" + " for more details."); + goto out; + } + /* If scrubber is resume then value of scrubber will be + * "Active" in the dictionary. */ + if (!strcmp (scrub_cmd_from_dict, scrub_cmd) || + (!strncmp ("Active", scrub_cmd_from_dict, + strlen("Active")) && !strncmp ("resume", + scrub_cmd, strlen("resume")))) { + snprintf (msg, sizeof (msg), "Scrub is already" + " %sd for volume %s", scrub_cmd, + volinfo->volname); + *op_errstr = gf_strdup (msg); + ret = -1; + goto out; + } + } + ret = 0; + } + out: if (ret && op_errstr && *op_errstr) gf_log (this->name, GF_LOG_ERROR, "%s", *op_errstr); -- cgit