summaryrefslogtreecommitdiffstats
path: root/xlators/mgmt/glusterd/src
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/mgmt/glusterd/src')
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-handler.c10
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-op-sm.c64
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-op-sm.h2
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-store.c4
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-volgen.c2
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-volgen.h2
-rw-r--r--xlators/mgmt/glusterd/src/glusterd.c4
7 files changed, 43 insertions, 45 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-handler.c b/xlators/mgmt/glusterd/src/glusterd-handler.c
index 95da3d008..f4f2e0a2b 100644
--- a/xlators/mgmt/glusterd/src/glusterd-handler.c
+++ b/xlators/mgmt/glusterd/src/glusterd-handler.c
@@ -1724,21 +1724,21 @@ glusterd_handle_gsync_set (rpcsvc_request_t *req)
ret = dict_get_str (dict, "master", &master);
if (ret < 0) {
gf_log ("", GF_LOG_INFO, "master not found, while handling"
- "gsync options");
+ GEOREP" options");
master = "(No Master)";
}
ret = dict_get_str (dict, "slave", &slave);
if (ret < 0) {
gf_log ("", GF_LOG_INFO, "slave not not found, while"
- "handling gsync options");
+ "handling "GEOREP" options");
slave = "(No Slave)";
}
ret = dict_get_int32 (dict, "type", &type);
if (ret < 0) {
gf_log ("", GF_LOG_WARNING, "command type not found, while"
- "handling gsync options");
+ "handling "GEOREP" options");
goto out;
}
@@ -1761,10 +1761,10 @@ glusterd_handle_gsync_set (rpcsvc_request_t *req)
break;
}
- gf_cmd_log ("volume gsync", " %s command on %s,%s", operation, master,
+ gf_cmd_log ("volume "GEOREP, " %s command on %s,%s", operation, master,
slave);
ret = glusterd_op_begin (req, GD_OP_GSYNC_SET, dict, _gf_true);
- gf_cmd_log ("volume gsync", " %s command on %s,%s %s ", operation,
+ gf_cmd_log ("volume "GEOREP, " %s command on %s,%s %s ", operation,
master, slave, (ret != 0)? "FAILED" : "SUCCEEDED");
out:
diff --git a/xlators/mgmt/glusterd/src/glusterd-op-sm.c b/xlators/mgmt/glusterd/src/glusterd-op-sm.c
index 6e358821b..9719526a6 100644
--- a/xlators/mgmt/glusterd/src/glusterd-op-sm.c
+++ b/xlators/mgmt/glusterd/src/glusterd-op-sm.c
@@ -537,12 +537,12 @@ glusterd_op_stage_stop_volume (dict_t *dict, char **op_errstr)
ret = glusterd_check_gsync_running (volinfo, &is_run);
if (ret && (is_run == _gf_false))
gf_log ("", GF_LOG_WARNING, "Unable to get the status"
- " of active gsync session");
+ " of active "GEOREP" session");
if (is_run) {
- gf_log ("", GF_LOG_WARNING, "Gsync sessions active"
+ gf_log ("", GF_LOG_WARNING, GEOREP" sessions active"
"for the volume %s ", volname);
- snprintf (msg, sizeof(msg), "Gsync sessions are active "
- "for the volume '%s'.\nUse 'volume gsync "
+ snprintf (msg, sizeof(msg), GEOREP" sessions are active "
+ "for the volume '%s'.\nUse 'volume "GEOREP" "
"status' command for more info. Use 'force'"
"option to ignore and stop stop the volume",
volname);
@@ -1801,7 +1801,7 @@ glusterd_gsync_get_param_file (char *prmfile, const char *ext, char *master,
ptr = fgets(buff, sizeof(buff), in);
if (ptr) {
buff[strlen(buff)-1]='\0'; //strip off \n
- snprintf (prmfolder, PATH_MAX, "%s/gsync/%s", gl_workdir, buff);
+ snprintf (prmfolder, PATH_MAX, "%s/"GEOREP"/%s", gl_workdir, buff);
} else {
ret = -1;
goto out;
@@ -1850,7 +1850,7 @@ glusterd_gsync_get_pid_file (char *pidfile, char *master, char *slave)
ptr = fgets(buff, sizeof(buff), in);
if (ptr) {
buff[strlen(buff)-1]='\0'; //strip off \n
- snprintf (buffer, PATH_MAX, "%s/gsync/%s", priv->workdir, buff);
+ snprintf (buffer, PATH_MAX, "%s/"GEOREP"/%s", priv->workdir, buff);
strncpy (pidfolder, buffer, PATH_MAX);
} else {
ret = -1;
@@ -2230,7 +2230,7 @@ glusterd_check_gsync_running_local (char *master, char *slave,
if (ret == 0 && ret_status == 0) {
*is_run = _gf_true;
} else if (ret == -1) {
- gf_log ("", GF_LOG_WARNING, "gsync start validation "
+ gf_log ("", GF_LOG_WARNING, GEOREP" start validation "
" failed");
goto out;
}
@@ -2263,11 +2263,11 @@ glusterd_store_slave_in_info (glusterd_volinfo_t *volinfo, char *master,
dict_foreach (volinfo->gsync_slaves, _compare_host_uuid, &status);
if (status.ret_status == -1) {
- gf_log ("", GF_LOG_ERROR, "Gsync has already been invoked for "
+ gf_log ("", GF_LOG_ERROR, GEOREP" has already been invoked for "
"the %s (master) and %s (slave)"
"from a different machine",
master, slave);
- *op_errstr = gf_strdup ("Gsync already running in an an"
+ *op_errstr = gf_strdup (GEOREP" already running in an an"
"orhter machine");
ret = -1;
goto out;
@@ -2320,7 +2320,7 @@ glusterd_op_verify_gsync_start_options (glusterd_volinfo_t *volinfo,
if (GLUSTERD_STATUS_STARTED != volinfo->status) {
snprintf (msg, sizeof (msg), "Volume %s needs to be started "
- "before gsync start", volinfo->volname);
+ "before "GEOREP" start", volinfo->volname);
goto out;
}
/*Check if the gsync is already started in cmd. inited host
@@ -2330,12 +2330,12 @@ glusterd_op_verify_gsync_start_options (glusterd_volinfo_t *volinfo,
ret = glusterd_check_gsync_running_local (master, slave,
&is_running);
if (ret) {
- snprintf (msg, sizeof (msg), "gsync start option "
+ snprintf (msg, sizeof (msg), GEOREP" start option "
"validation failed ");
goto out;
}
if (_gf_true == is_running) {
- snprintf (msg, sizeof (msg), "gsync %s %s already "
+ snprintf (msg, sizeof (msg), GEOREP" %s %s already "
"started", master, slave);
ret = -1;
goto out;
@@ -2385,12 +2385,13 @@ glusterd_op_verify_gsync_running (glusterd_volinfo_t *volinfo,
if (GLUSTERD_STATUS_STARTED != volinfo->status) {
snprintf (msg, sizeof (msg), "Volume %s needs to be started "
- "before gsync start", volinfo->volname);
+ "before "GEOREP" start", volinfo->volname);
+
goto out;
}
ret = glusterd_gsync_get_uuid (master, slave, volinfo, uuid);
if (ret == -1) {
- snprintf (msg, sizeof (msg), "Gsync session is not active");
+ snprintf (msg, sizeof (msg), GEOREP" session is not active");
goto out;
}
@@ -4175,11 +4176,11 @@ stop_gsync (char *master, char *slave, char **op_errstr)
ret = gsync_status (master, slave, &status);
if (ret == 0 && status == -1) {
- gf_log ("", GF_LOG_WARNING, "Gsync is not running");
- *op_errstr = gf_strdup ("Gsync is not running");
+ gf_log ("", GF_LOG_WARNING, "gsyncd is not running");
+ *op_errstr = gf_strdup ("gsyncd is not running");
goto out;
} else if (ret == -1) {
- gf_log ("", GF_LOG_WARNING, "gsync stop validation "
+ gf_log ("", GF_LOG_WARNING, GEOREP" stop validation "
" failed");
*op_errstr = gf_strdup ("command to failed, please "
"check the log file");
@@ -4209,7 +4210,7 @@ stop_gsync (char *master, char *slave, char **op_errstr)
ret = kill (-pid, SIGTERM);
if (ret) {
gf_log ("", GF_LOG_WARNING,
- "failed to stop gsyncd");
+ "failed to kill gsyncd");
goto out;
}
for (i = 0; i < 20; i++) {
@@ -4229,7 +4230,7 @@ stop_gsync (char *master, char *slave, char **op_errstr)
}
ret = 0;
- *op_errstr = gf_strdup ("gsync stopped successfully");
+ *op_errstr = gf_strdup (GEOREP" stopped successfully");
out:
return ret;
@@ -4247,7 +4248,7 @@ gsync_config_set (char *master, char *slave,
if (THIS == NULL) {
gf_log ("", GF_LOG_ERROR, "THIS of glusterd not present");
- *op_errstr = gf_strdup ("Error! Glusterd cannot start gsyncd");
+ *op_errstr = gf_strdup ("Error! Glusterd cannot start "GEOREP);
goto out;
}
@@ -4255,7 +4256,7 @@ gsync_config_set (char *master, char *slave,
if (priv == NULL) {
gf_log ("", GF_LOG_ERROR, "priv of glusterd not present");
- *op_errstr = gf_strdup ("Error! Glusterd cannot start gsyncd");
+ *op_errstr = gf_strdup ("Error! Glusterd cannot start "GEOREP);
goto out;
}
@@ -4322,7 +4323,7 @@ gsync_config_del (char *master, char *slave,
if (THIS == NULL) {
gf_log ("", GF_LOG_ERROR, "THIS of glusterd not present");
- *op_errstr = gf_strdup ("Error! Glusterd cannot start gsyncd");
+ *op_errstr = gf_strdup ("Error! Glusterd cannot start "GEOREP);
goto out;
}
@@ -4330,7 +4331,7 @@ gsync_config_del (char *master, char *slave,
if (priv == NULL) {
gf_log ("", GF_LOG_ERROR, "priv of glusterd not present");
- *op_errstr = gf_strdup ("Error! Glusterd cannot start gsyncd");
+ *op_errstr = gf_strdup ("Error! Glusterd cannot start "GEOREP);
goto out;
}
@@ -4383,13 +4384,13 @@ glusterd_gsync_read_frm_status (char *path, char *data)
GF_ASSERT (data);
status_file = fopen (path, "r");
if (status_file == NULL) {
- gf_log ("", GF_LOG_WARNING, "Unable to read the Gsync status"
+ gf_log ("", GF_LOG_WARNING, "Unable to read gsyncd status"
" file");
return -1;
}
ret = fread (data, PATH_MAX, 1, status_file);
if (ret < 0) {
- gf_log ("", GF_LOG_WARNING, "Status file of Gsync is corrupt");
+ gf_log ("", GF_LOG_WARNING, "Status file of gsyncd is corrupt");
return -1;
}
@@ -4427,11 +4428,8 @@ glusterd_read_status_file (char *master, char *slave,
if (ret == 0 && status == -1) {
strncpy (buff, "Corrupt\n", sizeof (buff));
goto done;
- } else if (ret == -1) {
- gf_log ("", GF_LOG_WARNING, "Unable to determine "
- " Gsync's status");
+ } else if (ret == -1)
goto out;
- }
ret = glusterd_gsync_read_frm_status (statusfile, buff);
if (ret) {
@@ -4520,7 +4518,7 @@ glusterd_marker_create_volfile (glusterd_volinfo_t *volinfo)
ret = glusterd_create_volfiles_and_notify_services (volinfo);
if (ret) {
gf_log ("", GF_LOG_ERROR, "Unable to create volfile"
- " for setting of marker while 'gsync start'");
+ " for setting of marker while '"GEOREP" start'");
ret = -1;
goto out;
}
@@ -4785,7 +4783,7 @@ glusterd_op_gsync_set (dict_t *dict, char **op_errstr, dict_t *rsp_dict)
ret = glusterd_set_marker_gsync (master);
if (ret != 0) {
gf_log ("", GF_LOG_WARNING, "marker start failed");
- *op_errstr = gf_strdup ("gsync start failed");
+ *op_errstr = gf_strdup ("failed to initialize indexing");
ret = -1;
goto out;
}
@@ -4801,9 +4799,9 @@ glusterd_op_gsync_set (dict_t *dict, char **op_errstr, dict_t *rsp_dict)
ret = glusterd_gsync_get_uuid (master, slave, volinfo, uuid);
if (ret) {
- gf_log ("", GF_LOG_WARNING, "Gsync is not runing for"
+ gf_log ("", GF_LOG_WARNING, GEOREP" is not set up for"
"%s(master) and %s(slave)", master, slave);
- *op_errstr = strdup ("Gsync is not running");
+ *op_errstr = strdup (GEOREP" is not set up");
goto out;
}
diff --git a/xlators/mgmt/glusterd/src/glusterd-op-sm.h b/xlators/mgmt/glusterd/src/glusterd-op-sm.h
index 399d9a5c9..52e36ed3a 100644
--- a/xlators/mgmt/glusterd/src/glusterd-op-sm.h
+++ b/xlators/mgmt/glusterd/src/glusterd-op-sm.h
@@ -26,7 +26,7 @@
#endif
#ifndef GSYNC_CONF
-#define GSYNC_CONF "gsync/gsyncd.conf"
+#define GSYNC_CONF GEOREP"/gsyncd.conf"
#endif
#include <pthread.h>
diff --git a/xlators/mgmt/glusterd/src/glusterd-store.c b/xlators/mgmt/glusterd/src/glusterd-store.c
index 836c9d12c..d31110156 100644
--- a/xlators/mgmt/glusterd/src/glusterd-store.c
+++ b/xlators/mgmt/glusterd/src/glusterd-store.c
@@ -1523,8 +1523,8 @@ glusterd_store_retrieve_volume (char *volname)
"dict_set_str");
goto out;
}
- gf_log ("", GF_LOG_DEBUG, "Parsed as Gsync-"
- "skave:key=%s,value:%s", key, value);
+ gf_log ("", GF_LOG_DEBUG, "Parsed as "GEOREP" "
+ " slave:key=%s,value:%s", key, value);
}
else {
exists = glusterd_check_option_exists (key, NULL);
diff --git a/xlators/mgmt/glusterd/src/glusterd-volgen.c b/xlators/mgmt/glusterd/src/glusterd-volgen.c
index 6b5653be4..fd3b4792c 100644
--- a/xlators/mgmt/glusterd/src/glusterd-volgen.c
+++ b/xlators/mgmt/glusterd/src/glusterd-volgen.c
@@ -154,7 +154,7 @@ static struct volopt_map_entry glusterd_volopt_map[] = {
{"performance.quick-read", "performance/quick-read", "!perf", "on", NO_DOC, 0},
{VKEY_PERF_STAT_PREFETCH, "performance/stat-prefetch", "!perf", "on", NO_DOC, 0},
- {VKEY_MARKER_XTIME, "features/marker", "gsync", "off", NO_DOC, OPT_FLAG_FORCE},
+ {VKEY_MARKER_XTIME, "features/marker", "xtime", "off", NO_DOC, OPT_FLAG_FORCE},
{"nfs.enable-ino32", "nfs/server", "nfs.enable-ino32", NULL, GLOBAL_DOC, 0},
{"nfs.mem-factor", "nfs/server", "nfs.mem-factor", NULL, GLOBAL_DOC, 0},
diff --git a/xlators/mgmt/glusterd/src/glusterd-volgen.h b/xlators/mgmt/glusterd/src/glusterd-volgen.h
index 9e90b4130..518ae94ad 100644
--- a/xlators/mgmt/glusterd/src/glusterd-volgen.h
+++ b/xlators/mgmt/glusterd/src/glusterd-volgen.h
@@ -32,7 +32,7 @@
#define VKEY_DIAG_CNT_FOP_HITS "diagnostics.count-fop-hits"
#define VKEY_DIAG_LAT_MEASUREMENT "diagnostics.latency-measurement"
#define VKEY_FEATURES_LIMIT_USAGE "features.limit-usage"
-#define VKEY_MARKER_XTIME "features.marker-gsync"
+#define VKEY_MARKER_XTIME GEOREP".indexing"
#define VKEY_FEATURES_QUOTA "features.quota"
#define VKEY_PERF_STAT_PREFETCH "performance.stat-prefetch"
diff --git a/xlators/mgmt/glusterd/src/glusterd.c b/xlators/mgmt/glusterd/src/glusterd.c
index 7d20d6c5e..a0b654fc7 100644
--- a/xlators/mgmt/glusterd/src/glusterd.c
+++ b/xlators/mgmt/glusterd/src/glusterd.c
@@ -238,11 +238,11 @@ configure_syncaemon (xlator_t *this, const char *workdir)
char cmd[4096] = {0,};
int blen = 0;
- snprintf (voldir, PATH_MAX, "%s/gsync", workdir);
+ snprintf (voldir, PATH_MAX, "%s/"GEOREP, workdir);
ret = mkdir (voldir, 0777);
if ((-1 == ret) && (errno != EEXIST)) {
gf_log (this->name, GF_LOG_CRITICAL,
- "Unable to create gsync directory %s (%s)",
+ "Unable to create "GEOREP" directory %s (%s)",
voldir, strerror (errno));
return -1;
}
generated by cgit (git 2.34.1) at 2024-11-01 04:26:27 +0000