[Ocfs2-tools-devel] [PATCH 15/25] o2cb: Add ops start-heartbeat and stop-heartbeat
Sunil Mushran
sunil.mushran at oracle.com
Wed Jun 23 11:44:25 PDT 2010
Add ops to start and stop global heartbeat.
Signed-off-by: Sunil Mushran <sunil.mushran at oracle.com>
---
libo2cb/o2cb_err.et | 3 +
o2cb_ctl/Makefile | 7 +-
o2cb_ctl/o2cbtool.c | 12 ++
o2cb_ctl/o2cbtool.h | 3 +
o2cb_ctl/op_start.c | 341 +++++++++++++++++++++++++++++++++++++++++++++++++++
5 files changed, 364 insertions(+), 2 deletions(-)
create mode 100644 o2cb_ctl/op_start.c
diff --git a/libo2cb/o2cb_err.et b/libo2cb/o2cb_err.et
index 38a7069..978954d 100644
--- a/libo2cb/o2cb_err.et
+++ b/libo2cb/o2cb_err.et
@@ -81,4 +81,7 @@ ec O2CB_ET_BAD_VERSION,
ec O2CB_ET_INVALID_STACK_NAME,
"Cluster stack specified does not match the one currently running"
+ec O2CB_ET_UNKNOWN_REGION,
+ "Heartbeat region could not be found"
+
end
diff --git a/o2cb_ctl/Makefile b/o2cb_ctl/Makefile
index 7c4ef6a..cdeb80c 100644
--- a/o2cb_ctl/Makefile
+++ b/o2cb_ctl/Makefile
@@ -28,12 +28,12 @@ DEFINES = -DVERSION=\"$(VERSION)\"
O2CB_CONFIG_CFILES = o2cb_config.c jconfig.c jiterator.c
O2CB_CTL_CFILES = ${O2CB_CONFIG_CFILES} o2cb_ctl.c
O2CB_CFILES = ${O2CB_CONFIG_CFILES} o2cbtool.c op_cluster.c op_node.c op_heartbeat.c \
- op_lists.c op_register.c
+ op_lists.c op_register.c op_start.c o2cb_scandisk.c
O2CB_CTL_OBJS = $(subst .c,.o,$(O2CB_CTL_CFILES))
O2CB_OBJS = $(subst .c,.o,$(O2CB_CFILES))
-HFILES = o2cb_config.h jconfig.h jiterator.h o2cbtool.h
+HFILES = o2cb_config.h jconfig.h jiterator.h o2cbtool.h o2cb_scandisk.h
CFILES = $(O2CB_CTL_CFILES) $(O2CB_CFILES)
@@ -53,9 +53,12 @@ op_node_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
op_heartbeat_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
op_lists_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
op_register_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
+op_start_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
+o2cb_scandisk_CPPFLAGS = $(GLIB_CFLAGS) -DG_DISABLE_DEPRECATED
o2cb_ctl: $(O2CB_CTL_OBJS) $(LIBOCFS2_DEPS) $(LIBO2CB_DEPS)
$(LINK) $(LIBO2CB_LIBS) $(GLIB_LIBS) $(LIBOCFS2_LIBS) $(COM_ERR_LIBS)
+
o2cb: $(O2CB_OBJS) $(LIBOCFS2_DEPS) $(LIBO2CB_DEPS) ${LIBO2DLM_DEPS} ${LIBTOOLS_INTERNAL_DEPS}
$(LINK) $(LIBO2CB_LIBS) $(GLIB_LIBS) $(LIBOCFS2_LIBS) ${LIBO2DLM_LIBS} ${LIBTOOLS_INTERNAL_LIBS} $(COM_ERR_LIBS)
diff --git a/o2cb_ctl/o2cbtool.c b/o2cb_ctl/o2cbtool.c
index 5c44cab..181cdb3 100644
--- a/o2cb_ctl/o2cbtool.c
+++ b/o2cb_ctl/o2cbtool.c
@@ -109,6 +109,18 @@ struct o2cb_command o2cbtool_cmds[] = {
.o_help = "Unregisters the cluster from configfs.",
},
{
+ .o_name = "start-heartbeat",
+ .o_action = o2cbtool_start_heartbeat,
+ .o_usage = "<clustername>",
+ .o_help = "Starts global heartbeat."
+ },
+ {
+ .o_name = "stop-heartbeat",
+ .o_action = o2cbtool_stop_heartbeat,
+ .o_usage = "<clustername>",
+ .o_help = "Stops global heartbeat."
+ },
+ {
.o_name = NULL,
.o_action = NULL,
},
diff --git a/o2cb_ctl/o2cbtool.h b/o2cb_ctl/o2cbtool.h
index d5dd946..c2ff652 100644
--- a/o2cb_ctl/o2cbtool.h
+++ b/o2cb_ctl/o2cbtool.h
@@ -78,3 +78,6 @@ errcode_t o2cbtool_init_cluster_stack(void);
errcode_t o2cbtool_register_cluster(struct o2cb_command *cmd);
errcode_t o2cbtool_unregister_cluster(struct o2cb_command *cmd);
+
+errcode_t o2cbtool_start_heartbeat(struct o2cb_command *cmd);
+errcode_t o2cbtool_stop_heartbeat(struct o2cb_command *cmd);
diff --git a/o2cb_ctl/op_start.c b/o2cb_ctl/op_start.c
new file mode 100644
index 0000000..0d9f03c
--- /dev/null
+++ b/o2cb_ctl/op_start.c
@@ -0,0 +1,341 @@
+/* -*- mode: c; c-basic-offset: 8; -*-
+ * vim: noexpandtab sw=8 ts=8 sts=0:
+ *
+ * op_start.c
+ *
+ * Starts and stops the global heartbeat
+ *
+ * Copyright (C) 2010 Oracle. All rights reserved.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public
+ * License, version 2, as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * General Public License for more details.
+ */
+
+#include "o2cbtool.h"
+#include "o2cb_scandisk.h"
+
+extern const char *stackname;
+
+static errcode_t _fake_default_cluster_desc(
+ struct o2cb_cluster_desc *cluster_desc)
+{
+ errcode_t ret;
+ char **clusters;
+
+ memset(cluster_desc, 0, sizeof(struct o2cb_cluster_desc));
+
+ ret = o2cb_list_clusters(&clusters);
+ if (ret)
+ return ret;
+
+ cluster_desc->c_stack = strdup(stackname);
+ cluster_desc->c_cluster = strdup(clusters[0]);
+
+ if (!cluster_desc->c_stack || !cluster_desc->c_cluster) {
+ ret = O2CB_ET_NO_MEMORY;
+ free(cluster_desc->c_stack);
+ free(cluster_desc->c_cluster);
+ }
+
+ o2cb_free_cluster_list(clusters);
+
+ return ret;
+}
+
+/*
+ * Only the elements needed by o2cb_stop_heartbeat() are initialized in
+ * _fake_region_desc().
+ */
+static errcode_t _fake_region_desc(struct o2cb_region_desc *region_desc,
+ char *region_name)
+{
+ memset(region_desc, 0, sizeof(struct o2cb_region_desc));
+
+ region_desc->r_name = strdup(region_name);
+ if (!region_desc->r_name)
+ return O2CB_ET_NO_MEMORY;
+ region_desc->r_persist = 1;
+
+ return 0;
+}
+
+static void stop_heartbeat(struct o2cb_device *od)
+{
+ if (!(od->od_flags & O2CB_DEVICE_FOUND) ||
+ !(od->od_flags & O2CB_DEVICE_HB_STARTED))
+ return;
+}
+
+static void free_region_descs(struct list_head *hbdevs, int stop_hb)
+{
+ struct list_head *pos, *pos1;
+ struct o2cb_device *od;
+
+ list_for_each_safe(pos, pos1, hbdevs) {
+ od = list_entry(pos, struct o2cb_device, od_list);
+ if (stop_hb)
+ stop_heartbeat(od);
+ list_del(pos);
+ free(od->od_uuid);
+ free(od);
+ }
+}
+
+static errcode_t get_region_descs(O2CBCluster *cluster,
+ struct list_head *hbdevs)
+{
+ errcode_t ret = O2CB_ET_NO_MEMORY;
+ O2CBHeartbeat *heartbeat;
+ JIterator *iter;
+ gchar *region;
+ struct o2cb_device *od;
+
+ iter = o2cb_cluster_get_heartbeat_regions(cluster);
+
+ while (j_iterator_has_more(iter)) {
+ heartbeat = (O2CBHeartbeat *)j_iterator_get_next(iter);
+
+ region = o2cb_heartbeat_get_region(heartbeat);
+
+ verbosef(VL_DEBUG, "Heartbeat region %s\n", region);
+ od = calloc(1, sizeof(struct o2cb_device));
+ if (od) {
+ list_add_tail(&od->od_list, hbdevs);
+ od->od_uuid = strdup(region);
+ }
+
+ g_free(region);
+
+ if (!od || !od->od_uuid) {
+ tcom_err(ret, "while reading regions");
+ goto bail;
+ }
+ }
+
+ verbosef(VL_DEBUG, "Scanning devices\n");
+ o2cb_scandisk(hbdevs);
+
+ ret = 0;
+
+bail:
+ if (iter)
+ j_iterator_free(iter);
+
+ return ret;
+}
+
+static errcode_t start_heartbeat(struct o2cb_device *od)
+{
+ errcode_t ret = O2CB_ET_UNKNOWN_REGION;
+
+ if (!(od->od_flags & O2CB_DEVICE_FOUND)) {
+ tcom_err(ret, "%s", od->od_uuid);
+ goto bail;
+ }
+
+ verbosef(VL_DEBUG, "Starting heartbeat on region %s, device %s\n",
+ od->od_region.r_name, od->od_region.r_device_name);
+ ret = o2cb_start_heartbeat(&od->od_cluster, &od->od_region);
+ if (ret) {
+ if (ret == O2CB_ET_REGION_EXISTS)
+ ret = 0;
+ tcom_err(ret, "unable to start hb on uuid %s", od->od_uuid);
+ goto bail;
+ }
+
+ od->od_flags |= O2CB_DEVICE_HB_STARTED;
+
+bail:
+ return ret;
+}
+
+static errcode_t start_global_heartbeat(O2CBCluster *cluster)
+{
+ struct list_head hbdevs, *pos;
+ struct o2cb_device *od;
+ errcode_t ret;
+
+ INIT_LIST_HEAD(&hbdevs);
+ ret = get_region_descs(cluster, &hbdevs);
+ if (ret)
+ goto bail;
+
+ verbosef(VL_DEBUG, "About to start heartbeat\n");
+ list_for_each(pos, &hbdevs) {
+ od = list_entry(pos, struct o2cb_device, od_list);
+ ret = start_heartbeat(od);
+ if (ret)
+ goto bail;
+ }
+
+bail:
+ free_region_descs(&hbdevs, !!ret);
+ return ret;
+}
+
+/*
+ * o2cb start-heartbeat <clustername>
+ */
+errcode_t o2cbtool_start_heartbeat(struct o2cb_command *cmd)
+{
+ O2CBCluster *cluster;
+ int ret = -1;
+ gchar *clustername;
+ int global = 0;
+
+ if (cmd->o_argc < 2) {
+ errorf("usage: %s %s\n", cmd->o_name, cmd->o_usage);
+ goto bail;
+ }
+
+ clustername = cmd->o_argv[1];
+
+ cluster = o2cb_config_get_cluster_by_name(cmd->o_config, clustername);
+ if (!cluster) {
+ errorf("Unknown cluster '%s'\n", clustername);
+ goto bail;
+ }
+
+ ret = o2cbtool_init_cluster_stack();
+ if (ret)
+ goto bail;
+
+ verbosef(VL_DEBUG, "Checking heartbeat mode\n");
+ /* Exit it not global */
+ ret = o2cb_global_heartbeat_mode(clustername, &global);
+ if (ret) {
+ tcom_err(ret, "while starting heartbeat");
+ goto bail;
+ }
+
+ if (!global)
+ goto bail;
+ verbosef(VL_DEBUG, "Global heartbeat enabled\n");
+
+ /* TODO ensure cluster is registered */
+
+ ret = start_global_heartbeat(cluster);
+ if (ret)
+ goto bail;
+
+ verbosef(VL_OUT, "Global heartbeat started\n");
+
+bail:
+ return ret;
+}
+
+static errcode_t stop_global_heartbeat(char *clustername)
+{
+ struct o2cb_cluster_desc cluster_desc = { NULL, NULL };
+ struct o2cb_region_desc region_desc = { NULL, };
+ errcode_t ret;
+ gchar **regions = NULL;
+ int i;
+
+ ret = _fake_default_cluster_desc(&cluster_desc);
+ if (ret) {
+ tcom_err(ret, "while looking up the active cluster.");
+ goto bail;
+ }
+
+ if (strcmp(cluster_desc.c_cluster, clustername)) {
+ errorf("Cluster %s is not active\n", clustername);
+ ret = -1;
+ goto bail;
+ }
+
+ verbosef(VL_DEBUG, "Looking up active heartbeat regions\n");
+ /* lookup active heartbeats */
+ ret = o2cb_list_hbregions(clustername, ®ions);
+ if (ret) {
+ tcom_err(ret, "while looking up the active heartbeat regions");
+ goto bail;
+ }
+
+ /* error, if found */
+ for (i = 0; regions[i]; ++i) {
+ if (!regions[i] || !(*(regions[i])))
+ continue;
+
+ ret = _fake_region_desc(®ion_desc, regions[i]);
+ if (ret) {
+ tcom_err(ret, "while filling region description");
+ goto bail;
+ }
+
+ verbosef(VL_DEBUG, "Stopping heartbeat on region %s\n",
+ regions[i]);
+ ret = o2cb_stop_heartbeat(&cluster_desc, ®ion_desc);
+ if (ret) {
+ tcom_err(ret, "while stopping heartbeat in region "
+ "'%s'\n", regions[i]);
+ goto bail;
+ }
+ free(region_desc.r_name);
+ region_desc.r_name = NULL;
+ }
+
+ ret = 0;
+
+bail:
+ if (regions)
+ o2cb_free_hbregions_list(regions);
+ free(cluster_desc.c_stack);
+ free(cluster_desc.c_cluster);
+ free(region_desc.r_name);
+
+ return ret;
+}
+
+/*
+ * o2cb stop-heartbeat <clustername>
+ */
+errcode_t o2cbtool_stop_heartbeat(struct o2cb_command *cmd)
+{
+ //O2CBCluster *cluster;
+ int ret = -1;
+ gchar *clustername;
+ int global = 0;
+
+ if (cmd->o_argc < 2) {
+ errorf("usage: %s %s\n", cmd->o_name, cmd->o_usage);
+ goto bail;
+ }
+
+ clustername = cmd->o_argv[1];
+
+ ret = o2cbtool_init_cluster_stack();
+ if (ret)
+ goto bail;
+
+ /* ensure cluster is registered */
+
+ verbosef(VL_DEBUG, "Checking heartbeat mode\n");
+ /* Exit it not global */
+ ret = o2cb_global_heartbeat_mode(clustername, &global);
+ if (ret) {
+ tcom_err(ret, "while stopping heartbeat");
+ goto bail;
+ }
+
+ if (!global) {
+ verbosef(VL_DEBUG, "Global heartbeat not enabled\n");
+ goto bail;
+ }
+
+ verbosef(VL_DEBUG, "Global heartbeat enabled\n");
+
+ ret = stop_global_heartbeat(clustername);
+ if (ret)
+ goto bail;
+
+ verbosef(VL_OUT, "Global heartbeat stopped\n");
+bail:
+ return ret;
+}
--
1.7.0.4
More information about the Ocfs2-tools-devel
mailing list