No OneTemporary
Actions

Size

41 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/crm/common/utils.c b/lib/crm/common/utils.c
	index 44a252ebfe..22eeb77293 100644
	--- a/lib/crm/common/utils.c
	+++ b/lib/crm/common/utils.c
	@@ -1,1870 +1,1871 @@
	/* $Id: utils.c,v 1.64 2006/08/14 09:06:31 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>

	#ifndef _GNU_SOURCE
	# define _GNU_SOURCE
	#endif

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

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

	#include <heartbeat.h>
	#include <ha_msg.h>
	#include <clplumbing/cl_log.h>
	#include <clplumbing/cl_signal.h>
	#include <clplumbing/cl_syslog.h>
	#include <clplumbing/cl_misc.h>
	#include <clplumbing/coredumps.h>
	#include <clplumbing/lsb_exitcodes.h>
	#include <clplumbing/cl_pidfile.h>

	#include <time.h>

	#include <clplumbing/Gmain_timeout.h>

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

	#ifndef MAXLINE
	# define MAXLINE 512
	#endif

	static uint ref_counter = 0;
	gboolean crm_assert_failed = FALSE;
	unsigned int crm_log_level = LOG_INFO;
	gboolean crm_config_error = FALSE;
	gboolean crm_config_warning = FALSE;

	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_notice("Using default value '%s' for cluster option '%s'",
	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;
	}

	gboolean
	decode_hash_value(gpointer value, char node, char subsys)
	{
	char char_value = (char)value;
	int value_len = strlen(char_value);

	CRM_CHECK(value != NULL, return FALSE);
	CRM_CHECK(node != NULL, return FALSE);
	CRM_CHECK(subsys != NULL, return FALSE);

	*node = NULL;
	*subsys = NULL;

	crm_info("Decoding hash value: (%s:%d)", char_value, value_len);

	if (strcasecmp(CRM_SYSTEM_DC, (char*)value) == 0) {
	*node = NULL;
	subsys = (char)crm_strdup(char_value);
	CRM_CHECK(*subsys != NULL, return FALSE);
	crm_info("Decoded value: (%s:%d)", *subsys,
	(int)strlen(*subsys));
	return TRUE;

	} else if (decodeNVpair(char_value, '_', node, subsys)) {
	return TRUE;
	}

	crm_free(*node);
	crm_free(*subsys);
	*node = NULL;
	*subsys = NULL;
	return FALSE;
	}


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

	gboolean
	crm_log_init(const char *entity)
	{
	/* const char test = "Testing log daemon connection"; /
	/* Redirect messages from glib functions to our handler */
	/* cl_malloc_forced_for_glib(); */
	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(entity);
	cl_log_set_facility(LOG_LOCAL7);

	cl_set_corerootdir(HA_COREDIR);
	cl_cdtocoredir();

	crm_set_env_options();

	CL_SIGNAL(DEBUG_INC, alter_debug);
	CL_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;
	}

	void
	crm_log_message_adv(int level, const char prefix, const HA_Message msg)
	{
	if((int)crm_log_level >= level) {
	do_crm_log(level, "#========= %s message start ==========#", prefix?prefix:"");
	if(level > LOG_DEBUG) {
	cl_log_message(LOG_DEBUG, msg);
	} else {
	cl_log_message(level, msg);
	}
	}
	}

	int
	compare_version(const char version1, const char version2)
	{
	int lpc = 0;
	char step1 = NULL, step2 = 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;
	}

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

	while(1) {
	int cmp = 0;
	int step1_i = 0;
	int step2_i = 0;
	char tmp1 = NULL, tmp2 = NULL;

	decodeNVpair(rest1, '.', &step1, &tmp1);
	decodeNVpair(rest2, '.', &step2, &tmp2);

	if(step1 != NULL) {
	step1_i = crm_parse_int(step1, NULL);
	}
	if(step2 != NULL) {
	step2_i = crm_parse_int(step2, NULL);
	}

	if(step1_i < step2_i){
	cmp = -1;
	} else if (step1_i > step2_i){
	cmp = 1;
	}

	crm_debug_4("compare[%d (%d)]: %d(%s) %d(%s)",
	lpc++, cmp,
	step1_i, crm_str(step1),
	step2_i, crm_str(step2));

	crm_free(rest1);
	crm_free(rest2);

	rest1 = tmp1;
	rest2 = tmp2;

	if(step1 == NULL && step2 == NULL) {
	break;
	}

	crm_free(step1);
	crm_free(step2);

	if(cmp < 0) {
	crm_debug_3("%s < %s", version1, version2);
	return -1;

	} else if(cmp > 0) {
	crm_debug_3("%s > %s", version1, version2);
	return 1;
	}
	}
	crm_debug_3("%s == %s", version1, version2);
	return 0;
	}

	gboolean do_stderr = FALSE;

	void
	alter_debug(int nsig)
	{
	CL_SIGNAL(DEBUG_INC, alter_debug);
	CL_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);
	}

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

	errno = 0;

	if(text != NULL) {
	if(end_text != NULL) {
	atoi_result = (int)strtol(text, end_text, 10);
	} else {
	atoi_result = (int)strtol(text, &local_end_text, 10);
	}

	/* CRM_CHECK(errno != EINVAL); */
	if(errno == EINVAL) {
	crm_err("Conversion of %s failed", text);
	atoi_result = -1;

	} else {
	if(errno == ERANGE) {
	crm_err("Conversion of %s was clipped", text);
	}
	if(end_text == NULL && local_end_text[0] != '\0') {
	crm_err("Characters left over after parsing "
	"\"%s\": \"%s\"", text, local_end_text);
	}

	}
	}
	return atoi_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
	crm_str_eq(const char a, const char b, gboolean use_case)
	{
	if(a == NULL \|\| b == NULL) {
	CRM_ASSERT(a != b);
	return FALSE;

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

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

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

	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(const char *src)
	{
	char *dup = NULL;
	CRM_CHECK(src != NULL, return NULL);
	crm_malloc0(dup, strlen(src) + 1);
	return strcpy(dup, src);
	}

	static GHashTable *crm_uuid_cache = NULL;
	static GHashTable *crm_uname_cache = NULL;

	void
	unget_uuid(const char *uname)
	{
	if(crm_uuid_cache == NULL) {
	return;
	}
	g_hash_table_remove(crm_uuid_cache, uname);
	}
	const char *
	get_uuid(ll_cluster_t hb, const char uname)
	{
	cl_uuid_t uuid_raw;
	char *uuid_calc = NULL;
	const char *unknown = "00000000-0000-0000-0000-000000000000";

	if(crm_uuid_cache == NULL) {
	crm_uuid_cache = g_hash_table_new_full(
	g_str_hash, g_str_equal,
	g_hash_destroy_str, g_hash_destroy_str);
	}

	CRM_CHECK(uname != NULL, return NULL);

	/* avoid blocking calls where possible */
	uuid_calc = g_hash_table_lookup(crm_uuid_cache, uname);
	if(uuid_calc != NULL) {
	return uuid_calc;
	}


	if(hb->llc_ops->get_uuid_by_name(hb, uname, &uuid_raw) == HA_FAIL) {
	crm_err("get_uuid_by_name() call failed for host %s", uname);
	crm_free(uuid_calc);
	return NULL;

	}

	crm_malloc0(uuid_calc, 50);

	if(uuid_calc == NULL) {
	return NULL;
	}

	cl_uuid_unparse(&uuid_raw, uuid_calc);

	if(safe_str_eq(uuid_calc, unknown)) {
	crm_warn("Could not calculate UUID for %s", uname);
	crm_free(uuid_calc);
	return NULL;
	}

	g_hash_table_insert(crm_uuid_cache, crm_strdup(uname), uuid_calc);
	uuid_calc = g_hash_table_lookup(crm_uuid_cache, uname);

	return uuid_calc;
	}

	const char *
	get_uname(ll_cluster_t hb, const char uuid)
	{
	char *uname = NULL;

	if(crm_uuid_cache == NULL) {
	crm_uname_cache = g_hash_table_new_full(
	g_str_hash, g_str_equal,
	g_hash_destroy_str, g_hash_destroy_str);
	}

	CRM_CHECK(uuid != NULL, return NULL);

	/* avoid blocking calls where possible */
	uname = g_hash_table_lookup(crm_uname_cache, uuid);
	if(uname != NULL) {
	return uname;
	}

	if(uuid != NULL) {
	cl_uuid_t uuid_raw;
	char *uuid_copy = crm_strdup(uuid);
	cl_uuid_parse(uuid_copy, &uuid_raw);

	if(hb->llc_ops->get_name_by_uuid(
	hb, &uuid_raw, uname, 256) == HA_FAIL) {
	crm_err("Could not calculate UUID for %s", uname);
	uname = NULL;
	crm_free(uuid_copy);

	} else {
	g_hash_table_insert(
	crm_uuid_cache,
	uuid_copy, crm_strdup(uname));
	uname = g_hash_table_lookup(crm_uname_cache, uuid);
	}
	return uname;
	}
	return NULL;
	}

	void
	set_uuid(ll_cluster_t hb,crm_data_t node,const char attr,const char uname)
	{
	const char *uuid_calc = get_uuid(hb, uname);
	crm_xml_add(node, attr, uuid_calc);
	return;
	}


	#define ENV_PREFIX "HA_"
	void
	crm_set_env_options(void)
	{
	char *param_val = NULL;
	const char *param_name = NULL;

	/* apparently we're not allowed to free the result of getenv */

	param_name = ENV_PREFIX "" KEY_DEBUGLEVEL;
	param_val = getenv(param_name);
	if(param_val != NULL) {
	int debug_level = crm_parse_int(param_val, NULL);
	if(debug_level > 0 && (debug_level+LOG_INFO) > (int)crm_log_level) {
	set_crm_log_level(LOG_INFO + debug_level);
	}
	crm_debug("%s = %s", param_name, param_val);
	param_val = NULL;
	}

	param_name = ENV_PREFIX "" KEY_FACILITY;
	param_val = getenv(param_name);
	crm_debug("%s = %s", param_name, param_val);
	if(param_val != NULL) {
	int facility = cl_syslogfac_str2int(param_val);
	- if(facility > 0) {
	+ if(facility >= 0) {
	cl_log_set_facility(facility);
	}
	param_val = NULL;
	}

	param_name = ENV_PREFIX "" KEY_LOGFILE;
	param_val = getenv(param_name);
	crm_debug("%s = %s", param_name, param_val);
	if(param_val != NULL) {
	if(safe_str_eq("/dev/null", param_val)) {
	param_val = NULL;
	}
	cl_log_set_logfile(param_val);
	param_val = NULL;
	}

	param_name = ENV_PREFIX "" KEY_DBGFILE;
	param_val = getenv(param_name);
	crm_debug("%s = %s", param_name, param_val);
	if(param_val != NULL) {
	if(safe_str_eq("/dev/null", param_val)) {
	param_val = NULL;
	}
	cl_log_set_debugfile(param_val);
	param_val = NULL;
	}

	param_name = ENV_PREFIX "" KEY_LOGDAEMON;
	param_val = getenv(param_name);
	crm_debug("%s = %s", param_name, param_val);
	if(param_val != NULL) {
	int uselogd;
	cl_str_to_boolean(param_val, &uselogd);
	cl_log_set_uselogd(uselogd);
	if(uselogd) {
	cl_set_logging_wqueue_maxlen(500);
	cl_log_set_logd_channel_source(NULL, NULL);
	}
	param_val = NULL;
	}

	param_name = ENV_PREFIX "" KEY_CONNINTVAL;
	param_val = getenv(param_name);
	crm_debug("%s = %s", param_name, param_val);
	if(param_val != NULL) {
	int logdtime;
	logdtime = crm_get_msec(param_val);
	cl_log_set_logdtime(logdtime);
	param_val = NULL;
	}

	inherit_compress();
	}

	gboolean
	crm_is_true(const char * s)
	{
	gboolean ret = FALSE;
	if(s != NULL) {
	cl_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

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

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

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

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

	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 ret;
	}
	dret = atof(cp);
	dret *= (double)multiplier;
	dret /= (double)divisor;
	dret += 0.5;
	ret = (long)dret;
	return(ret);
	}

	gboolean
	ccm_have_quorum(oc_ed_t event)
	{
	if(event==OC_EV_MS_NEW_MEMBERSHIP) {
	return TRUE;
	}
	return FALSE;
	}


	const char *
	ccm_event_name(oc_ed_t event)
	{

	if(event==OC_EV_MS_NEW_MEMBERSHIP) {
	return "NEW MEMBERSHIP";

	} else if(event==OC_EV_MS_NOT_PRIMARY) {
	return "NOT PRIMARY";

	} else if(event==OC_EV_MS_PRIMARY_RESTORED) {
	return "PRIMARY RESTORED";

	} else if(event==OC_EV_MS_EVICTED) {
	return "EVICTED";

	} else if(event==OC_EV_MS_INVALID) {
	return "INVALID";
	}

	return "NO QUORUM MEMBERSHIP";

	}

	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_CHECK(status >= LRM_OP_PENDING && status <= LRM_OP_CANCELLED,
	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)
	{
	char *rc = NULL;
	char *key = NULL;
	char *magic2 = NULL;
	char *status = NULL;

	if(decodeNVpair(magic, ':', &status, &magic2) == FALSE) {
	crm_err("Couldn't find ':' in: %s", magic);
	return FALSE;
	}

	if(decodeNVpair(magic2, ';', &rc, &key) == FALSE) {
	crm_err("Couldn't find ';' in: %s", magic2);
	return FALSE;
	}


	CRM_CHECK(decode_transition_key(key, uuid, transition_id, action_id),
	return FALSE);

	*op_rc = crm_parse_int(rc, NULL);
	*op_status = crm_parse_int(status, NULL);

	crm_free(rc);
	crm_free(key);
	crm_free(magic2);
	crm_free(status);

	return TRUE;
	}

	char *
	generate_transition_key(int transition_id, int action_id, 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:%s",
	action_id, transition_id, node);
	}
	return fail_state;
	}


	gboolean
	decode_transition_key(
	const char key, char uuid, int transition_id, int *action_id)
	{
	char *tmp = NULL;
	char *action = NULL;
	char *transition = NULL;

	*uuid = NULL;
	*action_id = -1;
	*transition_id = -1;

	if(decodeNVpair(key, ':', &action, &tmp) == FALSE) {
	crm_err("Couldn't find ':' in: %s", key);
	return FALSE;
	}

	*action_id = crm_parse_int(action, NULL);
	crm_free(action);

	if(decodeNVpair(tmp, ':', &transition, uuid) == FALSE) {
	/* this would be an error but some versions dont
	* have the action
	*/
	transition_id = action_id;
	*action_id = -1;
	*uuid = tmp;

	} else {
	*transition_id = crm_parse_int(transition, NULL);
	crm_free(transition);
	crm_free(tmp);
	}
	return TRUE;
	}

	void
	filter_action_parameters(crm_data_t param_set, const char version)
	{
	#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)) {
	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]);
	}

	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) {
	/* remove it */
	xml_remove_prop(param_set, prop_name);
	/* unwind the counetr */
	__counter--;
	}
	);
	}

	void
	filter_reload_parameters(crm_data_t 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) {
	/* remove it */
	crm_debug_3("%s not found in %s",
	prop_name, restart_string);
	xml_remove_prop(param_set, prop_name);
	/* unwind the counetr */
	__counter--;
	}
	crm_free(name);
	);
	}

	gboolean
	crm_mem_stats(volatile cl_mem_stats_t *mem_stats)
	{
	volatile cl_mem_stats_t *active_stats = mem_stats;
	if(active_stats == NULL) {
	active_stats = cl_malloc_getstats();
	}
	CRM_CHECK(active_stats != NULL, ;);
	#ifndef CRM_USE_MALLOC
	if(active_stats->numalloc > active_stats->numfree) {
	crm_warn("Potential memory leak detected:"
	" %lu alloc's vs. %lu free's (%lu)"
	" (%lu bytes not freed: req=%lu, alloc'd=%lu)",
	active_stats->numalloc, active_stats->numfree,
	active_stats->numalloc - active_stats->numfree,
	active_stats->nbytes_alloc, active_stats->nbytes_req,
	active_stats->mallocbytes);
	return TRUE;

	} else if(active_stats->numalloc < active_stats->numfree) {
	crm_debug("Process shrank: %lu alloc's vs. %lu free's (%lu)",
	active_stats->numalloc, active_stats->numfree,
	active_stats->numalloc - active_stats->numfree);
	}
	#endif
	return FALSE;
	}

	void
	crm_zero_mem_stats(volatile cl_mem_stats_t *stats)
	{
	if(stats == NULL) {
	crm_debug("Resetting global memory stats");
	stats = cl_malloc_getstats();
	}
	stats->numalloc = 0;
	stats->numfree = 0;
	stats->numrealloc = 0;
	stats->nbytes_req = 0;
	stats->nbytes_alloc = 0;
	stats->mallocbytes = 0;
	stats->arena = 0;
	}

	void
	crm_save_mem_stats(const char location, cl_mem_stats_t saved_stats)
	{
	volatile cl_mem_stats_t *stats = cl_malloc_getstats();
	if(saved_stats == NULL) {
	return;
	}
	crm_debug_2("Saving memory stats: %s", location);
	saved_stats = stats;
	}

	void
	crm_xml_nbytes(crm_data_t xml, long bytes, long allocs, long frees)
	{
	crm_data_t *xml_copy = NULL;
	volatile cl_mem_stats_t *stats = cl_malloc_getstats();

	if(xml == NULL) {
	*bytes = 0;
	*allocs = 0;
	*frees = 0;
	return;
	}

	*bytes = 0 - stats->nbytes_alloc;
	*allocs = 0 - stats->numalloc;
	*frees = 0 - stats->numfree;

	xml_copy = copy_xml(xml);

	*bytes += stats->nbytes_alloc;
	*allocs += stats->numalloc;
	*frees += stats->numfree;

	crm_debug_3("XML size: %ld bytes, %ld allocs, %ld frees",
	bytes, allocs, *frees);

	free_xml(xml_copy);
	}

	void
	crm_adjust_mem_stats(volatile cl_mem_stats_t *stats, long bytes, long allocs, long frees)
	{
	if(bytes == 0&& allocs == 0 && frees == 0) {
	return;
	}

	if(stats == NULL) {
	stats = cl_malloc_getstats();
	}

	stats->nbytes_alloc -= bytes;
	stats->numalloc -= allocs;
	stats->numfree -= frees;

	crm_debug("Adjusted CIB Memory usage by: %10ld bytes, %5ld allocs, %5ld frees",
	bytes, allocs, frees);
	}

	cl_mem_stats_t *crm_running_stats = NULL;

	gboolean
	crm_diff_mem_stats(int log_level_up, int log_level_down, const char *location,
	volatile cl_mem_stats_t stats, volatile cl_mem_stats_t saved_stats)
	{
	long delta_allocs = 0;
	long delta_frees = 0;
	long delta_bytes = 0;
	long delta_req = 0;

	gboolean increase = TRUE;
	gboolean reset_on_change = (log_level_up == LOG_DEBUG);

	/* long delta_malloc = stats->mallocbytes - saved_stats->mallocbytes; */
	return FALSE;

	if(stats == NULL && saved_stats == NULL) {
	crm_err("Comparision doesnt make sense");
	return FALSE;

	} else if(stats == NULL) {
	stats = cl_malloc_getstats();

	} else if(saved_stats == NULL) {
	saved_stats = cl_malloc_getstats();
	}

	delta_allocs = stats->numalloc - saved_stats->numalloc;
	delta_frees = stats->numfree - saved_stats->numfree;
	delta_bytes = stats->nbytes_alloc - saved_stats->nbytes_alloc;
	delta_req = stats->nbytes_req - saved_stats->nbytes_req;

	if(delta_bytes == 0) {
	crm_debug_2("Memory usage constant at %s: %ld alloc's %ld free's",
	location, delta_allocs, delta_frees);
	return FALSE;
	}

	if(delta_bytes < 0) {
	increase = FALSE;
	reset_on_change = (log_level_down == LOG_DEBUG);
	}

	do_crm_log(increase?log_level_up:log_level_down,
	"Memory usage %s detected at %s:\t"
	" %10ld alloc's vs. %10ld free's (%5ld change"
	" %10ld bytes leaked)",
	increase?"increase":"decrease", location,
	delta_allocs, delta_frees, delta_allocs - delta_frees,
	delta_bytes);

	if(reset_on_change) {
	crm_info("Resetting %s stats", location);
	stats = saved_stats;
	if(crm_running_stats) {
	crm_adjust_mem_stats(crm_running_stats, delta_bytes, delta_allocs, delta_frees);
	}
	}
	return TRUE;
	}

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

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

	} else if(crm_log_level < LOG_DEBUG) {
	do_crm_log(LOG_ERR,
	"%s: Triggered non-fatal assert at %s:%d : %s",
	function, file, line, assert_condition);
	return;

	} else {
	pid=fork();
	}

	switch(pid) {
	case -1:
	crm_err("Cannot fork!");
	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);
	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("%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;
	char *buffer = NULL;
	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;
	}
	buffer = crm_itoa(sequence);

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

	file_strm = fopen(series_file, "w");
	if(file_strm == NULL) {
	crm_err("%s does not exist", series_file);
	crm_free(series_file);
	return;
	}

	rc = fprintf(file_strm, "%s", buffer);
	if(rc < 0) {
	cl_perror("Cannot write output to %s", series_file);
	}

	fflush(file_strm);
	fclose(file_strm);


	crm_free(series_file);
	crm_free(buffer);
	}

	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);
	cl_perror("fork");
	exit(LSB_EXIT_GENERIC);

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

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

	umask(022);
	close(FD_STDIN);
	(void)open(devnull, O_RDONLY); /* Stdin: fd 0 */
	close(FD_STDOUT);
	(void)open(devnull, O_WRONLY); /* Stdout: fd 1 */
	close(FD_STDERR);
	(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;
	}

File Metadata

Mime Type: text/x-diff
Expires: Sat, Jan 25, 11:18 AM (1 d, 11 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1322320
Default Alt Text: (41 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions