No OneTemporary
Actions

Size

19 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/crm/admin/crm_verify.c b/crm/admin/crm_verify.c
	index 0c7756c64b..eb895fd248 100644
	--- a/crm/admin/crm_verify.c
	+++ b/crm/admin/crm_verify.c
	@@ -1,288 +1,295 @@
	-/* $Id: crm_verify.c,v 1.16 2006/07/04 14:11:11 lars Exp $ */
	+/* $Id: crm_verify.c,v 1.17 2006/07/12 15:42:35 andrew Exp $ */

	/*
	* Copyright (C) 2004 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.1 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	*/

	#include <portability.h>
	#include <crm/crm.h>

	#include <stdio.h>
	#include <sys/types.h>
	#include <unistd.h>

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

	#include <crm/common/xml.h>
	#include <crm/common/util.h>
	#include <crm/msg_xml.h>
	#include <clplumbing/cl_signal.h>

	#include <crm/cib.h>
	#include <clplumbing/lsb_exitcodes.h>

	#define OPTARGS "V?X:LS:"

	#ifdef HAVE_GETOPT_H
	# include <getopt.h>
	#endif
	#include <glib.h>
	#include <crm/pengine/status.h>

	gboolean USE_LIVE_CIB = FALSE;
	char *cib_save = NULL;
	const char *crm_system_name = NULL;
	void usage(const char *cmd, int exit_status);
	extern gboolean stage0(pe_working_set_t *data_set);
	void cleanup_alloc_calculations(pe_working_set_t *data_set);

	int
	main(int argc, char **argv)
	{
	crm_data_t *cib_object = NULL;
	crm_data_t *status = NULL;
	int argerr = 0;
	int flag;

	pe_working_set_t data_set;
	cib_t * cib_conn = NULL;
	enum cib_errors rc = cib_ok;

	const char *xml_file = NULL;
	crm_system_name = basename(argv[0]);

	g_log_set_handler(NULL,
	G_LOG_LEVEL_ERROR \| G_LOG_LEVEL_CRITICAL
	\| G_LOG_LEVEL_WARNING \| G_LOG_LEVEL_MESSAGE
	\| G_LOG_LEVEL_INFO \| G_LOG_LEVEL_DEBUG
	\| G_LOG_FLAG_RECURSION \| G_LOG_FLAG_FATAL,
	cl_glib_msg_handler, NULL);

	/* and for good measure... - this enum is a bit field (!) */
	g_log_set_always_fatal((GLogLevelFlags)0); /value out of range/

	cl_log_set_entity(crm_system_name);
	cl_log_set_facility(LOG_LOCAL7);
	cl_log_enable_stderr(TRUE);
	set_crm_log_level(LOG_ERR);

	CL_SIGNAL(DEBUG_INC, alter_debug);
	CL_SIGNAL(DEBUG_DEC, alter_debug);

	while (1) {
	#ifdef HAVE_GETOPT_H
	int option_index = 0;
	static struct option long_options[] = {
	/* Top-level Options */
	{"xml-file", 1, 0, 'X'},
	{"save-xml", 1, 0, 'S'},
	{"live-check", 0, 0, 'L'},
	{"help", 0, 0, '?'},

	{0, 0, 0, 0}
	};
	#endif

	#ifdef HAVE_GETOPT_H
	flag = getopt_long(argc, argv, OPTARGS,
	long_options, &option_index);
	#else
	flag = getopt(argc, argv, OPTARGS);
	#endif
	if (flag == -1)
	break;

	switch(flag) {
	#ifdef HAVE_GETOPT_H
	case 0:
	printf("option %s", long_options[option_index].name);
	if (optarg)
	printf(" with arg %s", optarg);
	printf("\n");

	break;
	#endif

	case 'X':
	xml_file = crm_strdup(optarg);
	break;
	case 'S':
	cib_save = crm_strdup(optarg);
	break;
	case 'V':
	alter_debug(DEBUG_INC);
	break;
	case 'L':
	USE_LIVE_CIB = TRUE;
	break;
	case '?':
	usage(crm_system_name, LSB_EXIT_GENERIC);
	break;
	default:
	printf("?? getopt returned character code 0%o ??\n", flag);
	++argerr;
	break;
	}
	}

	if (optind < argc) {
	printf("non-option ARGV-elements: ");
	while (optind < argc) {
	printf("%s ", argv[optind++]);
	}
	printf("\n");
	}

	if (optind > argc) {
	++argerr;
	}

	if (argerr) {
	crm_err("%d errors in option parsing", argerr);
	usage(crm_system_name, LSB_EXIT_GENERIC);
	}

	crm_info("=#=#=#=#= Getting XML =#=#=#=#=");

	+ crm_zero_mem_stats(NULL);
	+#ifdef HA_MALLOC_TRACK
	+ cl_malloc_dump_allocated(LOG_DEBUG_2, TRUE);
	+#endif
	+
	if(USE_LIVE_CIB) {
	cib_conn = cib_new();
	rc = cib_conn->cmds->signon(
	cib_conn, crm_system_name, cib_command_synchronous);
	}

	- crm_zero_mem_stats(NULL);

	if(USE_LIVE_CIB) {
	if(rc == cib_ok) {
	int options = cib_scope_local\|cib_sync_call;
	crm_info("Reading XML from: live cluster");
	rc = cib_conn->cmds->query(
	cib_conn, NULL, &cib_object, options);
	}


	if(rc != cib_ok) {
	fprintf(stderr, "Live CIB query failed: %s\n",
	cib_error2string(rc));
	return 3;
	}
	if(cib_object == NULL) {
	fprintf(stderr, "Live CIB query failed: empty result\n");
	return 3;
	}

	} else if(xml_file != NULL) {
	FILE *xml_strm = fopen(xml_file, "r");
	crm_info("Reading XML from: %s", xml_file);
	cib_object = file2xml(xml_strm);
	} else {
	fprintf(stderr, "Reading XML from: stdin\n");
	cib_object = stdin2xml();
	}

	CRM_CHECK(cib_object != NULL,
	fprintf(stderr, "No config supplied\n");
	return 3;
	);

	if(cib_save != NULL) {
	write_xml_file(cib_object, cib_save, FALSE);
	}

	status = get_object_root(XML_CIB_TAG_STATUS, cib_object);
	#if CRM_DEPRECATED_SINCE_2_0_4
	xml_child_iter_filter(status, node_state, XML_CIB_TAG_STATE,
	xml_remove_prop(node_state, XML_CIB_TAG_LRM);
	);
	#endif
	crm_notice("Required feature set: %s", feature_set(cib_object));
	if(do_id_check(cib_object, NULL, FALSE, FALSE)) {
	pe_config_err("ID Check failed");
	}

	if(validate_with_dtd(
	cib_object, FALSE, HA_LIBDIR"/heartbeat/crm.dtd") == FALSE) {
	pe_config_err("CIB did not pass DTD validation");
	}
	set_working_set_defaults(&data_set);
	data_set.input = cib_object;
	data_set.now = new_ha_date(TRUE);
	stage0(&data_set);

	cleanup_alloc_calculations(&data_set);

	#if 0
	if(USE_LIVE_CIB) {
	/* Calling msg2ipcchan() seems to initialize something
	* which isn't free'd when we disconnect and free the
	* CIB connection.
	* Fake this extra free and move along.
	*/
	volatile cl_mem_stats_t *active_stats = cl_malloc_getstats();
	active_stats->numfree++;
	}
	#endif
	-
	- CRM_CHECK(crm_mem_stats(NULL) == FALSE, ; );

	if(was_config_error) {
	fprintf(stderr, "Errors found during check: config not valid\n");
	if(crm_log_level < LOG_WARNING) {
	fprintf(stderr, " -V may provide more details\n");
	}
	- return 2;
	+ rc = 2;

	} else if(was_config_warning) {
	fprintf(stderr, "Warnings found during check: config may not be valid\n");
	if(crm_log_level < LOG_WARNING) {
	fprintf(stderr, " Use -V for more details\n");
	}
	- return 1;
	+ rc = 1;
	}

	if(USE_LIVE_CIB) {
	cib_conn->cmds->signoff(cib_conn);
	cib_delete(cib_conn);
	}

	- return 0;
	+ CRM_CHECK(crm_mem_stats(NULL) == FALSE, ; );
	+#ifdef HA_MALLOC_TRACK
	+ cl_malloc_dump_allocated(LOG_ERR, TRUE);
	+#endif
	+
	+ return rc;
	}


	void
	usage(const char *cmd, int exit_status)
	{
	FILE *stream;

	stream = exit_status ? stderr : stdout;
	fprintf(stream, "usage: %s [-V] -(?\|L\|X)\n", cmd);

	fprintf(stream, "\t--%s (-%c)\t: this help message\n", "help", '?');
	fprintf(stream, "\t--%s (-%c)\t: "
	"turn on debug info. additional instances increase verbosity\n",
	"verbose", 'V');
	fprintf(stream, "\t--%s (-%c)\t: Connect to the running cluster\n",
	"live-check", 'L');
	fprintf(stream, "\t--%s (-%c) <string>\t: Use the configuration in the named file\n",
	"xml-file", 'X');
	fflush(stream);

	exit(exit_status);
	}
	diff --git a/crm/pengine/ptest.c b/crm/pengine/ptest.c
	index f29da0adce..f7a38599c6 100644
	--- a/crm/pengine/ptest.c
	+++ b/crm/pengine/ptest.c
	@@ -1,430 +1,436 @@
	-/* $Id: ptest.c,v 1.78 2006/06/21 08:31:27 andrew Exp $ */
	+/* $Id: ptest.c,v 1.79 2006/07/12 15:42:35 andrew Exp $ */

	/*
	* Copyright (C) 2004 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.1 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	*/

	#include <portability.h>
	#include <crm/crm.h>

	#include <stdio.h>
	#include <sys/types.h>
	#include <unistd.h>

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

	#include <crm/transition.h>
	#include <crm/common/xml.h>
	#include <crm/common/util.h>
	#include <crm/msg_xml.h>

	#include <crm/cib.h>

	#define OPTARGS "V?X:D:G:I:Lwxd:"

	#ifdef HAVE_GETOPT_H
	# include <getopt.h>
	#endif
	#include <glib.h>
	#include <pengine.h>
	#include <lib/crm/pengine/utils.h>
	#include <allocate.h>

	gboolean use_stdin = FALSE;
	gboolean inhibit_exit = FALSE;
	extern crm_data_t * do_calculations(
	pe_working_set_t data_set, crm_data_t xml_input, ha_time_t *now);
	extern void cleanup_calculations(pe_working_set_t *data_set);
	char *use_date = NULL;

	FILE *dot_strm = NULL;
	#define DOT_PREFIX "PE_DOT: "
	/* #define DOT_PREFIX "" */

	#define dot_write(fmt...) if(dot_strm != NULL) { \
	fprintf(dot_strm, fmt); \
	fprintf(dot_strm, "\n"); \
	fflush(dot_strm); \
	} else { \
	crm_debug(DOT_PREFIX""fmt); \
	}

	static void
	init_dotfile(void)
	{
	dot_write("digraph \"g\" {");
	dot_write(" size = \"30,30\"");
	/* dot_write(" graph ["); */
	/* dot_write(" fontsize = \"12\""); */
	/* dot_write(" fontname = \"Times-Roman\""); */
	/* dot_write(" fontcolor = \"black\""); */
	/* dot_write(" bb = \"0,0,398.922306,478.927856\""); */
	/* dot_write(" color = \"black\""); */
	/* dot_write(" ]"); */
	/* dot_write(" node ["); */
	/* dot_write(" fontsize = \"12\""); */
	/* dot_write(" fontname = \"Times-Roman\""); */
	/* dot_write(" fontcolor = \"black\""); */
	/* dot_write(" shape = \"ellipse\""); */
	/* dot_write(" color = \"black\""); */
	/* dot_write(" ]"); */
	/* dot_write(" edge ["); */
	/* dot_write(" fontsize = \"12\""); */
	/* dot_write(" fontname = \"Times-Roman\""); */
	/* dot_write(" fontcolor = \"black\""); */
	/* dot_write(" color = \"black\""); */
	/* dot_write(" ]"); */
	}

	static void
	usage(const char *cli, int exitcode)
	{
	FILE *out = exitcode?stderr:stdout;
	fprintf(out, "Usage: %s -(?\|L\|X\|x) [-V] [-D] [-G] [-I]\n", cli);
	fprintf(out, " --%s (-%c): This text\n\n", "help", '?');
	fprintf(out, " --%s (-%c): Increase verbosity (can be supplied multiple times)\n\n", "verbose", 'V');
	fprintf(out, " --%s (-%c): Connect to the CIB and use the current contents as input\n", "live-check", 'L');
	fprintf(out, " --%s (-%c): Look for xml on stdin\n", "xml-stream", 'x');
	fprintf(out, " --%s (-%c)\t<filename> : Look for xml in the named file\n\n", "xml-file", 'X');

	fprintf(out, " --%s (-%c)\t<filename> : Save the transition graph to the named file\n", "save-graph", 'G');
	fprintf(out, " --%s (-%c)\t<filename> : Save the DOT formatted transition graph to the named file\n", "save-dotfile", 'D');
	fprintf(out, " --%s (-%c)\t<filename> : Save the input to the named file\n", "save-input", 'I');
	exit(exitcode);
	}

	static char *
	create_action_name(action_t *action)
	{
	char *action_name = NULL;
	const char *action_host = NULL;
	if(action->node) {
	action_host = action->node->details->uname;
	action_name = crm_concat(action->uuid, action_host, ' ');

	} else if(action->pseudo) {
	action_name = crm_strdup(action->uuid);

	} else {
	action_host = "<none>";
	action_name = crm_concat(action->uuid, action_host, ' ');
	}
	return action_name;
	}

	gboolean USE_LIVE_CIB = FALSE;

	int
	main(int argc, char **argv)
	{
	gboolean all_good = TRUE;
	enum transition_status graph_rc = -1;
	crm_graph_t *transition = NULL;
	ha_time_t *a_date = NULL;
	cib_t * cib_conn = NULL;

	crm_data_t * cib_object = NULL;
	int argerr = 0;
	int flag;

	char *msg_buffer = NULL;
	gboolean optional = FALSE;
	pe_working_set_t data_set;

	const char *xml_file = NULL;
	const char *dot_file = NULL;
	const char *graph_file = NULL;
	const char *input_file = NULL;

	cl_log_set_entity("ptest");
	cl_log_set_facility(LOG_USER);
	set_crm_log_level(LOG_CRIT-1);

	while (1) {
	#ifdef HAVE_GETOPT_H
	int option_index = 0;
	static struct option long_options[] = {
	/* Top-level Options */
	{"help", 0, 0, '?'},
	{"verbose", 0, 0, 'V'},

	{"live-check", 0, 0, 'L'},
	{"xml-stream", 0, 0, 'x'},
	{"xml-file", 1, 0, 'X'},

	{"save-graph", 1, 0, 'G'},
	{"save-dotfile",1, 0, 'D'},
	{"save-input", 1, 0, 'I'},

	{0, 0, 0, 0}
	};
	#endif

	#ifdef HAVE_GETOPT_H
	flag = getopt_long(argc, argv, OPTARGS,
	long_options, &option_index);
	#else
	flag = getopt(argc, argv, OPTARGS);
	#endif
	if (flag == -1)
	break;

	switch(flag) {
	#ifdef HAVE_GETOPT_H
	case 0:
	printf("option %s", long_options[option_index].name);
	if (optarg)
	printf(" with arg %s", optarg);
	printf("\n");

	break;
	#endif

	case 'w':
	inhibit_exit = TRUE;
	break;
	case 'x':
	use_stdin = TRUE;
	break;
	case 'X':
	xml_file = crm_strdup(optarg);
	break;
	case 'd':
	use_date = crm_strdup(optarg);
	break;
	case 'D':
	dot_file = crm_strdup(optarg);
	break;
	case 'G':
	graph_file = crm_strdup(optarg);
	break;
	case 'I':
	input_file = crm_strdup(optarg);
	break;
	case 'V':
	cl_log_enable_stderr(TRUE);
	alter_debug(DEBUG_INC);
	break;
	case 'L':
	USE_LIVE_CIB = TRUE;
	break;
	case '?':
	usage("ptest", 0);
	break;
	default:
	printf("?? getopt returned character code 0%o ??\n", flag);
	++argerr;
	break;
	}
	}

	if (optind < argc) {
	printf("non-option ARGV-elements: ");
	while (optind < argc) {
	printf("%s ", argv[optind++]);
	}
	printf("\n");
	}

	if (optind > argc) {
	++argerr;
	}

	if (argerr) {
	crm_err("%d errors in option parsing", argerr);
	usage("ptest", 1);
	}

	crm_info("=#=#=#=#= Getting XML =#=#=#=#=");

	if(USE_LIVE_CIB) {
	int rc = cib_ok;
	cib_conn = cib_new();
	rc = cib_conn->cmds->signon(
	cib_conn, "ptest", cib_command_synchronous);

	if(rc == cib_ok) {
	crm_info("Reading XML from: live cluster");
	cib_object = get_cib_copy(cib_conn);

	} else {
	fprintf(stderr, "Live CIB query failed: %s\n",
	cib_error2string(rc));
	return 3;
	}
	if(cib_object == NULL) {
	fprintf(stderr, "Live CIB query failed: empty result\n");
	return 3;
	}

	} else if(xml_file != NULL) {
	FILE *xml_strm = fopen(xml_file, "r");
	cib_object = file2xml(xml_strm);

	} else if(use_stdin) {
	cib_object = stdin2xml();

	} else {
	usage("ptest", 1);
	}

	#ifdef MCHECK
	mtrace();
	#endif
	CRM_CHECK(cib_object != NULL, return 4);

	crm_notice("Required feature set: %s", feature_set(cib_object));
	do_id_check(cib_object, NULL, FALSE, FALSE);
	if(!validate_with_dtd(cib_object,FALSE,HA_LIBDIR"/heartbeat/crm.dtd")) {
	crm_crit("%s is not a valid configuration", xml_file?xml_file:"stding");
	all_good = FALSE;
	}

	if(input_file != NULL) {
	FILE *input_strm = fopen(input_file, "w");
	msg_buffer = dump_xml_formatted(cib_object);
	fprintf(input_strm, "%s\n", msg_buffer);
	fflush(input_strm);
	fclose(input_strm);
	crm_free(msg_buffer);
	}

	crm_zero_mem_stats(NULL);
	+#ifdef HA_MALLOC_TRACK
	+ cl_malloc_dump_allocated(LOG_DEBUG_2, TRUE);
	+#endif

	if(use_date != NULL) {
	a_date = parse_date(&use_date);
	log_date(LOG_WARNING, "Set fake 'now' to",
	a_date, ha_log_date\|ha_log_time);
	log_date(LOG_WARNING, "Set fake 'now' to (localtime)",
	a_date, ha_log_date\|ha_log_time\|ha_log_local);
	}

	do_calculations(&data_set, cib_object, a_date);

	msg_buffer = dump_xml_formatted(data_set.graph);
	if(graph_file != NULL) {
	FILE *graph_strm = fopen(graph_file, "w");
	fprintf(graph_strm, "%s\n", msg_buffer);
	fflush(graph_strm);
	fclose(graph_strm);

	} else {
	fprintf(stdout, "%s\n", msg_buffer);
	fflush(stdout);
	}
	crm_free(msg_buffer);

	dot_strm = fopen(dot_file, "w");
	init_dotfile();
	slist_iter(
	action, action_t, data_set.actions, lpc,

	char *action_name = create_action_name(action);
	crm_debug_3("Action %d: %p", action->id, action);

	if(action->dumped == FALSE) {
	if(action->rsc != NULL && action->rsc->is_managed == FALSE) {
	dot_write("\"%s\" [ font_color=black style=filled fillcolor=%s ]",
	action_name, "purple");

	} else if(action->optional) {
	dot_write("\"%s\" [ style=\"dashed\" color=\"%s\" fontcolor=\"%s\" ]",
	action_name, "blue",
	action->pseudo?"orange":"black");

	} else {
	dot_write("\"%s\" [ font_color=purple style=filled fillcolor=%s ]",
	action_name, "red");
	CRM_CHECK(action->runnable == FALSE, ;);
	}

	} else {
	dot_write("\"%s\" [ style=bold color=\"%s\" fontcolor=\"%s\" ]",
	action_name, "green",
	action->pseudo?"orange":"black");
	}
	crm_free(action_name);
	);


	slist_iter(
	action, action_t, data_set.actions, lpc,
	int last_action = -1;
	slist_iter(
	before, action_wrapper_t, action->actions_before, lpc2,
	char *before_name = NULL;
	char *after_name = NULL;
	optional = FALSE;
	if(last_action == before->action->id) {
	continue;
	}
	last_action = before->action->id;
	if(action->dumped && before->action->dumped) {
	} else if(action->optional \|\| before->action->optional) {
	optional = TRUE;
	}
	before_name = create_action_name(before->action);
	after_name = create_action_name(action);
	dot_write("\"%s\" -> \"%s\" [ style = %s]",
	before_name, after_name,
	optional?"dashed":"bold");
	crm_free(before_name);
	crm_free(after_name);
	);
	);
	dot_write("}");

	transition = unpack_graph(data_set.graph);
	print_graph(LOG_NOTICE, transition);
	do {
	graph_rc = run_graph(transition);

	} while(graph_rc == transition_active);

	if(graph_rc != transition_complete) {
	crm_crit("Transition failed: %s", transition_status(graph_rc));
	print_graph(LOG_ERR, transition);
	}

	data_set.input = NULL;
	cleanup_alloc_calculations(&data_set);
	destroy_graph(transition);

	crm_mem_stats(NULL);
	+#ifdef HA_MALLOC_TRACK
	+ cl_malloc_dump_allocated(LOG_ERR, TRUE);
	+#endif
	CRM_CHECK(crm_mem_stats(NULL) == FALSE, all_good = FALSE; crm_err("Memory leak detected"));
	CRM_CHECK(graph_rc == transition_complete, all_good = FALSE; crm_err("An invalid transition was produced"));

	crm_free(cib_object);

	#ifdef MCHECK
	muntrace();
	#endif


	/* required for MallocDebug.app */
	if(inhibit_exit) {
	GMainLoop* mainloop = g_main_new(FALSE);
	g_main_run(mainloop);
	}

	if(all_good) {
	return 0;
	}
	return 5;
	}

File Metadata

Mime Type: text/x-diff
Expires: Tue, Jul 8, 6:19 PM (12 h, 18 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 2002584
Default Alt Text: (19 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions