summaryrefslogtreecommitdiffstats
path: root/xlators/mgmt/glusterd/src/glusterd-quotad-svc.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-quotad-svc.c')
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-quotad-svc.c158
1 files changed, 158 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..bd77a72c5ab
--- /dev/null
+++ b/xlators/mgmt/glusterd/src/glusterd-quotad-svc.c
@@ -0,0 +1,158 @@
+/*
+ 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 "globals.h"
+#include "run.h"
+#include "glusterd.h"
+#include "glusterd-utils.h"
+#include "glusterd-volgen.h"
+#include "glusterd-quotad-svc.h"
+
+char *quotad_svc_name = "quotad";
+
+int glusterd_quotadsvc_init (glusterd_svc_t *svc)
+{
+ int ret = -1;
+ char volfile[PATH_MAX] = {0,};
+ glusterd_conf_t *conf = THIS->private;
+
+ ret = glusterd_svc_init (svc, quotad_svc_name,
+ glusterd_quotadsvc_manager,
+ glusterd_quotadsvc_start,
+ glusterd_svc_stop);
+ if (ret)
+ goto out;
+
+ /* glusterd_svc_build_volfile_path () doesn't put correct quotad volfile
+ * path in proc object at service initialization. Re-initialize
+ * the correct path
+ */
+ glusterd_quotadsvc_build_volfile_path (quotad_svc_name, conf->workdir,
+ volfile, sizeof (volfile));
+ snprintf (svc->proc.volfile, sizeof (svc->proc.volfile), "%s", volfile);
+out:
+ return ret;
+}
+
+static int
+glusterd_quotadsvc_create_volfile ()
+{
+ char filepath[PATH_MAX] = {0,};
+ glusterd_conf_t *conf = THIS->private;
+
+ glusterd_quotadsvc_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;
+
+ 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:
+ gf_log (THIS->name, GF_LOG_DEBUG, "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[] = {
+ "*replicate*.entry-self-heal=off",
+ "--xlator-option",
+ "*replicate*.metadata-self-heal=off",
+ "--xlator-option",
+ "*replicate*.data-self-heal=off",
+ "--xlator-option",
+ NULL
+ };
+
+ cmdline = dict_new ();
+ if (!cmdline)
+ goto out;
+
+ for (i = 0; options[i]; i++) {
+ memset (key, 0, sizeof (key));
+ snprintf (key, sizeof (key), "arg%d", i);
+ ret = dict_set_str (cmdline, key, options[i]);
+ if (ret)
+ goto out;
+ }
+
+ ret = glusterd_svc_start (svc, flags, cmdline);
+
+out:
+ if (cmdline)
+ dict_unref (cmdline);
+
+ gf_log (THIS->name, GF_LOG_DEBUG, "Returning %d", ret);
+
+ return ret;
+}
+
+int
+glusterd_quotadsvc_reconfigure ()
+{
+ return glusterd_svc_reconfigure (glusterd_quotadsvc_create_volfile);
+}
+
+void
+glusterd_quotadsvc_build_volfile_path (char *server, char *workdir,
+ char *volfile, size_t len)
+{
+ char dir[PATH_MAX] = {0,};
+
+ GF_ASSERT (len == PATH_MAX);
+
+ glusterd_svc_build_svcdir (server, workdir, dir, sizeof (dir));
+ snprintf (volfile, len, "%s/%s.vol", dir, server);
+}