No OneTemporary
Actions

Size

64 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/common/utils.c b/lib/common/utils.c
	index 04abc29440..479ee10c78 100644
	--- a/lib/common/utils.c
	+++ b/lib/common/utils.c
	@@ -1,1990 +1,1992 @@
	/*
	* 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 <crm_internal.h>

	#ifndef _GNU_SOURCE
	# define _GNU_SOURCE
	#endif

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

	#include <stdlib.h>
	#include <limits.h>
	#include <ctype.h>
	#include <pwd.h>
	#include <grp.h>
	#include <time.h>

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

	#include <heartbeat/hb_config.h> /* for HB_COREDIR */

	#ifndef MAXLINE
	# define MAXLINE 512
	#endif

	#ifdef HAVE_GETOPT_H
	# include <getopt.h>
	#endif

	static uint ref_counter = 0;
	unsigned int crm_log_level = LOG_INFO;
	gboolean crm_config_error = FALSE;
	gboolean crm_config_warning = FALSE;
	const char *crm_system_name = "unknown";

	void crm_set_env_options(void);

	gboolean
	check_time(const char *value)
	{
	if(crm_get_msec(value) < 5000) {
	return FALSE;
	}
	return TRUE;
	}

	gboolean
	check_timer(const char *value)
	{
	if(crm_get_msec(value) < 0) {
	return FALSE;
	}
	return TRUE;
	}

	gboolean
	check_boolean(const char *value)
	{
	int tmp = FALSE;
	if(crm_str_to_boolean(value, &tmp) != 1) {
	return FALSE;
	}
	return TRUE;
	}

	gboolean
	check_number(const char *value)
	{
	errno = 0;
	if(value == NULL) {
	return FALSE;

	} else if(safe_str_eq(value, MINUS_INFINITY_S)) {

	} else if(safe_str_eq(value, INFINITY_S)) {

	} else {
	crm_int_helper(value, NULL);
	}

	if(errno != 0) {
	return FALSE;
	}
	return TRUE;
	}

	int
	char2score(const char *score)
	{
	int score_f = 0;

	if(score == NULL) {

	} else if(safe_str_eq(score, MINUS_INFINITY_S)) {
	score_f = -INFINITY;

	} else if(safe_str_eq(score, INFINITY_S)) {
	score_f = INFINITY;

	} else if(safe_str_eq(score, "+"INFINITY_S)) {
	score_f = INFINITY;

	} else {
	score_f = crm_parse_int(score, NULL);
	if(score_f > 0 && score_f > INFINITY) {
	score_f = INFINITY;

	} else if(score_f < 0 && score_f < -INFINITY) {
	score_f = -INFINITY;
	}
	}

	return score_f;
	}


	char *
	score2char(int score)
	{

	if(score >= INFINITY) {
	return crm_strdup("+"INFINITY_S);

	} else if(score <= -INFINITY) {
	return crm_strdup("-"INFINITY_S);
	}
	return crm_itoa(score);
	}


	const char *
	cluster_option(GHashTable* options, gboolean(validate)(const char),
	const char name, const char old_name, const char *def_value)
	{
	const char *value = NULL;
	CRM_ASSERT(name != NULL);

	if(options != NULL) {
	value = g_hash_table_lookup(options, name);
	}

	if(value == NULL && old_name && options != NULL) {
	value = g_hash_table_lookup(options, old_name);
	if(value != NULL) {
	crm_config_warn("Using deprecated name '%s' for"
	" cluster option '%s'", old_name, name);
	g_hash_table_insert(
	options, crm_strdup(name), crm_strdup(value));
	value = g_hash_table_lookup(options, old_name);
	}
	}

	if(value == NULL) {
	crm_debug("Using default value '%s' for cluster option '%s'",
	def_value, name);

	if(options == NULL) {
	return def_value;
	}

	g_hash_table_insert(
	options, crm_strdup(name), crm_strdup(def_value));
	value = g_hash_table_lookup(options, name);
	}

	if(validate && validate(value) == FALSE) {
	crm_config_err("Value '%s' for cluster option '%s' is invalid."
	" Defaulting to %s", value, name, def_value);
	g_hash_table_replace(options, crm_strdup(name),
	crm_strdup(def_value));
	value = g_hash_table_lookup(options, name);
	}

	return value;
	}


	const char *
	get_cluster_pref(GHashTable options, pe_cluster_option option_list, int len, const char *name)
	{
	int lpc = 0;
	const char *value = NULL;
	gboolean found = FALSE;
	for(lpc = 0; lpc < len; lpc++) {
	if(safe_str_eq(name, option_list[lpc].name)) {
	found = TRUE;
	value = cluster_option(options,
	option_list[lpc].is_valid,
	option_list[lpc].name,
	option_list[lpc].alt_name,
	option_list[lpc].default_value);
	}
	}
	CRM_CHECK(found, crm_err("No option named: %s", name));
	CRM_ASSERT(value != NULL);
	return value;
	}

	void
	config_metadata(const char name, const char version, const char desc_short, const char desc_long,
	pe_cluster_option *option_list, int len)
	{
	int lpc = 0;

	fprintf(stdout, "<?xml version=\"1.0\"?>"
	"<!DOCTYPE resource-agent SYSTEM \"ra-api-1.dtd\">\n"
	"<resource-agent name=\"%s\">\n"
	" <version>%s</version>\n"
	" <longdesc lang=\"en\">%s</longdesc>\n"
	" <shortdesc lang=\"en\">%s</shortdesc>\n"
	" <parameters>\n", name, version, desc_long, desc_short);

	for(lpc = 0; lpc < len; lpc++) {
	if(option_list[lpc].description_long == NULL
	&& option_list[lpc].description_short == NULL) {
	continue;
	}
	fprintf(stdout, " <parameter name=\"%s\" unique=\"0\">\n"
	" <shortdesc lang=\"en\">%s</shortdesc>\n"
	" <content type=\"%s\" default=\"%s\"/>\n"
	" <longdesc lang=\"en\">%s%s%s</longdesc>\n"
	" </parameter>\n",
	option_list[lpc].name,
	option_list[lpc].description_short,
	option_list[lpc].type,
	option_list[lpc].default_value,
	option_list[lpc].description_long?option_list[lpc].description_long:option_list[lpc].description_short,
	option_list[lpc].values?" Allowed values: ":"",
	option_list[lpc].values?option_list[lpc].values:"");
	}
	fprintf(stdout, " </parameters>\n</resource-agent>\n");
	}

	void
	verify_all_options(GHashTable options, pe_cluster_option option_list, int len)
	{
	int lpc = 0;
	for(lpc = 0; lpc < len; lpc++) {
	cluster_option(options,
	option_list[lpc].is_valid,
	option_list[lpc].name,
	option_list[lpc].alt_name,
	option_list[lpc].default_value);
	}
	}

	char *
	generateReference(const char custom1, const char custom2)
	{

	const char *local_cust1 = custom1;
	const char *local_cust2 = custom2;
	int reference_len = 4;
	char *since_epoch = NULL;

	reference_len += 20; /* too big */
	reference_len += 40; /* too big */

	if(local_cust1 == NULL) { local_cust1 = "_empty_"; }
	reference_len += strlen(local_cust1);

	if(local_cust2 == NULL) { local_cust2 = "_empty_"; }
	reference_len += strlen(local_cust2);

	crm_malloc0(since_epoch, reference_len);

	if(since_epoch != NULL) {
	sprintf(since_epoch, "%s-%s-%ld-%u",
	local_cust1, local_cust2,
	(unsigned long)time(NULL), ref_counter++);
	}

	return since_epoch;
	}

	gboolean
	decodeNVpair(const char srcstring, char separator, char name, char *value)
	{
	int lpc = 0;
	int len = 0;
	const char *temp = NULL;

	CRM_ASSERT(name != NULL && value != NULL);
	*name = NULL;
	*value = NULL;

	crm_debug_4("Attempting to decode: [%s]", srcstring);
	if (srcstring != NULL) {
	len = strlen(srcstring);
	while(lpc <= len) {
	if (srcstring[lpc] == separator) {
	crm_malloc0(*name, lpc+1);
	if(*name == NULL) {
	break; /* and return FALSE */
	}
	strncpy(*name, srcstring, lpc);
	(*name)[lpc] = '\0';

	/* this sucks but as the strtok manpage says..
	* it is a bug
	*/
	len = len-lpc; len--;
	if(len <= 0) {
	*value = NULL;
	} else {

	crm_malloc0(*value, len+1);
	if(*value == NULL) {
	crm_free(*name);
	break; /* and return FALSE */
	}
	temp = srcstring+lpc+1;
	strncpy(*value, temp, len);
	(*value)[len] = '\0';
	}
	return TRUE;
	}
	lpc++;
	}
	}

	if(*name != NULL) {
	crm_free(*name);
	}
	*name = NULL;
	*value = NULL;

	return FALSE;
	}

	char *
	crm_concat(const char prefix, const char suffix, char join)
	{
	int len = 0;
	char *new_str = NULL;
	CRM_ASSERT(prefix != NULL);
	CRM_ASSERT(suffix != NULL);
	len = strlen(prefix) + strlen(suffix) + 2;

	crm_malloc0(new_str, (len));
	sprintf(new_str, "%s%c%s", prefix, join, suffix);
	new_str[len-1] = 0;
	return new_str;
	}


	char *
	generate_hash_key(const char crm_msg_reference, const char sys)
	{
	char *hash_key = crm_concat(sys?sys:"none", crm_msg_reference, '_');
	crm_debug_3("created hash key: (%s)", hash_key);
	return hash_key;
	}

	char *
	generate_hash_value(const char src_node, const char src_subsys)
	{
	char *hash_value = NULL;

	if (src_node == NULL \|\| src_subsys == NULL) {
	return NULL;
	}

	if (strcasecmp(CRM_SYSTEM_DC, src_subsys) == 0) {
	hash_value = crm_strdup(src_subsys);
	if (!hash_value) {
	crm_err("memory allocation failed in "
	"generate_hash_value()");
	}
	return hash_value;
	}

	hash_value = crm_concat(src_node, src_subsys, '_');
	crm_info("created hash value: (%s)", hash_value);
	return hash_value;
	}

	char *
	crm_itoa(int an_int)
	{
	int len = 32;
	char *buffer = NULL;

	crm_malloc0(buffer, (len+1));
	if(buffer != NULL) {
	snprintf(buffer, len, "%d", an_int);
	}

	return buffer;
	}

	extern int LogToLoggingDaemon(int priority, const char * buf, int bstrlen, gboolean use_pri_str);

	#ifdef HAVE_G_LOG_SET_DEFAULT_HANDLER
	GLogFunc glib_log_default;

	static void
	crm_glib_handler(const gchar log_domain, GLogLevelFlags flags, const gchar message, gpointer user_data)
	{
	int log_level = LOG_WARNING;
	GLogLevelFlags msg_level = (flags & G_LOG_LEVEL_MASK);

	switch(msg_level) {
	case G_LOG_LEVEL_CRITICAL:
	/* log and record how we got here */
	crm_abort(__FILE__,__PRETTY_FUNCTION__,__LINE__, message, TRUE, TRUE);
	return;

	case G_LOG_LEVEL_ERROR: log_level = LOG_ERR; break;
	case G_LOG_LEVEL_MESSAGE: log_level = LOG_NOTICE; break;
	case G_LOG_LEVEL_INFO: log_level = LOG_INFO; break;
	case G_LOG_LEVEL_DEBUG: log_level = LOG_DEBUG; break;

	case G_LOG_LEVEL_WARNING:
	case G_LOG_FLAG_RECURSION:
	case G_LOG_FLAG_FATAL:
	case G_LOG_LEVEL_MASK:
	log_level = LOG_WARNING;
	break;
	}

	do_crm_log(log_level, "%s: %s", log_domain, message);
	}
	#endif

	void crm_log_deinit(void) {
	#ifdef HAVE_G_LOG_SET_DEFAULT_HANDLER
	g_log_set_default_handler(glib_log_default, NULL);
	#endif
	}

	gboolean
	crm_log_init(
	const char *entity, int level, gboolean coredir, gboolean to_stderr,
	int argc, char **argv)
	{
	/* Redirect messages from glib functions to our handler */
	/* cl_malloc_forced_for_glib(); */
	#ifdef HAVE_G_LOG_SET_DEFAULT_HANDLER
	glib_log_default = g_log_set_default_handler(crm_glib_handler, NULL);
	#endif

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

	crm_system_name = entity;
	setenv("PCMK_service", crm_system_name, 1);
	cl_log_set_entity(entity);
	cl_log_set_facility(HA_LOG_FACILITY);

	if(coredir) {
	int user = getuid();
	struct passwd *pwent = NULL;
	const char *base = HA_COREDIR;

	pwent = getpwuid(user);

	if (chdir(base) < 0) {
	crm_perror(LOG_ERR, "Cannot change active directory to %s", base);

	} else if (pwent == NULL) {
	crm_perror(LOG_ERR, "Cannot get name for uid: %d", user);

	} else if (chdir(pwent->pw_name) < 0) {
	crm_perror(LOG_ERR, "Cannot change active directory to %s/%s", base, pwent->pw_name);

	} else {
	crm_info("Changed active directory to %s/%s", base, pwent->pw_name);
	}
	}

	set_crm_log_level(level);
	crm_set_env_options();

	cl_log_args(argc, argv);
	cl_log_enable_stderr(to_stderr);

	crm_signal(DEBUG_INC, alter_debug);
	crm_signal(DEBUG_DEC, alter_debug);

	return TRUE;
	}

	/* returns the old value */
	unsigned int
	set_crm_log_level(unsigned int level)
	{
	unsigned int old = crm_log_level;

	while(crm_log_level < 100 && crm_log_level < level) {
	alter_debug(DEBUG_INC);
	}
	while(crm_log_level > 0 && crm_log_level > level) {
	alter_debug(DEBUG_DEC);
	}

	return old;
	}

	unsigned int
	get_crm_log_level(void)
	{
	return crm_log_level;
	}

	static int
	crm_version_helper(const char text, char *end_text)
	{
	int atoi_result = -1;
	CRM_ASSERT(end_text != NULL);

	errno = 0;

	if(text != NULL && text[0] != 0) {
	atoi_result = (int)strtol(text, end_text, 10);

	if(errno == EINVAL) {
	crm_err("Conversion of '%s' %c failed", text, text[0]);
	atoi_result = -1;
	}
	}
	return atoi_result;
	}


	/*
	* version1 < version2 : -1
	* version1 = version2 : 0
	* version1 > version2 : 1
	*/
	int
	compare_version(const char version1, const char version2)
	{
	int rc = 0;
	int lpc = 0;
	char ver1_copy = NULL, ver2_copy = NULL;
	char rest1 = NULL, rest2 = NULL;

	if(version1 == NULL && version2 == NULL) {
	return 0;
	} else if(version1 == NULL) {
	return -1;
	} else if(version2 == NULL) {
	return 1;
	}

	ver1_copy = crm_strdup(version1);
	ver2_copy = crm_strdup(version2);
	rest1 = ver1_copy;
	rest2 = ver2_copy;

	while(1) {
	int digit1 = 0;
	int digit2 = 0;

	lpc++;

	if(rest1 == rest2) {
	break;
	}

	if(rest1 != NULL) {
	digit1 = crm_version_helper(rest1, &rest1);
	}

	if(rest2 != NULL) {
	digit2 = crm_version_helper(rest2, &rest2);
	}

	if(digit1 < digit2){
	rc = -1;
	crm_debug_5("%d < %d", digit1, digit2);
	break;

	} else if (digit1 > digit2){
	rc = 1;
	crm_debug_5("%d > %d", digit1, digit2);
	break;
	}

	if(rest1 != NULL && rest1[0] == '.') {
	rest1++;
	}
	if(rest1 != NULL && rest1[0] == 0) {
	rest1 = NULL;
	}

	if(rest2 != NULL && rest2[0] == '.') {
	rest2++;
	}
	if(rest2 != NULL && rest2[0] == 0) {
	rest2 = NULL;
	}
	}

	crm_free(ver1_copy);
	crm_free(ver2_copy);

	if(rc == 0) {
	crm_debug_3("%s == %s (%d)", version1, version2, lpc);
	} else if(rc < 0) {
	crm_debug_3("%s < %s (%d)", version1, version2, lpc);
	} else if(rc > 0) {
	crm_debug_3("%s > %s (%d)", version1, version2, lpc);
	}

	return rc;
	}

	gboolean do_stderr = FALSE;

	void
	alter_debug(int nsig)
	{
	crm_signal(DEBUG_INC, alter_debug);
	crm_signal(DEBUG_DEC, alter_debug);

	switch(nsig) {
	case DEBUG_INC:
	if (crm_log_level < 100) {
	crm_log_level++;
	}
	break;

	case DEBUG_DEC:
	if (crm_log_level > 0) {
	crm_log_level--;
	}
	break;

	default:
	fprintf(stderr, "Unknown signal %d\n", nsig);
	cl_log(LOG_ERR, "Unknown signal %d", nsig);
	break;
	}
	}


	void g_hash_destroy_str(gpointer data)
	{
	crm_free(data);
	}

	#include <sys/types.h>
	/* #include <stdlib.h> */
	/* #include <limits.h> */

	long long
	crm_int_helper(const char text, char *end_text)
	{
	long long result = -1;
	char *local_end_text = NULL;

	errno = 0;

	if(text != NULL) {
	#ifdef ANSI_ONLY
	if(end_text != NULL) {
	result = strtol(text, end_text, 10);
	} else {
	result = strtol(text, &local_end_text, 10);
	}
	#else
	if(end_text != NULL) {
	result = strtoll(text, end_text, 10);
	} else {
	result = strtoll(text, &local_end_text, 10);
	}
	#endif
	/* CRM_CHECK(errno != EINVAL); */
	if(errno == EINVAL) {
	crm_err("Conversion of %s failed", text);
	result = -1;

	} else if(errno == ERANGE) {
	crm_err("Conversion of %s was clipped: %lld", text, result);

	} else if(errno != 0) {
	crm_perror(LOG_ERR,"Conversion of %s failed:", text);
	}

	if(local_end_text != NULL && local_end_text[0] != '\0') {
	crm_err("Characters left over after parsing '%s': '%s'", text, local_end_text);
	}
	}
	return result;
	}

	int
	crm_parse_int(const char text, const char default_text)
	{
	int atoi_result = -1;
	if(text != NULL) {
	atoi_result = crm_int_helper(text, NULL);
	if(errno == 0) {
	return atoi_result;
	}
	}

	if(default_text != NULL) {
	atoi_result = crm_int_helper(default_text, NULL);
	if(errno == 0) {
	return atoi_result;
	}

	} else {
	crm_err("No default conversion value supplied");
	}

	return -1;
	}

	gboolean
	safe_str_neq(const char a, const char b)
	{
	if(a == b) {
	return FALSE;

	} else if(a==NULL \|\| b==NULL) {
	return TRUE;

	} else if(strcasecmp(a, b) == 0) {
	return FALSE;
	}
	return TRUE;
	}

	char *
	crm_strdup_fn(const char src, const char file, const char *fn, int line)
	{
	char *dup = NULL;
	CRM_CHECK(src != NULL, return NULL);
	crm_malloc0(dup, strlen(src) + 1);
	return strcpy(dup, src);
	}



	#define ENV_PREFIX "HA_"
	void
	crm_set_env_options(void)
	{
	cl_inherit_logging_environment(500);
	cl_log_set_logd_channel_source(NULL, NULL);

	if(debug_level > 0 && (debug_level+LOG_INFO) > (int)crm_log_level) {
	set_crm_log_level(LOG_INFO + debug_level);
	}
	}

	gboolean
	crm_is_true(const char * s)
	{
	gboolean ret = FALSE;
	if(s != NULL) {
	crm_str_to_boolean(s, &ret);
	}
	return ret;
	}

	int
	crm_str_to_boolean(const char * s, int * ret)
	{
	if(s == NULL) {
	return -1;

	} else if (strcasecmp(s, "true") == 0
	\|\| strcasecmp(s, "on") == 0
	\|\| strcasecmp(s, "yes") == 0
	\|\| strcasecmp(s, "y") == 0
	\|\| strcasecmp(s, "1") == 0){
	*ret = TRUE;
	return 1;

	} else if (strcasecmp(s, "false") == 0
	\|\| strcasecmp(s, "off") == 0
	\|\| strcasecmp(s, "no") == 0
	\|\| strcasecmp(s, "n") == 0
	\|\| strcasecmp(s, "0") == 0){
	*ret = FALSE;
	return 1;
	}
	return -1;
	}

	#ifndef NUMCHARS
	# define NUMCHARS "0123456789."
	#endif

	#ifndef WHITESPACE
	# define WHITESPACE " \t\n\r\f"
	#endif

	unsigned long long
	crm_get_interval(const char * input)
	{
	ha_time_t *interval = NULL;
	char *input_copy = crm_strdup(input);
	char *input_copy_mutable = input_copy;
	unsigned long long msec = 0;

	if(input == NULL) {
	return 0;

	} else if(input[0] != 'P') {
	crm_free(input_copy);
	return crm_get_msec(input);
	}

	interval = parse_time_duration(&input_copy_mutable);
	msec = date_in_seconds(interval);
	free_ha_date(interval);
	crm_free(input_copy);
	return msec * 1000;
	}

	long long
	crm_get_msec(const char * input)
	{
	const char *cp = input;
	const char *units;
	long long multiplier = 1000;
	long long divisor = 1;
	long long msec = -1;
	char *end_text = NULL;
	/* double dret; */

	if(input == NULL) {
	return msec;
	}

	cp += strspn(cp, WHITESPACE);
	units = cp + strspn(cp, NUMCHARS);
	units += strspn(units, WHITESPACE);

	if (strchr(NUMCHARS, *cp) == NULL) {
	return msec;
	}

	if (strncasecmp(units, "ms", 2) == 0
	\|\| strncasecmp(units, "msec", 4) == 0) {
	multiplier = 1;
	divisor = 1;
	} else if (strncasecmp(units, "us", 2) == 0
	\|\| strncasecmp(units, "usec", 4) == 0) {
	multiplier = 1;
	divisor = 1000;
	} else if (strncasecmp(units, "s", 1) == 0
	\|\| strncasecmp(units, "sec", 3) == 0) {
	multiplier = 1000;
	divisor = 1;
	} else if (strncasecmp(units, "m", 1) == 0
	\|\| strncasecmp(units, "min", 3) == 0) {
	multiplier = 60*1000;
	divisor = 1;
	} else if (strncasecmp(units, "h", 1) == 0
	\|\| strncasecmp(units, "hr", 2) == 0) {
	multiplier = 60601000;
	divisor = 1;
	} else if (units != EOS && units != '\n' && *units != '\r') {
	return msec;
	}

	msec = crm_int_helper(cp, &end_text);
	msec *= multiplier;
	msec /= divisor;
	/* dret += 0.5; */
	/* msec = (long long)dret; */
	return msec;
	}

	const char *
	op_status2text(op_status_t status)
	{
	switch(status) {
	case LRM_OP_PENDING:
	return "pending";
	break;
	case LRM_OP_DONE:
	return "complete";
	break;
	case LRM_OP_ERROR:
	return "Error";
	break;
	case LRM_OP_TIMEOUT:
	return "Timed Out";
	break;
	case LRM_OP_NOTSUPPORTED:
	return "NOT SUPPORTED";
	break;
	case LRM_OP_CANCELLED:
	return "Cancelled";
	break;
	}
	crm_err("Unknown status: %d", status);
	return "UNKNOWN!";
	}

	char *
	generate_op_key(const char rsc_id, const char op_type, int interval)
	{
	int len = 35;
	char *op_id = NULL;

	CRM_CHECK(rsc_id != NULL, return NULL);
	CRM_CHECK(op_type != NULL, return NULL);

	len += strlen(op_type);
	len += strlen(rsc_id);
	crm_malloc0(op_id, len);
	CRM_CHECK(op_id != NULL, return NULL);
	sprintf(op_id, "%s_%s_%d", rsc_id, op_type, interval);
	return op_id;
	}

	gboolean
	parse_op_key(const char key, char rsc_id, char op_type, int interval)
	{
	char *mutable_key = NULL;
	char *mutable_key_ptr = NULL;
	int len = 0, offset = 0, ch = 0;

	CRM_CHECK(key != NULL, return FALSE);

	*interval = 0;
	len = strlen(key);
	offset = len-1;

	crm_debug_3("Source: %s", key);

	while(offset > 0 && isdigit(key[offset])) {
	int digits = len-offset;
	ch = key[offset] - '0';
	CRM_CHECK(ch < 10, return FALSE);
	CRM_CHECK(ch >= 0, return FALSE);
	while(digits > 1) {
	digits--;
	ch = ch * 10;
	}
	*interval += ch;
	offset--;
	}

	crm_debug_3(" Interval: %d", *interval);
	CRM_CHECK(key[offset] == '_', return FALSE);

	mutable_key = crm_strdup(key);
	mutable_key_ptr = mutable_key_ptr;
	mutable_key[offset] = 0;
	offset--;

	while(offset > 0 && key[offset] != '_') {
	offset--;
	}

	CRM_CHECK(key[offset] == '_',
	crm_free(mutable_key); return FALSE);

	mutable_key_ptr = mutable_key+offset+1;

	crm_debug_3(" Action: %s", mutable_key_ptr);

	*op_type = crm_strdup(mutable_key_ptr);

	mutable_key[offset] = 0;
	offset--;

	CRM_CHECK(mutable_key != mutable_key_ptr,
	crm_free(mutable_key); return FALSE);

	crm_debug_3(" Resource: %s", mutable_key);
	*rsc_id = crm_strdup(mutable_key);

	crm_free(mutable_key);
	return TRUE;
	}

	char *
	generate_notify_key(const char rsc_id, const char notify_type, const char *op_type)
	{
	int len = 12;
	char *op_id = NULL;

	CRM_CHECK(rsc_id != NULL, return NULL);
	CRM_CHECK(op_type != NULL, return NULL);
	CRM_CHECK(notify_type != NULL, return NULL);

	len += strlen(op_type);
	len += strlen(rsc_id);
	len += strlen(notify_type);
	crm_malloc0(op_id, len);
	if(op_id != NULL) {
	sprintf(op_id, "%s_%s_notify_%s_0", rsc_id, notify_type, op_type);
	}
	return op_id;
	}

	char *
	generate_transition_magic_v202(const char *transition_key, int op_status)
	{
	int len = 80;
	char *fail_state = NULL;

	CRM_CHECK(transition_key != NULL, return NULL);

	len += strlen(transition_key);

	crm_malloc0(fail_state, len);
	if(fail_state != NULL) {
	snprintf(fail_state, len, "%d:%s", op_status,transition_key);
	}
	return fail_state;
	}

	char *
	generate_transition_magic(const char *transition_key, int op_status, int op_rc)
	{
	int len = 80;
	char *fail_state = NULL;

	CRM_CHECK(transition_key != NULL, return NULL);

	len += strlen(transition_key);

	crm_malloc0(fail_state, len);
	if(fail_state != NULL) {
	snprintf(fail_state, len, "%d:%d;%s",
	op_status, op_rc, transition_key);
	}
	return fail_state;
	}

	gboolean
	decode_transition_magic(
	const char magic, char uuid, int transition_id, int *action_id,
	int op_status, int op_rc, int *target_rc)
	{
	int res = 0;
	char *key = NULL;
	gboolean result = TRUE;

	CRM_CHECK(magic != NULL, return FALSE);
	CRM_CHECK(op_rc != NULL, return FALSE);
	CRM_CHECK(op_status != NULL, return FALSE);

	crm_malloc0(key, strlen(magic));
	res = sscanf(magic, "%d:%d;%s", op_status, op_rc, key);
	if(res != 3) {
	crm_crit("Only found %d items in: %s", res, magic);
	result = FALSE;
	goto bail;
	}

	CRM_CHECK(decode_transition_key(key, uuid, transition_id, action_id, target_rc),
	result = FALSE;
	goto bail;
	);

	bail:
	crm_free(key);
	return result;
	}

	char *
	generate_transition_key(int transition_id, int action_id, int target_rc, const char *node)
	{
	int len = 40;
	char *fail_state = NULL;

	CRM_CHECK(node != NULL, return NULL);

	len += strlen(node);

	crm_malloc0(fail_state, len);
	if(fail_state != NULL) {
	snprintf(fail_state, len, "%d:%d:%d:%s",
	action_id, transition_id, target_rc, node);
	}
	return fail_state;
	}


	gboolean
	decode_transition_key(
	const char key, char uuid, int transition_id, int action_id, int target_rc)
	{
	int res = 0;
	gboolean done = FALSE;

	CRM_CHECK(uuid != NULL, return FALSE);
	CRM_CHECK(target_rc != NULL, return FALSE);
	CRM_CHECK(action_id != NULL, return FALSE);
	CRM_CHECK(transition_id != NULL, return FALSE);

	crm_malloc0(*uuid, strlen(key));
	res = sscanf(key, "%d:%d:%d:%s", action_id, transition_id, target_rc, *uuid);
	switch(res) {
	case 4:
	/* Post Pacemaker 0.6 */
	done = TRUE;
	break;
	case 3:
	case 2:
	/* this can be tricky - the UUID might start with an integer */

	/* Until Pacemaker 0.6 */
	done = TRUE;
	*target_rc = -1;
	res = sscanf(key, "%d:%d:%s", action_id, transition_id, *uuid);
	if(res == 2) {
	*action_id = -1;
	res = sscanf(key, "%d:%s", transition_id, *uuid);
	CRM_CHECK(res == 2, done = FALSE);

	} else if(res != 3) {
	CRM_CHECK(res == 3, done = FALSE);
	}
	break;

	case 1:
	/* Prior to Heartbeat 2.0.8 */
	done = TRUE;
	*action_id = -1;
	*target_rc = -1;
	res = sscanf(key, "%d:%s", transition_id, *uuid);
	CRM_CHECK(res == 2, done = FALSE);
	break;
	default:
	crm_crit("Unhandled sscanf result (%d) for %s", res, key);

	}

	if(strlen(*uuid) != 36) {
	crm_warn("Bad UUID (%s) in sscanf result (%d) for %s", *uuid, res, key);
	}

	if(done == FALSE) {
	crm_err("Cannot decode '%s' rc=%d", key, res);

	crm_free(*uuid);
	*uuid = NULL;
	*target_rc = -1;
	*action_id = -1;
	*transition_id = -1;
	}

	return done;
	}

	void
	filter_action_parameters(xmlNode param_set, const char version)
	{
	char *key = NULL;
	char *timeout = NULL;
	char *interval = NULL;
	#if CRM_DEPRECATED_SINCE_2_0_5
	const char *filter_205[] = {
	XML_ATTR_TE_TARGET_RC,
	XML_ATTR_LRM_PROBE,
	XML_RSC_ATTR_START,
	XML_RSC_ATTR_NOTIFY,
	XML_RSC_ATTR_UNIQUE,
	XML_RSC_ATTR_MANAGED,
	XML_RSC_ATTR_PRIORITY,
	XML_RSC_ATTR_MULTIPLE,
	XML_RSC_ATTR_STICKINESS,
	XML_RSC_ATTR_FAIL_STICKINESS,
	XML_RSC_ATTR_TARGET_ROLE,

	/* ignore clone fields */
	XML_RSC_ATTR_INCARNATION,
	XML_RSC_ATTR_INCARNATION_MAX,
	XML_RSC_ATTR_INCARNATION_NODEMAX,
	XML_RSC_ATTR_MASTER_MAX,
	XML_RSC_ATTR_MASTER_NODEMAX,

	/* old field names */
	"role",
	"crm_role",
	"te-target-rc",

	/* ignore notify fields */
	"notify_stop_resource",
	"notify_stop_uname",
	"notify_start_resource",
	"notify_start_uname",
	"notify_active_resource",
	"notify_active_uname",
	"notify_inactive_resource",
	"notify_inactive_uname",
	"notify_promote_resource",
	"notify_promote_uname",
	"notify_demote_resource",
	"notify_demote_uname",
	"notify_master_resource",
	"notify_master_uname",
	"notify_slave_resource",
	"notify_slave_uname"
	};
	#endif

	const char *attr_filter[] = {
	XML_ATTR_ID,
	XML_ATTR_CRM_VERSION,
	XML_LRM_ATTR_OP_DIGEST,
	};

	gboolean do_delete = FALSE;
	int lpc = 0;
	static int meta_len = 0;
	if(meta_len == 0) {
	meta_len = strlen(CRM_META);
	}

	if(param_set == NULL) {
	return;
	}

	#if CRM_DEPRECATED_SINCE_2_0_5
	if(version == NULL \|\| compare_version("1.0.5", version) > 0) {
	for(lpc = 0; lpc < DIMOF(filter_205); lpc++) {
	xml_remove_prop(param_set, filter_205[lpc]);
	}
	}
	#endif

	for(lpc = 0; lpc < DIMOF(attr_filter); lpc++) {
	xml_remove_prop(param_set, attr_filter[lpc]);
	}

	key = crm_meta_name(XML_LRM_ATTR_INTERVAL);
	interval = crm_element_value_copy(param_set, key);
	crm_free(key);

	key = crm_meta_name(XML_ATTR_TIMEOUT);
	timeout = crm_element_value_copy(param_set, key);

	xml_prop_iter(param_set, prop_name, prop_value,
	do_delete = FALSE;
	if(strncasecmp(prop_name, CRM_META, meta_len) == 0) {
	do_delete = TRUE;
	}

	if(do_delete) {
	xml_remove_prop(param_set, prop_name);
	}
	);

	if(crm_get_msec(interval) > 0 && compare_version(version, "1.0.8") > 0) {
	/* Re-instate the operation's timeout value */
	if(timeout != NULL) {
	crm_xml_add(param_set, key, timeout);
	}
	}

	crm_free(interval);
	crm_free(timeout);
	crm_free(key);
	}

	void
	filter_reload_parameters(xmlNode param_set, const char restart_string)
	{
	int len = 0;
	char *name = NULL;
	char *match = NULL;

	if(param_set == NULL) {
	return;
	}

	xml_prop_iter(param_set, prop_name, prop_value,
	name = NULL;
	len = strlen(prop_name) + 3;

	crm_malloc0(name, len);
	sprintf(name, " %s ", prop_name);
	name[len-1] = 0;

	match = strstr(restart_string, name);
	if(match == NULL) {
	crm_debug_3("%s not found in %s",
	prop_name, restart_string);
	xml_remove_prop(param_set, prop_name);
	}
	crm_free(name);
	);
	}

	void
	crm_abort(const char file, const char function, int line,
	const char *assert_condition, gboolean do_core, gboolean do_fork)
	{
	int rc = 0;
	int pid = 0;
	int status = 0;

	if(do_core == FALSE) {
	do_crm_log(LOG_ERR, "%s: Triggered assert at %s:%d : %s",
	function, file, line, assert_condition);
	return;

	} else if(do_fork) {
	pid=fork();

	} else {
	do_crm_log(LOG_ERR, "%s: Triggered fatal assert at %s:%d : %s",
	function, file, line, assert_condition);
	}

	switch(pid) {
	case -1:
	do_crm_log(LOG_CRIT, "%s: Cannot create core for non-fatal assert at %s:%d : %s",
	function, file, line, assert_condition);
	return;

	default: /* Parent */
	do_crm_log(LOG_ERR,
	"%s: Forked child %d to record non-fatal assert at %s:%d : %s",
	function, pid, file, line, assert_condition);
	do {
	rc = waitpid(pid, &status, 0);
	if(rc < 0 && errno != EINTR) {
	crm_perror(LOG_ERR,"%s: Cannot wait on forked child %d", function, pid);
	}

	} while(rc < 0 && errno == EINTR);

	return;

	case 0: /* Child */
	abort();
	break;
	}
	}

	char *
	generate_series_filename(
	const char directory, const char series, int sequence, gboolean bzip)
	{
	int len = 40;
	char *filename = NULL;
	const char *ext = "raw";

	CRM_CHECK(directory != NULL, return NULL);
	CRM_CHECK(series != NULL, return NULL);

	len += strlen(directory);
	len += strlen(series);
	crm_malloc0(filename, len);
	CRM_CHECK(filename != NULL, return NULL);

	if(bzip) {
	ext = "bz2";
	}
	sprintf(filename, "%s/%s-%d.%s", directory, series, sequence, ext);

	return filename;
	}

	int
	get_last_sequence(const char directory, const char series)
	{
	FILE *file_strm = NULL;
	int start = 0, length = 0, read_len = 0;
	char *series_file = NULL;
	char *buffer = NULL;
	int seq = 0;
	int len = 36;

	CRM_CHECK(directory != NULL, return 0);
	CRM_CHECK(series != NULL, return 0);

	len += strlen(directory);
	len += strlen(series);
	crm_malloc0(series_file, len);
	CRM_CHECK(series_file != NULL, return 0);
	sprintf(series_file, "%s/%s.last", directory, series);

	file_strm = fopen(series_file, "r");
	if(file_strm == NULL) {
	crm_debug("Series file %s does not exist", series_file);
	crm_free(series_file);
	return 0;
	}

	/* see how big the file is */
	start = ftell(file_strm);
	fseek(file_strm, 0L, SEEK_END);
	length = ftell(file_strm);
	fseek(file_strm, 0L, start);

	CRM_ASSERT(start == ftell(file_strm));

	crm_debug_3("Reading %d bytes from file", length);
	crm_malloc0(buffer, (length+1));
	read_len = fread(buffer, 1, length, file_strm);

	if(read_len != length) {
	crm_err("Calculated and read bytes differ: %d vs. %d",
	length, read_len);
	crm_free(buffer);
	buffer = NULL;

	} else if(length <= 0) {
	crm_info("%s was not valid", series_file);
	crm_free(buffer);
	buffer = NULL;
	}

	crm_free(series_file);
	seq = crm_parse_int(buffer, "0");
	crm_free(buffer);
	fclose(file_strm);
	return seq;
	}

	void
	write_last_sequence(
	const char directory, const char series, int sequence, int max)
	{
	int rc = 0;
	int len = 36;
	FILE *file_strm = NULL;
	char *series_file = NULL;

	CRM_CHECK(directory != NULL, return);
	CRM_CHECK(series != NULL, return);

	if(max == 0) {
	return;
	}
	while(max > 0 && sequence > max) {
	sequence -= max;
	}

	len += strlen(directory);
	len += strlen(series);
	crm_malloc0(series_file, len);
	sprintf(series_file, "%s/%s.last", directory, series);

	file_strm = fopen(series_file, "w");
	if(file_strm == NULL) {
	crm_err("Cannout open series file %s for writing", series_file);
	goto bail;
	}

	rc = fprintf(file_strm, "%d", sequence);
	if(rc < 0) {
	crm_perror(LOG_ERR,"Cannot write to series file %s", series_file);
	}

	bail:
	if(file_strm != NULL) {
	fflush(file_strm);
	fclose(file_strm);
	}

	crm_free(series_file);
	}

	#define LOCKSTRLEN 11

	int crm_pid_active(long pid)
	{
	int rc = 0;
	int running = 0;
	char proc_path[PATH_MAX], exe_path[PATH_MAX], myexe_path[PATH_MAX];

	if(pid <= 0) {
	return -1;

	} else if (kill(pid, 0) < 0 && errno == ESRCH) {
	return 0;
	}

	#ifndef HAVE_PROC_PID
	return 1;
	#endif

	/* check to make sure pid hasn't been reused by another process */
	snprintf(proc_path, sizeof(proc_path), "/proc/%lu/exe", pid);

	rc = readlink(proc_path, exe_path, PATH_MAX-1);
	if(rc < 0) {
	crm_perror(LOG_ERR, "Could not read from %s", proc_path);
	goto bail;
	}

	exe_path[rc] = 0;
	snprintf(proc_path, sizeof(proc_path), "/proc/%lu/exe", (long unsigned int)getpid());
	rc = readlink(proc_path, myexe_path, PATH_MAX-1);
	if(rc < 0) {
	crm_perror(LOG_ERR, "Could not read from %s", proc_path);
	goto bail;
	}

	myexe_path[rc] = 0;
	if(strcmp(exe_path, myexe_path) == 0) {
	running = 1;
	}

	bail:
	return running;
	}


	int
	crm_read_pidfile(const char *filename)
	{
	int fd;
	long pid = -1;
	char buf[LOCKSTRLEN+1];
	if ((fd = open(filename, O_RDONLY)) < 0) {
	goto bail;
	}

	if (read(fd, buf, sizeof(buf)) < 1) {
	goto bail;
	}

	if (sscanf(buf, "%lu", &pid) > 0) {
	if (pid <= 0){
	pid = -LSB_STATUS_STOPPED;
	}
	}

	bail:
	close(fd);
	return pid;
	}

	int
	crm_lock_pidfile(const char *filename)
	{
	struct stat sbuf;
	int fd = 0, rc = 0;
	long pid = 0, mypid = 0;
	char lf_name[256], tf_name[256], buf[LOCKSTRLEN+1];

	mypid = (unsigned long) getpid();
	snprintf(lf_name, sizeof(lf_name), "%s",filename);
	snprintf(tf_name, sizeof(tf_name), "%s.%lu", filename, mypid);

	if ((fd = open(lf_name, O_RDONLY)) >= 0) {
	if (fstat(fd, &sbuf) >= 0 && sbuf.st_size < LOCKSTRLEN) {
	sleep(1); /* if someone was about to create one,
	* give'm a sec to do so
	* Though if they follow our protocol,
	* this won't happen. They should really
	* put the pid in, then link, not the
	* other way around.
	*/
	}
	if (read(fd, buf, sizeof(buf)) > 0) {
	if (sscanf(buf, "%lu", &pid) > 0) {
	if (pid > 1 && pid != getpid() && crm_pid_active(pid)) {
	/* locked by existing process - give up */
	close(fd);
	return -1;
	}
	}
	}
	unlink(lf_name);
	close(fd);
	}

	if ((fd = open(tf_name, O_CREAT \| O_WRONLY \| O_EXCL, 0644)) < 0) {
	/* Hmmh, why did we fail? Anyway, nothing we can do about it */
	return -3;
	}

	/* Slight overkill with the %d format ;-) /
	snprintf(buf, sizeof(buf), "%*lu\n", LOCKSTRLEN-1, mypid);

	if (write(fd, buf, LOCKSTRLEN) != LOCKSTRLEN) {
	/* Again, nothing we can do about this */
	rc = -3;
	close(fd);
	goto out;
	}
	close(fd);

	switch (link(tf_name, lf_name)) {
	case 0:
	if (stat(tf_name, &sbuf) < 0) {
	/* something weird happened */
	rc = -3;

	} else if (sbuf.st_nlink < 2) {
	/* somehow, it didn't get through - NFS trouble? */
	rc = -2;

	} else {
	rc = 0;
	}
	break;

	case EEXIST:
	rc = -1;
	break;

	default:
	rc = -3;
	}
	out:
	unlink(tf_name);
	return rc;
	}

	void
	crm_make_daemon(const char name, gboolean daemonize, const char pidfile)
	{
	long pid;
	const char *devnull = "/dev/null";

	if(daemonize == FALSE) {
	return;
	}

	pid = fork();
	if (pid < 0) {
	fprintf(stderr, "%s: could not start daemon\n", name);
	crm_perror(LOG_ERR,"fork");
	exit(LSB_EXIT_GENERIC);

	} else if (pid > 0) {
	exit(LSB_EXIT_OK);
	}

	if (crm_lock_pidfile(pidfile) < 0 ) {
	pid = crm_read_pidfile(pidfile);
	if(crm_pid_active(pid) > 0) {
	crm_warn("%s: already running [pid %ld] (%s).\n", name, pid, pidfile);
	exit(LSB_EXIT_OK);
	}
	}

	umask(022);
	close(STDIN_FILENO);
	(void)open(devnull, O_RDONLY); /* Stdin: fd 0 */
	close(STDOUT_FILENO);
	(void)open(devnull, O_WRONLY); /* Stdout: fd 1 */
	close(STDERR_FILENO);
	(void)open(devnull, O_WRONLY); /* Stderr: fd 2 */
	}

	gboolean
	crm_is_writable(const char dir, const char file,
	const char user, const char group, gboolean need_both)
	{
	int s_res = -1;
	struct stat buf;
	char *full_file = NULL;
	const char *target = NULL;

	gboolean pass = TRUE;
	gboolean readwritable = FALSE;

	CRM_ASSERT(dir != NULL);
	if(file != NULL) {
	full_file = crm_concat(dir, file, '/');
	target = full_file;
	s_res = stat(full_file, &buf);
	if( s_res == 0 && S_ISREG(buf.st_mode) == FALSE ) {
	crm_err("%s must be a regular file", target);
	pass = FALSE;
	goto out;
	}
	}

	if (s_res != 0) {
	target = dir;
	s_res = stat(dir, &buf);
	if(s_res != 0) {
	crm_err("%s must exist and be a directory", dir);
	pass = FALSE;
	goto out;

	} else if( S_ISDIR(buf.st_mode) == FALSE ) {
	crm_err("%s must be a directory", dir);
	pass = FALSE;
	}
	}

	if(user) {
	struct passwd *sys_user = NULL;
	sys_user = getpwnam(user);
	readwritable = (sys_user != NULL
	&& buf.st_uid == sys_user->pw_uid
	&& (buf.st_mode & (S_IRUSR\|S_IWUSR)));
	if(readwritable == FALSE) {
	crm_err("%s must be owned and r/w by user %s",
	target, user);
	if(need_both) {
	pass = FALSE;
	}
	}
	}

	if(group) {
	struct group *sys_grp = getgrnam(group);
	readwritable = (
	sys_grp != NULL
	&& buf.st_gid == sys_grp->gr_gid
	&& (buf.st_mode & (S_IRGRP\|S_IWGRP)));
	if(readwritable == FALSE) {
	if(need_both \|\| user == NULL) {
	pass = FALSE;
	crm_err("%s must be owned and r/w by group %s",
	target, group);
	} else {
	crm_warn("%s should be owned and r/w by group %s",
	target, group);
	}
	}
	}

	out:
	crm_free(full_file);
	return pass;
	}

	static unsigned long long crm_bit_filter = 0; /* 0x00000002ULL; */
	static unsigned int bit_log_level = LOG_DEBUG_5;

	long long
	crm_clear_bit(const char *function, long long word, long long bit)
	{
	unsigned int level = bit_log_level;
	if(bit & crm_bit_filter) {
	level = LOG_ERR;
	}

	do_crm_log_unlikely(level, "Bit 0x%.16llx cleared by %s", bit, function);
	word &= ~bit;

	return word;
	}

	long long
	crm_set_bit(const char *function, long long word, long long bit)
	{
	unsigned int level = bit_log_level;
	if(bit & crm_bit_filter) {
	level = LOG_ERR;
	}

	do_crm_log_unlikely(level, "Bit 0x%.16llx set by %s", bit, function);
	word \|= bit;
	return word;
	}

	static const char *cluster_type = NULL;

	gboolean is_openais_cluster(void)
	{
	if(cluster_type == NULL) {
	cluster_type = getenv("HA_cluster_type");
	if(cluster_type == NULL) {
	cluster_type = "Heartbeat";
	}
	}

	if(safe_str_eq("openais", cluster_type)) {
	#if SUPPORT_AIS
	return TRUE;
	#else
	crm_crit("The installation of Pacemaker only supports Heartbeat"
	" but you're trying to run it on %s. Terminating.",
	cluster_type);
	exit(100);
	#endif
	}
	return FALSE;
	}

	gboolean is_heartbeat_cluster(void)
	{
	#if SUPPORT_HEARTBEAT
	return !is_openais_cluster();
	#else
	if(is_openais_cluster() == FALSE) {
	crm_crit("The installation of Pacemaker only supports OpenAIS"
	" but you're trying to run it on %s. Terminating.",
	cluster_type);
	exit(100);
	}
	return FALSE;
	#endif
	}

	gboolean crm_str_eq(const char a, const char b, gboolean use_case)
	{
	if(a == b) {
	return TRUE;

	} else if(a == NULL \|\| b == NULL) {
	/* shouldn't be comparing NULLs */
	return FALSE;

	} else if(use_case && a[0] != b[0]) {
	return FALSE;

	} else if(strcasecmp(a, b) == 0) {
	return TRUE;
	}
	return FALSE;
	}

	char crm_meta_name(const char field)
	{
	int lpc = 0;
	int max = 0;
	char *crm_name = NULL;

	CRM_CHECK(field != NULL, return NULL);
	crm_name = crm_concat(CRM_META, field, '_');

	/* Massage the names so they can be used as shell variables */
	max = strlen(crm_name);
	for(; lpc < max; lpc++) {
	switch(crm_name[lpc]) {
	case '-':
	crm_name[lpc] = '_';
	break;
	}
	}
	return crm_name;
	}

	const char crm_meta_value(GHashTable hash, const char *field)
	{
	char *key = NULL;
	const char *value = NULL;

	key = crm_meta_name(field);
	if(key) {
	value = g_hash_table_lookup(hash, key);
	crm_free(key);
	}

	return value;
	}

	static struct crm_option *crm_long_options = NULL;
	static const char *crm_app_description = NULL;
	static const char *crm_short_options = NULL;
	static const char *crm_app_usage = NULL;

	static struct option crm_create_long_opts(struct crm_option long_options)
	{
	struct option *long_opts = NULL;

	#ifdef HAVE_GETOPT_H
	int index = 0, lpc = 0;
	for(lpc = 0; long_options[lpc].name != NULL; lpc++) {
	if(long_options[lpc].name[0] == '-') {
	continue;
	}

	crm_realloc(long_opts, (index+1) * sizeof(struct option));
	long_opts[index].name = long_options[lpc].name;
	long_opts[index].has_arg = long_options[lpc].has_arg;
	long_opts[index].flag = long_options[lpc].flag;
	long_opts[index].val = long_options[lpc].val;
	index++;
	}

	/* Now create the list terminator */
	crm_realloc(long_opts, (index+1) * sizeof(struct option));
	long_opts[index].name = NULL;
	long_opts[index].has_arg = 0;
	long_opts[index].flag = 0;
	long_opts[index].val = 0;
	#endif

	return long_opts;
	}

	void crm_set_options(const char short_options, const char app_usage, struct crm_option long_options, const char app_desc)
	{
	if(short_options) {
	crm_short_options = short_options;
	}
	if(long_options) {
	crm_long_options = long_options;
	}
	if(app_desc) {
	crm_app_description = app_desc;
	}
	if(app_usage) {
	crm_app_usage = app_usage;
	}
	}

	char crm_get_option(int argc, char *argv, int index)
	{
	#ifdef HAVE_GETOPT_H
	static struct option *long_opts = NULL;
	if(long_opts == NULL && crm_long_options) {
	long_opts = crm_create_long_opts(crm_long_options);
	}

	if(long_opts) {
	return getopt_long(argc, argv, crm_short_options, long_opts, index);
	}
	#endif

	if(crm_short_options) {
	return getopt(argc, argv, crm_short_options);
	}

	return -1;
	}

	void crm_help(char cmd, int exit_code)
	{
	FILE *stream = (exit_code ? stderr : stdout);

	if(cmd == 'v') {
	fprintf(stream, "%s %s (Build: %s)\n", crm_system_name, VERSION, BUILD_VERSION);
	+ fprintf(stream, "\nWritten by Andrew Beekhof <abeekhof@suse.de>\n");

	} else if(cmd == '?') {
	int i = 0;
	fprintf(stream, "%s - %s\n", crm_system_name, crm_app_description);

	if(crm_app_usage) {
	fprintf(stream, "Usage: %s %s\n", crm_system_name, crm_app_usage);
	}

	if(crm_long_options) {
	- fprintf(stream, "Options: \n");
	-
	+ fprintf(stream, "\n");
	for(i = 0; crm_long_options[i].name != NULL; i++) {
	if(crm_long_options[i].name[0] == '-' && crm_long_options[i].desc) {
	fprintf(stream, "%s\n", crm_long_options[i].desc);

	} else if(crm_long_options[i].hidden == 0) {
	- fprintf(stream, "\t-%c\|--%s %s\t%s\n", crm_long_options[i].val, crm_long_options[i].name, crm_long_options[i].has_arg?"{value}":"", crm_long_options[i].desc?crm_long_options[i].desc:"");
	+ fprintf(stream, " -%c, --%s%c%s\t%s\n", crm_long_options[i].val, crm_long_options[i].name,
	+ crm_long_options[i].has_arg?'=':' ',crm_long_options[i].has_arg?"value":"",
	+ crm_long_options[i].desc?crm_long_options[i].desc:"");
	}
	}

	} else if(crm_short_options) {
	fprintf(stream, "Usage: %s - %s\n", crm_system_name, crm_app_description);
	for(i = 0; crm_short_options[i] != 0; i++) {
	int has_arg = FALSE;

	if(crm_short_options[i+1] == ':') {
	has_arg = TRUE;
	}

	- fprintf(stream, "\t-%c %s\n", crm_short_options[i], has_arg?"{value}":"");
	+ fprintf(stream, " -%c %s\n", crm_short_options[i], has_arg?"{value}":"");
	if(has_arg) {
	i++;
	}
	}
	}
	}

	if(exit_code >= 0) {
	exit(exit_code);
	}
	}
	diff --git a/pengine/Makefile.am b/pengine/Makefile.am
	index 7defc0e9c6..9179db900d 100644
	--- a/pengine/Makefile.am
	+++ b/pengine/Makefile.am
	@@ -1,66 +1,72 @@
	#
	# Copyright (C) 2004 Andrew Beekhof
	#
	# 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 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.
	#
	# You should have received a copy of the GNU General Public License
	# along with this program; if not, write to the Free Software
	# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
	#
	MAINTAINERCLEANFILES = Makefile.in

	INCLUDES = -I$(top_builddir)/include -I$(top_srcdir)/include \
	-I$(top_builddir) -I$(top_srcdir) \
	-I$(top_builddir)/libltdl -I$(top_srcdir)/libltdl

	halibdir = $(CRM_DAEMON_DIR)

	COMMONLIBS = \
	$(top_builddir)/lib/common/libcrmcommon.la \
	$(top_builddir)/lib/pengine/libpe_status.la \
	libpengine.la $(CURSESLIBS) $(CLUSTERLIBS)

	## libraries
	lib_LTLIBRARIES = libpengine.la

	## binary progs
	halib_PROGRAMS = pengine
	sbin_PROGRAMS = ptest

	+if BUILD_HELP
	+man8_MANS = ptest.8
	+%.8: %
	+ help2man --output $@ --no-info --section 8 --name "Part of the Pacemaker cluster resource manager" $(abs_builddir)/$<
	+endif
	+
	## SOURCES
	noinst_HEADERS = allocate.h utils.h pengine.h
	#utils.h pengine.h

	libpengine_la_LDFLAGS = -version-info 3:0:0
	# -L$(top_builddir)/lib/pils -lpils -export-dynamic -module -avoid-version
	libpengine_la_SOURCES = pengine.c allocate.c utils.c constraints.c \
	native.c group.c clone.c master.c graph.c

	pengine_SOURCES = main.c
	pengine_LDADD = $(COMMONLIBS) $(top_builddir)/lib/cib/libcib.la
	# libcib for get_object_root()
	# $(top_builddir)/lib/hbclient/libhbclient.la

	ptest_SOURCES = ptest.c
	ptest_LDADD = $(COMMONLIBS) \
	$(top_builddir)/lib/cib/libcib.la \
	$(top_builddir)/lib/transition/libtransitioner.la

	clean-generic:
	rm -f .log .debug ~ .gres. testcases/.gres.*

	install-exec-local:
	$(mkinstalldirs) $(DESTDIR)/$(PE_STATE_DIR)
	-chown $(CRM_DAEMON_USER) $(DESTDIR)/$(PE_STATE_DIR)
	-chgrp $(CRM_DAEMON_GROUP) $(DESTDIR)/$(PE_STATE_DIR)
	-chmod 750 $(DESTDIR)/$(PE_STATE_DIR)

	uninstall-local:
	diff --git a/pengine/ptest.c b/pengine/ptest.c
	index 4e33e31f36..8ecef45ca9 100644
	--- a/pengine/ptest.c
	+++ b/pengine/ptest.c
	@@ -1,479 +1,479 @@

	/*
	* 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 <crm_internal.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>

	#include <glib.h>
	#include <pengine.h>
	#include <lib/pengine/utils.h>
	#include <allocate.h>
	#if HAVE_LIBXML2
	# include <libxml/parser.h>
	#endif

	gboolean use_stdin = FALSE;
	gboolean do_simulation = FALSE;
	gboolean inhibit_exit = FALSE;
	gboolean all_actions = FALSE;
	extern xmlNode * do_calculations(
	pe_working_set_t data_set, xmlNode 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"); \
	} 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 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, ' ');
	}
	if(safe_str_eq(action->task, RSC_CANCEL)) {
	char *tmp_action_name = action_name;
	action_name = crm_concat("Cancel", tmp_action_name, ' ');
	crm_free(tmp_action_name);
	}

	return action_name;
	}

	gboolean USE_LIVE_CIB = FALSE;
	static struct crm_option long_options[] = {
	/* Top-level Options */
	{"help", 0, 0, '?', "This text"},
	{"version", 0, 0, 'v', "Version information" },
	{"verbose", 0, 0, 'V', "Increase debug output\n"},

	{"show-scores", 0, 0, 's', "Display resource allocation scores"},
	- {"simulate", 0, 0, 'S', "\tSimulate the transition's execution to find invalid graphs\n"},
	+ {"simulate", 0, 0, 'S', "Simulate the transition's execution to find invalid graphs\n"},

	{"live-check", 0, 0, 'L', "Connect to the CIB and use the current contents as input"},
	{"xml-text", 1, 0, 'X', "Retrieve XML from the supplied string"},
	{"xml-file", 1, 0, 'x', "Retrieve XML from the named file"},
	- {"xml-pipe", 0, 0, 'p', "\tRetrieve XML from stdin\n"},
	+ {"xml-pipe", 0, 0, 'p', "Retrieve XML from stdin\n"},

	{"save-input", 1, 0, 'I', "\tSave the input to the named file"},
	{"save-graph", 1, 0, 'G', "\tSave the transition graph (XML format) to the named file"},
	{"save-dotfile",1, 0, 'D', "Save the transition graph (DOT format) to the named file\n"},

	{0, 0, 0, 0}
	};

	int
	main(int argc, char **argv)
	{
	gboolean process = TRUE;
	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;

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

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

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

	/* disable glib's fancy allocators that can't be free'd */
	GMemVTable vtable;

	vtable.malloc = malloc;
	vtable.realloc = realloc;
	vtable.free = free;
	vtable.calloc = calloc;
	vtable.try_malloc = malloc;
	vtable.try_realloc = realloc;

	g_mem_set_vtable(&vtable);


	crm_log_init("ptest", LOG_CRIT, FALSE, FALSE, 0, NULL);
	crm_set_options("V?vXD:G:I:Lwx:d:aSs", "[-?Vv] -[Xxp] {other options}", long_options,
	"Calculate the cluster's response to the supplied cluster state\n");
	cl_log_set_facility(LOG_USER);

	while (1) {
	int option_index = 0;
	flag = crm_get_option(argc, argv, &option_index);
	if (flag == -1)
	break;

	switch(flag) {
	case 'S':
	do_simulation = TRUE;
	break;
	case 'a':
	all_actions = TRUE;
	break;
	case 'w':
	inhibit_exit = TRUE;
	break;
	case 'X':
	use_stdin = TRUE;
	break;
	case 's':
	show_scores = TRUE;
	break;
	case 'x':
	xml_file = optarg;
	break;
	case 'd':
	use_date = optarg;
	break;
	case 'D':
	dot_file = optarg;
	break;
	case 'G':
	graph_file = optarg;
	break;
	case 'I':
	input_file = optarg;
	break;
	case 'V':
	cl_log_enable_stderr(TRUE);
	alter_debug(DEBUG_INC);
	break;
	case 'L':
	USE_LIVE_CIB = TRUE;
	break;
	case 'v':
	case '?':
	crm_help(flag, 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);
	crm_help('?', 1);
	}

	if(USE_LIVE_CIB) {
	int rc = cib_ok;
	source = "live cib";
	cib_conn = cib_new();
	rc = cib_conn->cmds->signon(cib_conn, "ptest", cib_command);

	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) {
	source = xml_file;
	cib_object = filename2xml(xml_file);

	} else if(use_stdin) {
	source = "stdin";
	cib_object = filename2xml(NULL);
	}

	if(cib_object == NULL && source) {
	fprintf(stderr, "Could not parse configuration input from: %s\n", source);
	return 4;

	} else if(cib_object == NULL) {
	fprintf(stderr, "Not configuration specified\n");
	crm_help('?', 1);
	}

	if(cli_config_update(&cib_object, NULL) == FALSE) {
	free_xml(cib_object);
	return cib_STALE;
	}

	if(validate_xml(cib_object, NULL, FALSE) != TRUE) {
	free_xml(cib_object);
	return cib_dtd_validation;
	}

	if(input_file != NULL) {
	FILE *input_strm = fopen(input_file, "w");
	if(input_strm == NULL) {
	crm_perror(LOG_ERR,"Could not open %s for writing", input_file);
	} else {
	msg_buffer = dump_xml_formatted(cib_object);
	if(fprintf(input_strm, "%s\n", msg_buffer) < 0) {
	crm_perror(LOG_ERR,"Write to %s failed", input_file);
	}
	fflush(input_strm);
	fclose(input_strm);
	crm_free(msg_buffer);
	}
	}

	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);
	}

	if(process) {
	if(show_scores) {
	fprintf(stdout, "Allocation scores:\n");
	}
	do_calculations(&data_set, cib_object, a_date);
	}

	msg_buffer = dump_xml_formatted(data_set.graph);
	if(safe_str_eq(graph_file, "-")) {
	fprintf(stdout, "%s\n", msg_buffer);
	fflush(stdout);
	} else if(graph_file != NULL) {
	FILE *graph_strm = fopen(graph_file, "w");
	if(graph_strm == NULL) {
	crm_perror(LOG_ERR,"Could not open %s for writing", graph_file);
	} else {
	if(fprintf(graph_strm, "%s\n\n", msg_buffer) < 0) {
	crm_perror(LOG_ERR,"Write to %s failed", graph_file);
	}
	fflush(graph_strm);
	fclose(graph_strm);
	}
	}
	crm_free(msg_buffer);

	if(dot_file != NULL) {
	dot_strm = fopen(dot_file, "w");
	if(dot_strm == NULL) {
	crm_perror(LOG_ERR,"Could not open %s for writing", dot_file);
	}
	}

	if(dot_strm == NULL) {
	goto simulate;
	}

	init_dotfile();
	slist_iter(
	action, action_t, data_set.actions, lpc,

	const char *style = "filled";
	const char *font = "black";
	const char *color = "black";
	const char *fill = NULL;
	char *action_name = create_action_name(action);
	crm_debug_3("Action %d: %p", action->id, action);

	if(action->pseudo) {
	font = "orange";
	}

	style = "dashed";
	if(action->dumped) {
	style = "bold";
	color = "green";

	} else if(action->rsc != NULL
	&& is_not_set(action->rsc->flags, pe_rsc_managed)) {
	color = "purple";
	if(all_actions == FALSE) {
	goto dont_write;
	}

	} else if(action->optional) {
	color = "blue";
	if(all_actions == FALSE) {
	goto dont_write;
	}

	} else {
	color = "red";
	CRM_CHECK(action->runnable == FALSE, ;);
	}

	action->dumped = TRUE;
	dot_write("\"%s\" [ style=%s color=\"%s\" fontcolor=\"%s\" %s%s]",
	action_name, style, color, font, fill?"fillcolor=":"", fill?fill:"");
	dont_write:
	crm_free(action_name);
	);


	slist_iter(
	action, action_t, data_set.actions, lpc,
	slist_iter(
	before, action_wrapper_t, action->actions_before, lpc2,
	char *before_name = NULL;
	char *after_name = NULL;
	const char *style = "dashed";
	optional = TRUE;
	if(before->state == pe_link_dumped) {
	optional = FALSE;
	style = "bold";
	} else if(action->pseudo
	&& (before->type & pe_order_stonith_stop)) {
	continue;
	} else if(before->state == pe_link_dup) {
	continue;
	} else if(action->dumped && before->action->dumped) {
	optional = FALSE;
	}

	if(all_actions \|\| optional == FALSE) {
	before_name = create_action_name(before->action);
	after_name = create_action_name(action);
	dot_write("\"%s\" -> \"%s\" [ style = %s]",
	before_name, after_name, style);
	crm_free(before_name);
	crm_free(after_name);
	}
	);
	);
	dot_write("}");
	if(dot_strm != NULL) {
	fflush(dot_strm);
	fclose(dot_strm);
	}

	simulate:

	if(do_simulation == FALSE) {
	goto cleanup;
	}

	transition = unpack_graph(data_set.graph, "ptest");
	transition->batch_limit = 0;

	print_graph(LOG_DEBUG, 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);
	}
	destroy_graph(transition);
	CRM_CHECK(graph_rc == transition_complete, all_good = FALSE; crm_err("An invalid transition was produced"));

	cleanup:
	cleanup_alloc_calculations(&data_set);
	crm_log_deinit();

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

	if(all_good) {
	return 0;
	}
	return 5;
	}
	diff --git a/tools/Makefile.am b/tools/Makefile.am
	index 4681ed6c0f..e857f00e12 100644
	--- a/tools/Makefile.am
	+++ b/tools/Makefile.am
	@@ -1,124 +1,130 @@
	#
	# Copyright (C) 2004-2009 Andrew Beekhof
	#
	# 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 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.
	#
	# You should have received a copy of the GNU General Public License
	# along with this program; if not, write to the Free Software
	# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
	#
	MAINTAINERCLEANFILES = Makefile.in ccdv

	SUBDIRS = shell

	INCLUDES = -I$(top_builddir)/include -I$(top_srcdir)/include \
	-I$(top_builddir)/libltdl -I$(top_srcdir)/libltdl \
	-I$(AISPREFIX)/include/openais

	COMMONLIBS = \
	$(top_builddir)/lib/common/libcrmcommon.la \
	$(top_builddir)/lib/cib/libcib.la \
	-lplumb $(CURSESLIBS) $(CLUSTERLIBS)

	headerdir = $(pkgincludedir)/crm
	header_HEADERS = attrd.h

	EXTRA_DIST = ccdv.c

	halibdir = $(CRM_DAEMON_DIR)
	halib_SCRIPTS = haresources2cib.py hb2openais.sh
	halib_PROGRAMS = attrd pingd
	halib_PYTHON = crm_primitive.py hb2openais-helper.py

	sbin_PROGRAMS = crmadmin cibadmin crm_node crm_diff crm_mon iso8601 \
	crm_master crm_standby crm_failcount crm_attribute \
	crm_resource crm_verify crm_uuid crm_shadow attrd_updater

	+if BUILD_HELP
	+man8_MANS = crmadmin.8 cibadmin.8 crm_mon.8 crm_shadow.8 crm_node.8 crm_verify.8
	+%.8: %
	+ help2man --output $@ --no-info --section 8 --name "Part of the Pacemaker cluster resource manager" $(abs_builddir)/$<
	+endif
	+
	sbin_SCRIPTS = crm

	## SOURCES
	ccdv: $(top_srcdir)/tools/ccdv.c
	gcc $(AM_CFLAGS) $(CFLAGS) -o ccdv $(top_srcdir)/tools/ccdv.c

	## SOURCES

	#noinst_HEADERS = config.h control.h crmd.h
	noinst_HEADERS =

	crmadmin_SOURCES = crmadmin.c
	crmadmin_LDADD = $(COMMONLIBS) $(CLUSTERLIBS) \
	$(top_builddir)/lib/pengine/libpe_status.la

	crm_uuid_SOURCES = crm_uuid.c
	crm_uuid_LDADD = $(top_builddir)/lib/common/libcrmcluster.la

	cibadmin_SOURCES = cibadmin.c
	cibadmin_LDADD = $(COMMONLIBS)

	crm_shadow_SOURCES = cib_shadow.c
	crm_shadow_LDADD = $(COMMONLIBS)

	crm_node_SOURCES = ccm_epoche.c
	crm_node_LDADD = $(COMMONLIBS) $(CLUSTERLIBS) \
	$(top_builddir)/lib/common/libcrmcluster.la

	crm_diff_SOURCES = xml_diff.c
	crm_diff_LDADD = $(COMMONLIBS)

	crm_mon_SOURCES = crm_mon.c
	crm_mon_LDADD = $(COMMONLIBS) $(SNMPLIBS) $(ESMTPLIBS) -llrm \
	$(top_builddir)/lib/pengine/libpe_status.la

	# Arguments could be made that this should live in crm/pengine
	crm_verify_SOURCES = crm_verify.c
	crm_verify_LDADD = $(COMMONLIBS) \
	$(top_builddir)/lib/pengine/libpe_status.la \
	$(top_builddir)/pengine/libpengine.la

	crm_master_SOURCES = crm_attribute.c
	crm_master_LDADD = $(COMMONLIBS)

	crm_standby_SOURCES = crm_attribute.c
	crm_standby_LDADD = $(COMMONLIBS)

	crm_attribute_SOURCES = crm_attribute.c
	crm_attribute_LDADD = $(COMMONLIBS)

	crm_failcount_SOURCES = crm_attribute.c
	crm_failcount_LDADD = $(COMMONLIBS)

	crm_resource_SOURCES = crm_resource.c
	crm_resource_LDADD = $(COMMONLIBS) \
	$(top_builddir)/lib/pengine/libpe_rules.la \
	$(top_builddir)/lib/pengine/libpe_status.la

	iso8601_SOURCES = test.iso8601.c
	iso8601_LDADD = $(COMMONLIBS)

	# A little trick. Now ccdv can be auto-built but not auto-cleaned.
	attrd_DEPENDENCIES = ccdv
	attrd_SOURCES = attrd.c
	attrd_LDADD = $(COMMONLIBS) $(top_builddir)/lib/common/libcrmcluster.la

	pingd_SOURCES = pingd.c
	pingd_LDADD = $(COMMONLIBS)

	attrd_updater_SOURCES = attrd_updater.c
	attrd_updater_LDADD = $(COMMONLIBS)

	clean-generic:
	rm -f .log .debug .xml ~

	install-exec-local:

	uninstall-local:

	.PHONY: install-exec-hook

File Metadata

Mime Type: text/x-diff
Expires: Wed, Oct 15, 11:57 PM (2 h, 58 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 2530599
Default Alt Text: (64 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions