No OneTemporary
Actions

Size

33 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/fencing/main.c b/fencing/main.c
	index 087bd01160..502bfe1a57 100644
	--- a/fencing/main.c
	+++ b/fencing/main.c
	@@ -1,863 +1,864 @@
	/*
	* Copyright (C) 2009 Andrew Beekhof <andrew@beekhof.net>
	*
	* This program is free software; you can redistribute it and/or
	* modify it under the terms of the GNU General Public
	* License as published by the Free Software Foundation; either
	* version 2 of the License, or (at your option) any later version.
	*
	* This software 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.
	*
	* You should have received a copy of the GNU General Public
	* License along with this library; if not, write to the Free Software
	* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
	*/

	#include <crm_internal.h>

	#include <sys/param.h>
	#include <stdio.h>
	#include <sys/types.h>
	#include <sys/stat.h>
	#include <unistd.h>
	#include <sys/utsname.h>

	#include <stdlib.h>
	#include <errno.h>
	#include <fcntl.h>

	#include <crm/crm.h>
	#include <crm/msg_xml.h>
	#include <crm/common/ipc.h>
	#include <crm/cluster/internal.h>

	#include <crm/stonith-ng.h>
	#include <crm/fencing/internal.h>
	#include <crm/common/xml.h>

	#include <crm/common/mainloop.h>

	#include <crm/cib/internal.h>

	#include <internal.h>

	#include <standalone_config.h>

	char *stonith_our_uname = NULL;

	GMainLoop *mainloop = NULL;
	GHashTable *client_list = NULL;

	gboolean stand_alone = FALSE;
	gboolean stonith_shutdown_flag = FALSE;

	qb_ipcs_service_t *ipcs = NULL;

	#if SUPPORT_HEARTBEAT
	ll_cluster_t *hb_conn = NULL;
	#endif

	static void stonith_shutdown(int nsig);
	static void stonith_cleanup(void);

	static int32_t
	st_ipc_accept(qb_ipcs_connection_t *c, uid_t uid, gid_t gid)
	{
	crm_trace("Connecting %p for uid=%d gid=%d", c, uid, gid);
	if(stonith_shutdown_flag) {
	- crm_info("Ignoring new client [%d] during shutdown", crm_ipcs_client_pid(c));
	- return -EPERM;
	+ crm_info("Ignoring new client [%d] during shutdown", crm_ipcs_client_pid(c));
	+ return -EPERM;
	}
	return 0;
	}

	static void
	st_ipc_created(qb_ipcs_connection_t *c)
	{
	stonith_client_t *new_client = NULL;

	#if 0
	struct qb_ipcs_stats srv_stats;

	qb_ipcs_stats_get(s1, &srv_stats, QB_FALSE);
	qb_log(LOG_INFO, "Connection created (active:%d, closed:%d)",
	srv_stats.active_connections,
	srv_stats.closed_connections);
	#endif

	new_client = calloc(1, sizeof(stonith_client_t));
	new_client->channel = c;
	new_client->channel_name = strdup("ipc");
	-
	+
	CRM_CHECK(new_client->id == NULL, free(new_client->id));
	new_client->id = crm_generate_uuid();
	crm_trace("Created channel %p for client %s", c, new_client->id);
	-
	+
	/* make sure we can find ourselves later for sync calls
	* redirected to the master instance
	*/
	g_hash_table_insert(client_list, new_client->id, new_client);
	qb_ipcs_context_set(c, new_client);
	CRM_ASSERT(qb_ipcs_context_get(c) != NULL);
	}

	/* Exit code means? */
	static int32_t
	st_ipc_dispatch(qb_ipcs_connection_t c, void data, size_t size)
	{
	xmlNode *request = NULL;
	- stonith_client_t client = (stonith_client_t)qb_ipcs_context_get(c);
	+ stonith_client_t client = (stonith_client_t)qb_ipcs_context_get(c);

	request = crm_ipcs_recv(c, data, size);
	if (request == NULL) {
	return 0;
	}

	CRM_CHECK(client != NULL, goto cleanup);
	-
	+
	if(client->name == NULL) {
	const char *value = crm_element_value(request, F_STONITH_CLIENTNAME);
	if(value == NULL) {
	client->name = crm_itoa(crm_ipcs_client_pid(c));
	} else {
	client->name = strdup(value);
	}
	}

	CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p/%s", client, client->name); goto cleanup);
	-
	+
	crm_xml_add(request, F_STONITH_CLIENTID, client->id);
	crm_xml_add(request, F_STONITH_CLIENTNAME, client->name);
	-
	+
	crm_log_xml_trace(request, "Client[inbound]");
	stonith_command(client, request, NULL);

	cleanup:
	if(client == NULL \|\| client->id == NULL) {
	crm_log_xml_notice(request, "Invalid client");
	}

	free_xml(request);
	return 0;
	}

	/* Error code means? */
	static int32_t
	-st_ipc_closed(qb_ipcs_connection_t *c)
	+st_ipc_closed(qb_ipcs_connection_t *c)
	{
	stonith_client_t client = (stonith_client_t)qb_ipcs_context_get(c);

	#if 0
	qb_ipcs_stats_get(s1, &srv_stats, QB_FALSE);
	qb_ipcs_connection_stats_get(c, &stats, QB_FALSE);
	qb_log(LOG_INFO, "Connection to pid:%d destroyed (active:%d, closed:%d)",
	stats.client_pid,
	srv_stats.active_connections,
	srv_stats.closed_connections);

	qb_log(LOG_DEBUG, " Requests %"PRIu64"", stats.requests);
	qb_log(LOG_DEBUG, " Responses %"PRIu64"", stats.responses);
	qb_log(LOG_DEBUG, " Events %"PRIu64"", stats.events);
	qb_log(LOG_DEBUG, " Send retries %"PRIu64"", stats.send_retries);
	qb_log(LOG_DEBUG, " Recv retries %"PRIu64"", stats.recv_retries);
	qb_log(LOG_DEBUG, " FC state %d", stats.flow_control_state);
	qb_log(LOG_DEBUG, " FC count %"PRIu64"", stats.flow_control_count);
	#endif

	if (client == NULL) {
	- crm_err("No client");
	- return 0;
	+ crm_err("No client");
	+ return 0;
	}
	-
	+
	crm_trace("Cleaning up after client disconnect: %p/%s/%s", client, crm_str(client->name), client->id);
	if(client->id != NULL) {
	g_hash_table_remove(client_list, client->id);
	}

	/* 0 means: yes, go ahead and destroy the connection */
	return 0;
	}

	static void
	-st_ipc_destroy(qb_ipcs_connection_t *c)
	+st_ipc_destroy(qb_ipcs_connection_t *c)
	{
	stonith_client_t client = (stonith_client_t)qb_ipcs_context_get(c);

	/* Make sure the connection is fully cleaned up */
	st_ipc_closed(c);

	if(client == NULL) {
	- crm_trace("Nothing to destroy");
	- return;
	+ crm_trace("Nothing to destroy");
	+ return;
	}

	crm_trace("Destroying %s (%p)", client->name, client);
	-
	+
	free(client->name);
	free(client->id);
	free(client);
	crm_trace("Done");

	return;
	}

	static void
	stonith_peer_callback(xmlNode * msg, void* private_data)
	{
	const char *remote = crm_element_value(msg, F_ORIG);
	crm_log_xml_trace(msg, "Peer[inbound]");
	stonith_command(NULL, msg, remote);
	}

	#if SUPPORT_HEARTBEAT
	static void
	stonith_peer_hb_callback(HA_Message * msg, void* private_data)
	{
	xmlNode *xml = convert_ha_message(NULL, msg, __FUNCTION__);
	stonith_peer_callback(xml, private_data);
	free_xml(xml);
	}
	static void
	stonith_peer_hb_destroy(gpointer user_data)
	{
	if(stonith_shutdown_flag) {
	- crm_info("Heartbeat disconnection complete... exiting");
	+ crm_info("Heartbeat disconnection complete... exiting");
	} else {
	- crm_err("Heartbeat connection lost! Exiting.");
	+ crm_err("Heartbeat connection lost! Exiting.");
	}
	stonith_shutdown(0);
	}
	#endif


	-#if SUPPORT_COROSYNC
	+#if SUPPORT_COROSYNC
	static gboolean stonith_peer_ais_callback(
	- AIS_Message wrapper, char data, int sender)
	+ AIS_Message wrapper, char data, int sender)
	{
	xmlNode *xml = NULL;

	if(wrapper->header.id == crm_class_cluster) {
	- xml = string2xml(data);
	- if(xml == NULL) {
	- goto bail;
	- }
	- crm_xml_add(xml, F_ORIG, wrapper->sender.uname);
	- crm_xml_add_int(xml, F_SEQ, wrapper->id);
	- stonith_peer_callback(xml, NULL);
	+ xml = string2xml(data);
	+ if(xml == NULL) {
	+ goto bail;
	+ }
	+ crm_xml_add(xml, F_ORIG, wrapper->sender.uname);
	+ crm_xml_add_int(xml, F_SEQ, wrapper->id);
	+ stonith_peer_callback(xml, NULL);
	}

	free_xml(xml);
	return TRUE;

	bail:
	crm_err("Invalid XML: '%.120s'", data);
	return TRUE;

	}

	static void
	stonith_peer_ais_destroy(gpointer user_data)
	{
	crm_err("AIS connection terminated");
	stonith_shutdown(0);
	}
	#endif

	void do_local_reply(xmlNode notify_src, const char client_id,
	- gboolean sync_reply, gboolean from_peer)
	+ gboolean sync_reply, gboolean from_peer)
	{
	/* send callback to originating child */
	stonith_client_t *client_obj = NULL;
	int local_rc = pcmk_ok;

	crm_trace("Sending response");

	if(client_id != NULL) {
	- client_obj = g_hash_table_lookup(client_list, client_id);
	+ client_obj = g_hash_table_lookup(client_list, client_id);
	} else {
	- crm_trace("No client to sent the response to."
	- " F_STONITH_CLIENTID not set.");
	+ crm_trace("No client to sent the response to."
	+ " F_STONITH_CLIENTID not set.");
	}
	-
	+
	crm_trace("Sending callback to request originator");
	if(client_obj == NULL) {
	- local_rc = -1;
	-
	+ local_rc = -1;
	+
	} else {
	- crm_trace("Sending %ssync response to %s %s",
	- sync_reply?"":"an a-",
	- client_obj->name,
	- from_peer?"(originator of delegated request)":"");
	-
	- local_rc = crm_ipcs_send(client_obj->channel, notify_src, !sync_reply);
	- }
	-
	+ crm_trace("Sending %ssync response to %s %s",
	+ sync_reply?"":"an a-",
	+ client_obj->name,
	+ from_peer?"(originator of delegated request)":"");
	+
	+ local_rc = crm_ipcs_send(client_obj->channel, notify_src, !sync_reply);
	+ }
	+
	if(local_rc < pcmk_ok && client_obj != NULL) {
	- crm_warn("%sSync reply to %s failed: %s",
	- sync_reply?"":"A-",
	- client_obj?client_obj->name:"<unknown>", pcmk_strerror(local_rc));
	+ crm_warn("%sSync reply to %s failed: %s",
	+ sync_reply?"":"A-",
	+ client_obj?client_obj->name:"<unknown>", pcmk_strerror(local_rc));
	}
	}

	-long long get_stonith_flag(const char *name)
	+long long get_stonith_flag(const char *name)
	{
	if(safe_str_eq(name, T_STONITH_NOTIFY_FENCE)) {
	- return 0x01;
	-
	+ return 0x01;
	+
	} else if(safe_str_eq(name, STONITH_OP_DEVICE_ADD)) {
	- return 0x04;
	+ return 0x04;

	} else if(safe_str_eq(name, STONITH_OP_DEVICE_DEL)) {
	- return 0x10;
	+ return 0x10;
	}
	return 0;
	}

	static void
	stonith_notify_client(gpointer key, gpointer value, gpointer user_data)
	{

	xmlNode *update_msg = user_data;
	stonith_client_t *client = value;
	const char *type = NULL;

	CRM_CHECK(client != NULL, return);
	CRM_CHECK(update_msg != NULL, return);

	type = crm_element_value(update_msg, F_SUBTYPE);
	CRM_CHECK(type != NULL, crm_log_xml_err(update_msg, "notify"); return);

	if(client->channel == NULL) {
	- crm_trace("Skipping client with NULL channel");
	- return;
	+ crm_trace("Skipping client with NULL channel");
	+ return;

	} else if(client->name == NULL) {
	- crm_trace("Skipping unnammed client / comamnd channel");
	- return;
	+ crm_trace("Skipping unnammed client / comamnd channel");
	+ return;
	}

	if(client->flags & get_stonith_flag(type)) {
	- crm_trace("Sending %s-notification to client %s/%s", type, client->name, client->id);
	+ crm_trace("Sending %s-notification to client %s/%s", type, client->name, client->id);
	if(crm_ipcs_send(client->channel, update_msg, ipcs_send_event\|ipcs_send_error) <= 0) {
	- crm_warn("%s-Notification of client %s/%s failed",
	- type, client->name, client->id);
	- }
	+ crm_warn("%s-Notification of client %s/%s failed",
	+ type, client->name, client->id);
	+ }
	}
	}

	void
	do_stonith_notify(
	int options, const char type, int result, xmlNode data,
	const char *remote)
	{
	/* TODO: Standardize the contents of data */
	xmlNode *update_msg = create_xml_node(NULL, "notify");

	CRM_CHECK(type != NULL, ;);
	-
	+
	crm_xml_add(update_msg, F_TYPE, T_STONITH_NOTIFY);
	crm_xml_add(update_msg, F_SUBTYPE, type);
	crm_xml_add(update_msg, F_STONITH_OPERATION, type);
	crm_xml_add_int(update_msg, F_STONITH_RC, result);
	-
	+
	if(data != NULL) {
	- add_message_xml(update_msg, F_STONITH_CALLDATA, data);
	+ add_message_xml(update_msg, F_STONITH_CALLDATA, data);
	}

	crm_trace("Notifying clients");
	g_hash_table_foreach(client_list, stonith_notify_client, update_msg);
	free_xml(update_msg);
	crm_trace("Notify complete");
	}

	-static stonith_key_value_t parse_device_list(const char devices)
	+static stonith_key_value_t parse_device_list(const char devices)
	{
	int lpc = 0;
	int max = 0;
	int last = 0;
	stonith_key_value_t *output = NULL;

	if(devices == NULL) {
	- return output;
	+ return output;
	}

	max = strlen(devices);
	for(lpc = 0; lpc <= max; lpc++) {
	if(devices[lpc] == ',' \|\| devices[lpc] == 0) {
	- char *line = NULL;
	+ char *line = NULL;

	line = calloc(1, 2 + lpc - last);
	snprintf(line, 1 + lpc - last, "%s", devices+last);
	output = stonith_key_value_add(output, NULL, line);
	free(line);

	last = lpc + 1;
	}
	}

	return output;
	}

	-static void topology_remove_helper(const char *node, int level)
	+static void topology_remove_helper(const char *node, int level)
	{
	int rc;
	char *desc = NULL;
	xmlNode *data = create_xml_node(NULL, F_STONITH_LEVEL);
	xmlNode *notify_data = create_xml_node(NULL, STONITH_OP_LEVEL_DEL);

	crm_xml_add(data, "origin", __FUNCTION__);
	crm_xml_add_int(data, XML_ATTR_ID, level);
	crm_xml_add(data, F_STONITH_TARGET, node);

	rc = stonith_level_remove(data, &desc);

	crm_xml_add(notify_data, F_STONITH_DEVICE, desc);
	crm_xml_add_int(notify_data, F_STONITH_ACTIVE, g_hash_table_size(topology));
	-
	+
	do_stonith_notify(0, STONITH_OP_LEVEL_DEL, rc, notify_data, NULL);

	free_xml(notify_data);
	free_xml(data);
	free(desc);
	}

	static void topology_register_helper(const char node, int level, stonith_key_value_t device_list)
	{
	int rc;
	char *desc = NULL;
	xmlNode *notify_data = create_xml_node(NULL, STONITH_OP_LEVEL_ADD);
	xmlNode *data = create_level_registration_xml(node, level, device_list);

	rc = stonith_level_register(data, &desc);

	crm_xml_add(notify_data, F_STONITH_DEVICE, desc);
	crm_xml_add_int(notify_data, F_STONITH_ACTIVE, g_hash_table_size(topology));
	-
	+
	do_stonith_notify(0, STONITH_OP_LEVEL_ADD, rc, notify_data, NULL);

	free_xml(notify_data);
	free_xml(data);
	free(desc);
	}

	static void remove_fencing_topology(xmlXPathObjectPtr xpathObj)
	{
	int max = 0, lpc = 0;

	if(xpathObj && xpathObj->nodesetval) {
	max = xpathObj->nodesetval->nodeNr;
	}

	for(lpc = 0; lpc < max; lpc++) {
	xmlNode *match = getXpathResult(xpathObj, lpc);
	CRM_CHECK(match != NULL, continue);

	if(crm_element_value(match, XML_DIFF_MARKER)) {
	/* Deletion */
	int index = 0;
	const char *target = crm_element_value(match, XML_ATTR_STONITH_TARGET);

	crm_element_value_int(match, XML_ATTR_STONITH_INDEX, &index);
	if(target == NULL) {
	crm_err("Invalid fencing target in element %s", ID(match));

	} else if(index <= 0) {
	crm_err("Invalid level for %s in element %s", target, ID(match));

	} else {
	topology_remove_helper(target, index);
	}
	/* } else { Deal with modifications during the 'addition' stage */
	}
	}
	}


	static void register_fencing_topology(xmlXPathObjectPtr xpathObj, gboolean force)
	{
	int max = 0, lpc = 0;

	if(xpathObj && xpathObj->nodesetval) {
	max = xpathObj->nodesetval->nodeNr;
	}

	for(lpc = 0; lpc < max; lpc++) {
	int index = 0;
	const char *target;
	const char *dev_list;
	stonith_key_value_t *devices = NULL;
	xmlNode *match = getXpathResult(xpathObj, lpc);
	CRM_CHECK(match != NULL, continue);

	crm_element_value_int(match, XML_ATTR_STONITH_INDEX, &index);
	target = crm_element_value(match, XML_ATTR_STONITH_TARGET);
	dev_list = crm_element_value(match, XML_ATTR_STONITH_DEVICES);
	devices = parse_device_list(dev_list);

	crm_trace("Updating %s[%d] (%s) to %s", target, index, ID(match), dev_list);

	if(target == NULL) {
	crm_err("Invalid fencing target in element %s", ID(match));

	} else if(index <= 0) {
	crm_err("Invalid level for %s in element %s", target, ID(match));

	} else if(force == FALSE && crm_element_value(match, XML_DIFF_MARKER)) {
	/* Addition */
	topology_register_helper(target, index, devices);

	} else { /* Modification */
	/* Remove then re-add */
	topology_remove_helper(target, index);
	topology_register_helper(target, index, devices);
	}

	stonith_key_value_freeall(devices, 1, 1);
	}
	}

	/* Fencing
	<diff crm_feature_set="3.0.6">
	<diff-removed>
	<fencing-topology>
	<fencing-level id="f-p1.1" target="pcmk-1" index="1" devices="poison-pill" __crm_diff_marker__="removed:top"/>
	<fencing-level id="f-p1.2" target="pcmk-1" index="2" devices="power" __crm_diff_marker__="removed:top"/>
	<fencing-level devices="disk,network" id="f-p2.1"/>
	</fencing-topology>
	</diff-removed>
	<diff-added>
	<fencing-topology>
	<fencing-level id="f-p.1" target="pcmk-1" index="1" devices="poison-pill" __crm_diff_marker__="added:top"/>
	<fencing-level id="f-p2.1" target="pcmk-2" index="1" devices="disk,something"/>
	<fencing-level id="f-p3.1" target="pcmk-2" index="2" devices="power" __crm_diff_marker__="added:top"/>
	</fencing-topology>
	</diff-added>
	</diff>
	*/

	static void
	fencing_topology_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
	{
	xmlXPathObjectPtr xpathObj = NULL;
	const char *xpath = "//" XML_TAG_FENCING_LEVEL;

	crm_trace("Pushing in stonith topology");

	/* Grab everything */
	xpathObj = xpath_search(msg, xpath);

	register_fencing_topology(xpathObj, TRUE);

	if(xpathObj) {
	- xmlXPathFreeObject(xpathObj);
	+ xmlXPathFreeObject(xpathObj);
	}
	}

	static void
	update_fencing_topology(const char event, xmlNode msg)
	{
	const char *xpath;
	xmlXPathObjectPtr xpathObj = NULL;

	/* Process deletions (only) */
	xpath = "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_REMOVED "//" XML_TAG_FENCING_LEVEL;
	xpathObj = xpath_search(msg, xpath);

	remove_fencing_topology(xpathObj);

	if(xpathObj) {
	- xmlXPathFreeObject(xpathObj);
	+ xmlXPathFreeObject(xpathObj);
	}

	/* Process additions and changes */
	xpath = "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_ADDED "//" XML_TAG_FENCING_LEVEL;
	xpathObj = xpath_search(msg, xpath);

	register_fencing_topology(xpathObj, FALSE);

	if(xpathObj) {
	- xmlXPathFreeObject(xpathObj);
	+ xmlXPathFreeObject(xpathObj);
	}
	}

	static void
	stonith_shutdown(int nsig)
	{
	stonith_shutdown_flag = TRUE;
	crm_info("Terminating with %d clients", g_hash_table_size(client_list));
	if(mainloop != NULL && g_main_is_running(mainloop)) {
	g_main_quit(mainloop);
	} else {
	stonith_cleanup();
	exit(EX_OK);
	}
	}

	cib_t *cib = NULL;

	static void
	stonith_cleanup(void)
	{
	if(cib) {
	cib->cmds->signoff(cib);
	}

	qb_ipcs_destroy(ipcs);
	- crm_peer_destroy();
	+ crm_peer_destroy();
	g_hash_table_destroy(client_list);
	free(stonith_our_uname);
	#if HAVE_LIBXML2
	crm_xml_cleanup();
	#endif
	}

	/* INDENT-OFF */
	static struct crm_option long_options[] = {
	{"stand-alone", 0, 0, 's'},
	{"verbose", 0, 0, 'V'},
	{"version", 0, 0, '$'},
	{"help", 0, 0, '?'},
	-
	+
	{0, 0, 0, 0}
	};
	/* INDENT-ON */

	static void
	setup_cib(void)
	{
	static void *cib_library = NULL;
	static cib_t (cib_new_fn)(void) = NULL;
	static const char (cib_err_fn)(int) = NULL;

	int rc, retries = 0;

	if(cib_library == NULL) {
	cib_library = dlopen(CIB_LIBRARY, RTLD_LAZY);
	}
	if(cib_library && cib_new_fn == NULL) {
	cib_new_fn = dlsym(cib_library, "cib_new");
	}
	if(cib_library && cib_err_fn == NULL) {
	cib_err_fn = dlsym(cib_library, "pcmk_strerror");
	}
	if(cib_new_fn != NULL) {
	cib = (*cib_new_fn)();
	}
	-
	+
	if(cib == NULL) {
	crm_err("No connection to the CIB");
	return;
	}

	do {
	sleep(retries);
	rc = cib->cmds->signon(cib, CRM_SYSTEM_CRMD, cib_command);
	} while(rc == -ENOTCONN && ++retries < 5);
	-
	+
	if (rc != pcmk_ok) {
	crm_err("Could not connect to the CIB service: %s", (*cib_err_fn)(rc));
	-
	+
	} else if (pcmk_ok != cib->cmds->add_notify_callback(
	cib, T_CIB_DIFF_NOTIFY, update_fencing_topology)) {
	crm_err("Could not set CIB notification callback");
	-
	+
	} else {
	rc = cib->cmds->query(cib, NULL, NULL, cib_scope_local);
	add_cib_op_callback(cib, rc, FALSE, NULL, fencing_topology_callback);
	crm_notice("Watching for stonith topology changes");
	- }
	+ }
	}

	-struct qb_ipcs_service_handlers ipc_callbacks =
	+struct qb_ipcs_service_handlers ipc_callbacks =
	{
	.connection_accept = st_ipc_accept,
	.connection_created = st_ipc_created,
	.msg_process = st_ipc_dispatch,
	.connection_closed = st_ipc_closed,
	.connection_destroyed = st_ipc_destroy
	};

	int
	main(int argc, char ** argv)
	{
	int flag;
	int rc = 0;
	int lpc = 0;
	int argerr = 0;
	int option_index = 0;
	const char *actions[] = { "reboot", "poweroff", "list", "monitor", "status" };

	crm_log_init("stonith-ng", LOG_INFO, TRUE, FALSE, argc, argv, FALSE);
	crm_set_options(NULL, "mode [options]", long_options,
	- "Provides a summary of cluster's current state."
	- "\n\nOutputs varying levels of detail in a number of different formats.\n");
	+ "Provides a summary of cluster's current state."
	+ "\n\nOutputs varying levels of detail in a number of different formats.\n");

	while (1) {
	- flag = crm_get_option(argc, argv, &option_index);
	- if (flag == -1)
	- break;
	-
	- switch(flag) {
	- case 'V':
	- crm_bump_log_level();
	- break;
	- case 's':
	- stand_alone = TRUE;
	- break;
	- case '$':
	- case '?':
	- crm_help(flag, EX_OK);
	- break;
	- default:
	- ++argerr;
	- break;
	- }
	+ flag = crm_get_option(argc, argv, &option_index);
	+ if (flag == -1) {
	+ break;
	+ }
	+
	+ switch(flag) {
	+ case 'V':
	+ crm_bump_log_level();
	+ break;
	+ case 's':
	+ stand_alone = TRUE;
	+ break;
	+ case '$':
	+ case '?':
	+ crm_help(flag, EX_OK);
	+ break;
	+ default:
	+ ++argerr;
	+ break;
	+ }
	}

	if(argc - optind == 1 && safe_str_eq("metadata", argv[optind])) {
	- printf("<?xml version=\"1.0\"?><!DOCTYPE resource-agent SYSTEM \"ra-api-1.dtd\">\n");
	- printf("<resource-agent name=\"stonithd\">\n");
	- printf(" <version>1.0</version>\n");
	- printf(" <longdesc lang=\"en\">This is a fake resource that details the instance attributes handled by stonithd.</longdesc>\n");
	- printf(" <shortdesc lang=\"en\">Options available for all stonith resources</shortdesc>\n");
	- printf(" <parameters>\n");
	-
	- printf(" <parameter name=\"stonith-timeout\" unique=\"0\">\n");
	- printf(" <shortdesc lang=\"en\">How long to wait for the STONITH action to complete.</shortdesc>\n");
	- printf(" <longdesc lang=\"en\">Overrides the stonith-timeout cluster property</longdesc>\n");
	- printf(" <content type=\"time\" default=\"60s\"/>\n");
	- printf(" </parameter>\n");
	-
	- printf(" <parameter name=\"priority\" unique=\"0\">\n");
	- printf(" <shortdesc lang=\"en\">The priority of the stonith resource. The lower the number, the higher the priority.</shortdesc>\n");
	- printf(" <content type=\"integer\" default=\"0\"/>\n");
	- printf(" </parameter>\n");
	-
	- printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTARG);
	- printf(" <shortdesc lang=\"en\">Advanced use only: An alternate parameter to supply instead of 'port'</shortdesc>\n");
	- printf(" <longdesc lang=\"en\">Some devices do not support the standard 'port' parameter or may provide additional ones.\n"
	- "Use this to specify an alternate, device-specific, parameter that should indicate the machine to be fenced.\n"
	- "A value of 'none' can be used to tell the cluster not to supply any additional parameters.\n"
	- " </longdesc>\n");
	- printf(" <content type=\"string\" default=\"port\"/>\n");
	- printf(" </parameter>\n");
	-
	- printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTMAP);
	- printf(" <shortdesc lang=\"en\">A mapping of host names to ports numbers for devices that do not support host names.</shortdesc>\n");
	- printf(" <longdesc lang=\"en\">Eg. node1:1;node2:2,3 would tell the cluster to use port 1 for node1 and ports 2 and 3 for node2</longdesc>\n");
	- printf(" <content type=\"string\" default=\"\"/>\n");
	- printf(" </parameter>\n");
	-
	- printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTLIST);
	- printf(" <shortdesc lang=\"en\">A list of machines controlled by this device (Optional unless %s=static-list).</shortdesc>\n", STONITH_ATTR_HOSTCHECK);
	- printf(" <content type=\"string\" default=\"\"/>\n");
	- printf(" </parameter>\n");
	-
	- printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTCHECK);
	- printf(" <shortdesc lang=\"en\">How to determin which machines are controlled by the device.</shortdesc>\n");
	- printf(" <longdesc lang=\"en\">Allowed values: dynamic-list (query the device), static-list (check the %s attribute), none (assume every device can fence every machine)</longdesc>\n", STONITH_ATTR_HOSTLIST);
	- printf(" <content type=\"string\" default=\"dynamic-list\"/>\n");
	- printf(" </parameter>\n");
	-
	- for(lpc = 0; lpc < DIMOF(actions); lpc++) {
	- printf(" <parameter name=\"pcmk_%s_action\" unique=\"0\">\n", actions[lpc]);
	- printf(" <shortdesc lang=\"en\">Advanced use only: An alternate command to run instead of '%s'</shortdesc>\n", actions[lpc]);
	- printf(" <longdesc lang=\"en\">Some devices do not support the standard commands or may provide additional ones.\n"
	- "Use this to specify an alternate, device-specific, command that implements the '%s' action.</longdesc>\n", actions[lpc]);
	- printf(" <content type=\"string\" default=\"%s\"/>\n", actions[lpc]);
	- printf(" </parameter>\n");
	- }
	-
	- printf(" </parameters>\n");
	- printf("</resource-agent>\n");
	- return 0;
	+ printf("<?xml version=\"1.0\"?><!DOCTYPE resource-agent SYSTEM \"ra-api-1.dtd\">\n");
	+ printf("<resource-agent name=\"stonithd\">\n");
	+ printf(" <version>1.0</version>\n");
	+ printf(" <longdesc lang=\"en\">This is a fake resource that details the instance attributes handled by stonithd.</longdesc>\n");
	+ printf(" <shortdesc lang=\"en\">Options available for all stonith resources</shortdesc>\n");
	+ printf(" <parameters>\n");
	+
	+ printf(" <parameter name=\"stonith-timeout\" unique=\"0\">\n");
	+ printf(" <shortdesc lang=\"en\">How long to wait for the STONITH action to complete.</shortdesc>\n");
	+ printf(" <longdesc lang=\"en\">Overrides the stonith-timeout cluster property</longdesc>\n");
	+ printf(" <content type=\"time\" default=\"60s\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ printf(" <parameter name=\"priority\" unique=\"0\">\n");
	+ printf(" <shortdesc lang=\"en\">The priority of the stonith resource. The lower the number, the higher the priority.</shortdesc>\n");
	+ printf(" <content type=\"integer\" default=\"0\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTARG);
	+ printf(" <shortdesc lang=\"en\">Advanced use only: An alternate parameter to supply instead of 'port'</shortdesc>\n");
	+ printf(" <longdesc lang=\"en\">Some devices do not support the standard 'port' parameter or may provide additional ones.\n"
	+ "Use this to specify an alternate, device-specific, parameter that should indicate the machine to be fenced.\n"
	+ "A value of 'none' can be used to tell the cluster not to supply any additional parameters.\n"
	+ " </longdesc>\n");
	+ printf(" <content type=\"string\" default=\"port\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTMAP);
	+ printf(" <shortdesc lang=\"en\">A mapping of host names to ports numbers for devices that do not support host names.</shortdesc>\n");
	+ printf(" <longdesc lang=\"en\">Eg. node1:1;node2:2,3 would tell the cluster to use port 1 for node1 and ports 2 and 3 for node2</longdesc>\n");
	+ printf(" <content type=\"string\" default=\"\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTLIST);
	+ printf(" <shortdesc lang=\"en\">A list of machines controlled by this device (Optional unless %s=static-list).</shortdesc>\n", STONITH_ATTR_HOSTCHECK);
	+ printf(" <content type=\"string\" default=\"\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ printf(" <parameter name=\"%s\" unique=\"0\">\n", STONITH_ATTR_HOSTCHECK);
	+ printf(" <shortdesc lang=\"en\">How to determin which machines are controlled by the device.</shortdesc>\n");
	+ printf(" <longdesc lang=\"en\">Allowed values: dynamic-list (query the device), static-list (check the %s attribute), none (assume every device can fence every machine)</longdesc>\n", STONITH_ATTR_HOSTLIST);
	+ printf(" <content type=\"string\" default=\"dynamic-list\"/>\n");
	+ printf(" </parameter>\n");
	+
	+ for(lpc = 0; lpc < DIMOF(actions); lpc++) {
	+ printf(" <parameter name=\"pcmk_%s_action\" unique=\"0\">\n", actions[lpc]);
	+ printf(" <shortdesc lang=\"en\">Advanced use only: An alternate command to run instead of '%s'</shortdesc>\n", actions[lpc]);
	+ printf(" <longdesc lang=\"en\">Some devices do not support the standard commands or may provide additional ones.\n"
	+ "Use this to specify an alternate, device-specific, command that implements the '%s' action.</longdesc>\n", actions[lpc]);
	+ printf(" <content type=\"string\" default=\"%s\"/>\n", actions[lpc]);
	+ printf(" </parameter>\n");
	+ }
	+
	+ printf(" </parameters>\n");
	+ printf("</resource-agent>\n");
	+ return 0;
	}

	if (optind != argc) {
	- ++argerr;
	+ ++argerr;
	}
	-
	+
	if (argerr) {
	- crm_help('?', EX_USAGE);
	+ crm_help('?', EX_USAGE);
	}

	mainloop_add_signal(SIGTERM, stonith_shutdown);

	crm_peer_init();
	client_list = g_hash_table_new(crm_str_hash, g_str_equal);
	-
	+
	if(stand_alone == FALSE) {
	- void *dispatch = NULL;
	- void *destroy = NULL;
	+ void *dispatch = NULL;
	+ void *destroy = NULL;

	#if SUPPORT_HEARTBEAT
	- dispatch = stonith_peer_hb_callback;
	- destroy = stonith_peer_hb_destroy;
	+ dispatch = stonith_peer_hb_callback;
	+ destroy = stonith_peer_hb_destroy;
	#endif

	- if(is_openais_cluster()) {
	+ if(is_openais_cluster()) {
	#if SUPPORT_COROSYNC
	- destroy = stonith_peer_ais_destroy;
	- dispatch = stonith_peer_ais_callback;
	+ destroy = stonith_peer_ais_destroy;
	+ dispatch = stonith_peer_ais_callback;
	#endif
	- }
	-
	- if(crm_cluster_connect(&stonith_our_uname, NULL, dispatch, destroy,
	+ }
	+
	+ if(crm_cluster_connect(&stonith_our_uname, NULL, dispatch, destroy,
	#if SUPPORT_HEARTBEAT
	- &hb_conn
	+ &hb_conn
	#else
	- NULL
	+ NULL
	#endif
	- ) == FALSE){
	- crm_crit("Cannot sign in to the cluster... terminating");
	- exit(100);
	- }
	+ ) == FALSE) {
	+ crm_crit("Cannot sign in to the cluster... terminating");
	+ exit(100);
	+ }

	setup_cib();

	} else {
	- stonith_our_uname = strdup("localhost");
	+ stonith_our_uname = strdup("localhost");
	}

	device_list = g_hash_table_new_full(
	crm_str_hash, g_str_equal, NULL, free_device);

	topology = g_hash_table_new_full(
	crm_str_hash, g_str_equal, NULL, free_topology_entry);

	ipcs = mainloop_add_ipc_server("stonith-ng", QB_IPC_NATIVE, &ipc_callbacks);

	#if SUPPORT_STONITH_CONFIG
	if (((stand_alone == TRUE)) && !(standalone_cfg_read_file(STONITH_NG_CONF_FILE))) {
	standalone_cfg_commit();
	}
	#endif

	if(ipcs != NULL) {
	- /* Create the mainloop and run it... */
	- mainloop = g_main_new(FALSE);
	- crm_info("Starting %s mainloop", crm_system_name);
	+ /* Create the mainloop and run it... */
	+ mainloop = g_main_new(FALSE);
	+ crm_info("Starting %s mainloop", crm_system_name);

	- g_main_run(mainloop);
	+ g_main_run(mainloop);

	} else {
	- crm_err("Couldnt start all communication channels, exiting.");
	+ crm_err("Couldnt start all communication channels, exiting.");
	}
	-
	+
	stonith_cleanup();

	#if SUPPORT_HEARTBEAT
	if(hb_conn) {
	- hb_conn->llc_ops->delete(hb_conn);
	+ hb_conn->llc_ops->delete(hb_conn);
	}
	#endif
	-
	+
	crm_info("Done");
	qb_log_fini();

	return rc;
	}

File Metadata

Mime Type: text/x-diff
Expires: Sat, Nov 23, 7:26 AM (16 h, 20 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1018421
Default Alt Text: (33 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions