diff options
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-quotad-svc.c')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-quotad-svc.c | 217 |
1 files changed, 217 insertions, 0 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-quotad-svc.c b/xlators/mgmt/glusterd/src/glusterd-quotad-svc.c new file mode 100644 index 00000000000..f26d832a06d --- /dev/null +++ b/xlators/mgmt/glusterd/src/glusterd-quotad-svc.c @@ -0,0 +1,217 @@ +/* + Copyright (c) 2014 Red Hat, Inc. <http://www.redhat.com> + This file is part of GlusterFS. + + This file is licensed to you under your choice of the GNU Lesser + General Public License, version 3 or any later version (LGPLv3 or + later), or the GNU General Public License, version 2 (GPLv2), in all + cases as published by the Free Software Foundation. +*/ + +#include <glusterfs/globals.h> +#include <glusterfs/run.h> +#include "glusterd.h" +#include "glusterd-utils.h" +#include "glusterd-volgen.h" +#include "glusterd-quotad-svc.h" +#include "glusterd-messages.h" +#include "glusterd-svc-helper.h" + +char *quotad_svc_name = "quotad"; + +void +glusterd_quotadsvc_build(glusterd_svc_t *svc) +{ + svc->manager = glusterd_quotadsvc_manager; + svc->start = glusterd_quotadsvc_start; + svc->stop = glusterd_svc_stop; +} + +int +glusterd_quotadsvc_init(glusterd_svc_t *svc) +{ + int ret = -1; + + ret = glusterd_svc_init(svc, quotad_svc_name); + if (ret) + goto out; + +out: + return ret; +} + +static int +glusterd_quotadsvc_create_volfile() +{ + char filepath[PATH_MAX] = { + 0, + }; + glusterd_conf_t *conf = THIS->private; + + glusterd_svc_build_volfile_path(quotad_svc_name, conf->workdir, filepath, + sizeof(filepath)); + return glusterd_create_global_volfile(build_quotad_graph, filepath, NULL); +} + +int +glusterd_quotadsvc_manager(glusterd_svc_t *svc, void *data, int flags) +{ + int ret = 0; + glusterd_volinfo_t *volinfo = NULL; + + if (!svc->inited) { + ret = glusterd_quotadsvc_init(svc); + if (ret) { + gf_msg(THIS->name, GF_LOG_ERROR, 0, GD_MSG_FAILED_INIT_QUOTASVC, + "Failed to init " + "quotad service"); + goto out; + } else { + svc->inited = _gf_true; + gf_msg_debug(THIS->name, 0, + "quotad service " + "initialized"); + } + } + + volinfo = data; + + /* If all the volumes are stopped or all shd compatible volumes + * are stopped then stop the service if: + * - volinfo is NULL or + * - volinfo is present and volume is shd compatible + * Otherwise create volfile and restart service if: + * - volinfo is NULL or + * - volinfo is present and volume is shd compatible + */ + if (glusterd_are_all_volumes_stopped() || + glusterd_all_volumes_with_quota_stopped()) { + if (!(volinfo && !glusterd_is_volume_quota_enabled(volinfo))) { + ret = svc->stop(svc, SIGTERM); + } + } else { + if (!(volinfo && !glusterd_is_volume_quota_enabled(volinfo))) { + ret = glusterd_quotadsvc_create_volfile(); + if (ret) + goto out; + + ret = svc->stop(svc, SIGTERM); + if (ret) + goto out; + + ret = svc->start(svc, flags); + if (ret) + goto out; + + ret = glusterd_conn_connect(&(svc->conn)); + if (ret) + goto out; + } + } +out: + if (ret) + gf_event(EVENT_SVC_MANAGER_FAILED, "svc_name=%s", svc->name); + + gf_msg_debug(THIS->name, 0, "Returning %d", ret); + + return ret; +} + +int +glusterd_quotadsvc_start(glusterd_svc_t *svc, int flags) +{ + int i = 0; + int ret = -1; + dict_t *cmdline = NULL; + char key[16] = {0}; + char *options[] = {svc->name, "--process-name", NULL}; + + cmdline = dict_new(); + if (!cmdline) { + gf_smsg(THIS->name, GF_LOG_ERROR, errno, GD_MSG_DICT_CREATE_FAIL, NULL); + goto out; + } + + for (i = 0; options[i]; i++) { + ret = snprintf(key, sizeof(key), "arg%d", i); + ret = dict_set_strn(cmdline, key, ret, options[i]); + if (ret) + goto out; + } + + ret = glusterd_svc_start(svc, flags, cmdline); + +out: + if (cmdline) + dict_unref(cmdline); + + gf_msg_debug(THIS->name, 0, "Returning %d", ret); + + return ret; +} + +int +glusterd_quotadsvc_reconfigure() +{ + int ret = -1; + xlator_t *this = NULL; + glusterd_conf_t *priv = NULL; + gf_boolean_t identical = _gf_false; + + this = THIS; + GF_VALIDATE_OR_GOTO("glusterd", this, out); + + priv = this->private; + GF_VALIDATE_OR_GOTO(this->name, priv, out); + + if (glusterd_all_volumes_with_quota_stopped()) + goto manager; + + /* + * Check both OLD and NEW volfiles, if they are SAME by size + * and cksum i.e. "character-by-character". If YES, then + * NOTHING has been changed, just return. + */ + ret = glusterd_svc_check_volfile_identical(priv->quotad_svc.name, + build_quotad_graph, &identical); + if (ret) + goto out; + + if (identical) { + ret = 0; + goto out; + } + + /* + * They are not identical. Find out if the topology is changed + * OR just the volume options. If just the options which got + * changed, then inform the xlator to reconfigure the options. + */ + identical = _gf_false; /* RESET the FLAG */ + ret = glusterd_svc_check_topology_identical(priv->quotad_svc.name, + build_quotad_graph, &identical); + if (ret) + goto out; + + /* Topology is not changed, but just the options. But write the + * options to quotad volfile, so that quotad will be reconfigured. + */ + if (identical) { + ret = glusterd_quotadsvc_create_volfile(); + if (ret == 0) { /* Only if above PASSES */ + ret = glusterd_fetchspec_notify(THIS); + } + goto out; + } +manager: + /* + * quotad volfile's topology has been changed. quotad server needs + * to be RESTARTED to ACT on the changed volfile. + */ + ret = priv->quotad_svc.manager(&(priv->quotad_svc), NULL, + PROC_START_NO_WAIT); + +out: + gf_msg_debug(this ? this->name : "Quotad", 0, "Returning %d", ret); + return ret; +} |