Page MenuHomeClusterLabs Projects
Files F4638859

No OneTemporary
Actions

View Options

diff --git a/crm/common/Makefile.am b/crm/common/Makefile.am
deleted file mode 100644
index 214068e6d2..0000000000
--- a/crm/common/Makefile.am
+++ /dev/null
@@ -1,50 +0,0 @@
-#
-# 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)/libltdl -I$(top_srcdir)/libltdl \
- -I$(top_builddir)/linux-ha -I$(top_srcdir)/linux-ha \
- -I$(top_builddir) -I$(top_srcdir)
-
-AM_CFLAGS = @CFLAGS@ $(CRM_DEBUG_FLAGS)
-
-hadir = $(sysconfdir)/ha.d
-halibdir = $(libdir)/@HB_PKG@
-
-## libraries
-lib_LTLIBRARIES = libcrmcommon.la
-
-
-## binary progs
-halib_PROGRAMS =
-
-
-## SOURCES
-
-noinst_HEADERS =
-
-libcrmcommon_la_SOURCES = ipc.c msg.c utils.c xml.c ctrl.c
-libcrmcommon_la_LDFLAGS = -version-info 0:0:0
-
-clean-generic:
- rm -f *.log *.debug *.xml *~
-
-install-exec-local:
-
-uninstall-local:
diff --git a/crm/common/ctrl.c b/crm/common/ctrl.c
deleted file mode 100644
index 644cba7175..0000000000
--- a/crm/common/ctrl.c
+++ /dev/null
@@ -1,98 +0,0 @@
-/* $Id: ctrl.c,v 1.8 2005/02/19 18:11:03 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 <sys/param.h>
-
-#include <stdio.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <unistd.h>
-
-#include <stdlib.h>
-#include <errno.h>
-#include <fcntl.h>
-
-#include <crm/crm.h>
-#include <crm/msg_xml.h>
-#include <crm/common/ctrl.h>
-
-#include <apphb.h>
-
-#include <clplumbing/cl_log.h>
-#include <clplumbing/Gmain_timeout.h>
-
-#include <crm/dmalloc_wrapper.h>
-
-
-static int wdt_interval_ms = 10000;
-
-
-
-void
-register_with_apphb(const char *client_name,
- gboolean(*tickle_fn)(gpointer data))
-{
- char app_instance[APPNAME_LEN];
- int hb_intvl_ms = wdt_interval_ms * 2;
- int rc = 0;
-
- /* Register with apphb */
- crm_info("Signing in with AppHb");
- sprintf(app_instance, "%s_%ld", client_name, (long)getpid());
-
- crm_info("Client %s registering with apphb", app_instance);
-
- rc = apphb_register(client_name, app_instance);
-
- if (rc < 0) {
- cl_perror("%s registration failure", app_instance);
- exit(1);
- }
-
- crm_devel("Client %s registered with apphb", app_instance);
-
- crm_info("Client %s setting %d ms apphb heartbeat interval",
- app_instance, hb_intvl_ms);
- rc = apphb_setinterval(hb_intvl_ms);
- if (rc < 0) {
- cl_perror("%s setinterval failure", app_instance);
- exit(2);
- }
-
- /* regularly tell apphb that we are alive */
- crm_info("Setting up AppHb Heartbeat");
- Gmain_timeout_add(wdt_interval_ms, tickle_fn, NULL);
-}
-
-
-gboolean
-tickle_apphb_template(gpointer data)
-{
- char app_instance[APPNAME_LEN];
- int rc = 0;
- sprintf(app_instance, "%s_%ld", "our_system_name", (long)getpid());
-
- rc = apphb_hb();
- if (rc < 0) {
- cl_perror("%s apphb_hb failure", app_instance);
-
- exit(3);
- }
- return TRUE;
-}
diff --git a/crm/common/ipc.c b/crm/common/ipc.c
deleted file mode 100644
index 7189eda8e5..0000000000
--- a/crm/common/ipc.c
+++ /dev/null
@@ -1,383 +0,0 @@
-/* $Id: ipc.c,v 1.32 2005/04/11 10:34:11 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 <sys/param.h>
-
-#include <stdio.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <unistd.h>
-
-#include <errno.h>
-#include <fcntl.h>
-
-#include <crm/crm.h>
-
-#include <clplumbing/ipc.h>
-#include <clplumbing/Gmain_timeout.h>
-#include <clplumbing/cl_log.h>
-#include <clplumbing/cl_signal.h>
-#include <clplumbing/lsb_exitcodes.h>
-#include <clplumbing/uids.h>
-#include <clplumbing/realtime.h>
-#include <clplumbing/GSource.h>
-#include <clplumbing/cl_poll.h>
-
-#ifdef USE_LIBXML
-# include <libxml/xmlmemory.h>
-# include <libxml/parser.h>
-# include <libxml/xpath.h>
-#endif
-
-#include <crm/common/ipc.h>
-#include <crm/msg_xml.h>
-#include <ha_msg.h>
-
-
-#include <crm/dmalloc_wrapper.h>
-
-gboolean
-send_ha_message(ll_cluster_t *hb_conn, HA_Message *msg, const char *node)
-{
- gboolean all_is_good = TRUE;
-
- if (msg == NULL) {
- crm_err("cant send NULL message");
- all_is_good = FALSE;
-
- } else if(hb_conn == NULL) {
- crm_err("No heartbeat connection specified");
- all_is_good = FALSE;
-
- } else if(hb_conn->llc_ops->chan_is_connected(hb_conn) != HA_OK) {
- crm_err("Not connected to Heartbeat");
- all_is_good = FALSE;
-
- } else if(node == NULL
- && hb_conn->llc_ops->sendclustermsg(hb_conn, msg) != HA_OK) {
- IPC_Channel *ipc = hb_conn->llc_ops->ipcchan(hb_conn);
- all_is_good = FALSE;
- crm_err("Broadcast Send failed");
- CRM_DEV_ASSERT(ipc->send_queue->current_qlen < ipc->send_queue->max_qlen);
-
- } else if(node != NULL
- && hb_conn->llc_ops->send_ordered_nodemsg(
- hb_conn, msg, node) != HA_OK) {
- IPC_Channel *ipc = hb_conn->llc_ops->ipcchan(hb_conn);
- all_is_good = FALSE;
- crm_err("Send failed");
- CRM_DEV_ASSERT(ipc->send_queue->current_qlen < ipc->send_queue->max_qlen);
- }
-
- crm_log_message_adv(all_is_good?LOG_MSG:LOG_WARNING,"HA[outbound]",msg);
- return all_is_good;
-}
-
-#define ipc_log(fmt...) do_crm_log(server?LOG_WARNING:LOG_ERR, __FUNCTION__, NULL, fmt)
-
-/* frees msg */
-gboolean
-crm_send_ipc_message(IPC_Channel *ipc_client, HA_Message *msg, gboolean server)
-{
- gboolean all_is_good = TRUE;
-
- if (msg == NULL) {
- crm_err("cant send NULL message");
- all_is_good = FALSE;
-
- } else if (ipc_client == NULL) {
- crm_err("cant send message without an IPC Channel");
- all_is_good = FALSE;
-
- } else if(ipc_client->ops->get_chan_status(ipc_client) != IPC_CONNECT) {
- ipc_log("IPC Channel is not connected");
- all_is_good = FALSE;
- }
-
- if(all_is_good && msg2ipcchan(msg, ipc_client) != HA_OK) {
- ipc_log("Could not send IPC, message");
- all_is_good = FALSE;
-
- if(ipc_client->ops->get_chan_status(ipc_client) != IPC_CONNECT) {
- ipc_log("IPC Channel is no longer connected");
-
- } else if(server == FALSE) {
- CRM_DEV_ASSERT(ipc_client->send_queue->current_qlen < ipc_client->send_queue->max_qlen);
- }
- }
-
- crm_log_message_adv(all_is_good?LOG_MSG:LOG_WARNING,"IPC[outbound]",msg);
- crm_msg_del(msg);
-
- return all_is_good;
-}
-
-void
-default_ipc_connection_destroy(gpointer user_data)
-{
- return;
-}
-
-int
-init_server_ipc_comms(
- char *channel_name,
- gboolean (*channel_client_connect)(IPC_Channel *newclient,gpointer user_data),
- void (*channel_connection_destroy)(gpointer user_data))
-{
- /* the clients wait channel is the other source of events.
- * This source delivers the clients connection events.
- * listen to this source at a relatively lower priority.
- */
-
- char commpath[SOCKET_LEN];
- IPC_WaitConnection *wait_ch;
-
- sprintf(commpath, WORKING_DIR "/%s", channel_name);
-
- wait_ch = wait_channel_init(commpath);
-
- if (wait_ch == NULL) {
- return 1;
- }
-
- G_main_add_IPC_WaitConnection(
- G_PRIORITY_LOW, wait_ch, NULL, FALSE,
- channel_client_connect, channel_name,
- channel_connection_destroy);
-
- crm_devel("Listening on: %s", commpath);
-
- return 0;
-}
-
-GCHSource*
-init_client_ipc_comms(const char *channel_name,
- gboolean (*dispatch)(
- IPC_Channel* source_data, gpointer user_data),
- void *client_data, IPC_Channel **ch)
-{
- IPC_Channel *a_ch = NULL;
- GCHSource *the_source = NULL;
- void *callback_data = client_data;
-
- a_ch = init_client_ipc_comms_nodispatch(channel_name);
- if(ch != NULL) {
- *ch = a_ch;
- if(callback_data == NULL) {
- callback_data = a_ch;
- }
- }
-
- if(a_ch == NULL) {
- crm_err("Setup of client connection failed,"
- " not adding channel to mainloop");
-
- return NULL;
- }
-
- if(dispatch == NULL) {
- crm_warn("No dispatch method specified..."
- "maybe you meant init_client_ipc_comms_nodispatch()?");
- } else {
- crm_devel("Adding dispatch method to channel");
-
- the_source = G_main_add_IPC_Channel(
- G_PRIORITY_LOW, a_ch, FALSE, dispatch, callback_data,
- default_ipc_connection_destroy);
- }
-
- return the_source;
-}
-
-IPC_Channel *
-init_client_ipc_comms_nodispatch(const char *channel_name)
-{
- IPC_Channel *ch;
- GHashTable *attrs;
- static char path[] = IPC_PATH_ATTR;
-
- char *commpath = NULL;
- int local_socket_len = 2; /* 2 = '/' + '\0' */
-
-
- local_socket_len += strlen(channel_name);
- local_socket_len += strlen(WORKING_DIR);
-
- crm_malloc(commpath, sizeof(char)*local_socket_len);
- if(commpath != NULL) {
- sprintf(commpath, WORKING_DIR "/%s", channel_name);
- commpath[local_socket_len - 1] = '\0';
- crm_devel("Attempting to talk on: %s", commpath);
- }
-
- attrs = g_hash_table_new(g_str_hash,g_str_equal);
- g_hash_table_insert(attrs, path, commpath);
-
- ch = ipc_channel_constructor(IPC_ANYTYPE, attrs);
- g_hash_table_destroy(attrs);
-
- if (ch == NULL) {
- crm_err("Could not access channel on: %s", commpath);
- return NULL;
-
- } else if (ch->ops->initiate_connection(ch) != IPC_OK) {
- crm_debug("Could not init comms on: %s", commpath);
- return NULL;
- }
-
- ch->ops->set_recv_qlen(ch, 100);
- ch->ops->set_send_qlen(ch, 100);
-/* ch->should_send_block = TRUE; */
-
- crm_devel("Processing of %s complete", commpath);
-
- return ch;
-}
-
-IPC_WaitConnection *
-wait_channel_init(char daemonsocket[])
-{
- IPC_WaitConnection *wait_ch;
- mode_t mask;
- char path[] = IPC_PATH_ATTR;
- GHashTable * attrs;
-
-
- attrs = g_hash_table_new(g_str_hash,g_str_equal);
- g_hash_table_insert(attrs, path, daemonsocket);
-
- mask = umask(0);
- wait_ch = ipc_wait_conn_constructor(IPC_ANYTYPE, attrs);
- if (wait_ch == NULL) {
- cl_perror("Can't create wait channel of type %s",
- IPC_ANYTYPE);
- exit(1);
- }
- mask = umask(mask);
-
- g_hash_table_destroy(attrs);
-
- return wait_ch;
-}
-
-longclock_t ipc_call_start = 0;
-longclock_t ipc_call_stop = 0;
-longclock_t ipc_call_diff = 0;
-int ipc_call_diff_ms = 0;
-
-gboolean
-subsystem_msg_dispatch(IPC_Channel *sender, void *user_data)
-{
- int lpc = 0;
- IPC_Message *msg = NULL;
- ha_msg_input_t *new_input = NULL;
- gboolean all_is_well = TRUE;
- const char *sys_to;
- const char *task;
-
- while(sender->ops->is_message_pending(sender)) {
- gboolean process = FALSE;
- if (sender->ch_status == IPC_DISCONNECT) {
- /* The message which was pending for us is that
- * the IPC status is now IPC_DISCONNECT */
- break;
- }
- if (sender->ops->recv(sender, &msg) != IPC_OK) {
- perror("Receive failure:");
- return !all_is_well;
- }
- if (msg == NULL) {
- crm_err("No message this time");
- continue;
- }
-
- lpc++;
- new_input = new_ipc_msg_input(msg);
- msg->msg_done(msg);
- crm_log_message(LOG_MSG, new_input->msg);
-
- sys_to = cl_get_string(new_input->msg, F_CRM_SYS_TO);
- task = cl_get_string(new_input->msg, F_CRM_TASK);
-
- if(safe_str_eq(task, CRM_OP_HELLO)) {
- process = TRUE;
-
- } else if(sys_to == NULL) {
- crm_err("Value of %s was NULL!!", F_CRM_SYS_TO);
-
- } else if(task == NULL) {
- crm_err("Value of %s was NULL!!", F_CRM_TASK);
-
- } else {
- process = TRUE;
- }
-
- if(process){
- gboolean (*process_function)
- (HA_Message *msg, crm_data_t *data, IPC_Channel *sender) = NULL;
- process_function = user_data;
-#ifdef MSG_LOG
- crm_log_message_adv(
- LOG_MSG, __FUNCTION__, new_input->msg);
-#endif
- if(ipc_call_diff_max_ms > 0) {
- ipc_call_start = time_longclock();
- }
- if(FALSE == process_function(
- new_input->msg, new_input->xml, sender)) {
- crm_warn("Received a message destined for %s"
- " by mistake", sys_to);
- }
- if(ipc_call_diff_max_ms > 0) {
- ipc_call_stop = time_longclock();
- ipc_call_diff = sub_longclock(
- ipc_call_start, ipc_call_stop);
- ipc_call_diff_ms = longclockto_ms(
- ipc_call_diff);
- if(ipc_call_diff_ms > ipc_call_diff_max_ms) {
- crm_err("%s took %dms to complete",
- sys_to, ipc_call_diff_ms);
- }
- }
- } else {
-#ifdef MSG_LOG
- crm_log_message_adv(
- LOG_ERR, NULL, new_input->msg);
-#endif
- }
-
- delete_ha_msg_input(new_input);
- msg = NULL;
- }
-
- /* clean up after a break */
- if(msg != NULL) {
- msg->msg_done(msg);
- }
-
- crm_verbose("Processed %d messages", lpc);
- if (sender->ch_status != IPC_CONNECT) {
- crm_err("The server has left us: Shutting down...NOW");
-
- exit(1); /* shutdown properly later */
-
- return !all_is_well;
- }
- return all_is_well;
-}
-
diff --git a/crm/common/msg.c b/crm/common/msg.c
deleted file mode 100644
index d2479f43ed..0000000000
--- a/crm/common/msg.c
+++ /dev/null
@@ -1,356 +0,0 @@
-/* $Id: msg.c,v 1.15 2005/02/19 18:11:03 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 <sys/param.h>
-#include <stdio.h>
-#include <sys/types.h>
-#include <unistd.h>
-#include <string.h>
-
-#include <stdlib.h>
-
-#include <clplumbing/cl_log.h>
-#include <ha_msg.h>
-
-#include <time.h>
-
-#include <crm/crm.h>
-#include <crm/msg_xml.h>
-#include <crm/common/msg.h>
-#include <crm/common/ipc.h>
-
-#include <crm/dmalloc_wrapper.h>
-
-HA_Message *create_common_message(
- HA_Message *original_request, crm_data_t *xml_response_data);
-
-
-crm_data_t*
-createPingAnswerFragment(const char *from, const char *status)
-{
- crm_data_t *ping = NULL;
-
-
- ping = create_xml_node(NULL, XML_CRM_TAG_PING);
-
- set_xml_property_copy(ping, XML_PING_ATTR_STATUS, status);
- set_xml_property_copy(ping, XML_PING_ATTR_SYSFROM, from);
-
- return ping;
-}
-
-HA_Message *
-validate_crm_message(
- HA_Message *msg, const char *sys, const char *uuid, const char *msg_type)
-{
- const char *from = NULL;
- const char *to = NULL;
- const char *type = NULL;
- const char *crm_msg_reference = NULL;
- HA_Message *action = NULL;
- const char *true_sys;
-
-
- if (msg == NULL) {
- return NULL;
- }
-
- from = cl_get_string(msg, F_CRM_SYS_FROM);
- to = cl_get_string(msg, F_CRM_SYS_TO);
- type = cl_get_string(msg, F_CRM_MSG_TYPE);
-
- crm_msg_reference = cl_get_string(msg, XML_ATTR_REFERENCE);
- action = msg;
- true_sys = sys;
-
- if (uuid != NULL) { true_sys = generate_hash_key(sys, uuid); }
-
- if (to == NULL) {
- crm_info("No sub-system defined.");
- action = NULL;
- } else if (true_sys != NULL && strcmp(to, true_sys) != 0) {
- crm_devel("The message is not for this sub-system (%s != %s).",
- to, true_sys);
- action = NULL;
- }
-
- if (type == NULL) {
- crm_info("No message type defined.");
- return NULL;
- } else if (msg_type != NULL && strcmp(msg_type, type) != 0) {
- crm_info("Expecting a (%s) message but received a (%s).",
- msg_type, type);
- action = NULL;
- }
-
- if (crm_msg_reference == NULL) {
- crm_info("No message crm_msg_reference defined.");
- action = NULL;
- }
-/*
- if(action != NULL)
- crm_devel(
- "XML is valid and node with message type (%s) found.",
- type);
- crm_devel("Returning node (%s)", xmlGetNodePath(action));
-*/
-
- return action;
-}
-
-
-void
-send_hello_message(IPC_Channel *ipc_client,
- const char *uuid,
- const char *client_name,
- const char *major_version,
- const char *minor_version)
-{
- crm_data_t *hello_node = NULL;
- HA_Message *hello = NULL;
- if (uuid == NULL || strlen(uuid) == 0
- || client_name == NULL || strlen(client_name) == 0
- || major_version == NULL || strlen(major_version) == 0
- || minor_version == NULL || strlen(minor_version) == 0) {
- crm_err("Missing fields, Hello message will not be valid.");
- return;
- }
-
- hello_node = create_xml_node(NULL, XML_TAG_OPTIONS);
- set_xml_property_copy(hello_node, "major_version", major_version);
- set_xml_property_copy(hello_node, "minor_version", minor_version);
- set_xml_property_copy(hello_node, "client_name", client_name);
- set_xml_property_copy(hello_node, "client_uuid", uuid);
-
- crm_trace("creating hello message");
- hello = create_request(
- CRM_OP_HELLO, hello_node, NULL, NULL, client_name, uuid);
-
- send_ipc_message(ipc_client, hello);
- crm_trace("hello message sent");
-
- free_xml(hello_node);
-}
-
-
-gboolean
-process_hello_message(crm_data_t *hello,
- char **uuid,
- char **client_name,
- char **major_version,
- char **minor_version)
-{
- const char *local_uuid;
- const char *local_client_name;
- const char *local_major_version;
- const char *local_minor_version;
-
- *uuid = NULL;
- *client_name = NULL;
- *major_version = NULL;
- *minor_version = NULL;
-
- if(hello == NULL) {
- return FALSE;
- }
-
- local_uuid = crm_element_value(hello, "client_uuid");
- local_client_name = crm_element_value(hello, "client_name");
- local_major_version = crm_element_value(hello, "major_version");
- local_minor_version = crm_element_value(hello, "minor_version");
-
- if (local_uuid == NULL || strlen(local_uuid) == 0) {
- crm_err("Hello message was not valid (field %s not found)",
- "uuid");
- return FALSE;
-
- } else if (local_client_name==NULL || strlen(local_client_name)==0){
- crm_err("Hello message was not valid (field %s not found)",
- "client name");
- return FALSE;
-
- } else if(local_major_version == NULL
- || strlen(local_major_version) == 0){
- crm_err("Hello message was not valid (field %s not found)",
- "major version");
- return FALSE;
-
- } else if (local_minor_version == NULL
- || strlen(local_minor_version) == 0){
- crm_err("Hello message was not valid (field %s not found)",
- "minor version");
- return FALSE;
- }
-
- *uuid = crm_strdup(local_uuid);
- *client_name = crm_strdup(local_client_name);
- *major_version = crm_strdup(local_major_version);
- *minor_version = crm_strdup(local_minor_version);
-
- crm_devel("Hello message ok");
- return TRUE;
-}
-
-HA_Message *
-create_request_adv(const char *task, crm_data_t *msg_data,
- const char *host_to, const char *sys_to,
- const char *sys_from, const char *uuid_from,
- const char *origin)
-{
- char *true_from = NULL;
- HA_Message *request = NULL;
- char *reference = generateReference(task, sys_from);
-
- if (uuid_from != NULL) {
- true_from = generate_hash_key(sys_from, uuid_from);
- } else if(sys_from != NULL) {
- true_from = crm_strdup(sys_from);
- } else {
- crm_err("No sys from specified");
- }
-
- /* host_from will get set for us if necessary by CRMd when routed */
- request = ha_msg_new(11);
-
- ha_msg_add(request, F_CRM_ORIGIN, origin);
- ha_msg_add(request, F_TYPE, T_CRM);
- ha_msg_add(request, F_CRM_VERSION, CRM_VERSION);
- ha_msg_add(request, F_CRM_MSG_TYPE, XML_ATTR_REQUEST);
- ha_msg_add(request, XML_ATTR_REFERENCE, reference);
- ha_msg_add(request, F_CRM_TASK, task);
- ha_msg_add(request, F_CRM_SYS_TO, sys_to);
- ha_msg_add(request, F_CRM_SYS_FROM, true_from);
-
- /* HOSTTO will be ignored if it is to the DC anyway. */
- if(host_to != NULL && strlen(host_to) > 0) {
- ha_msg_add(request, F_CRM_HOST_TO, host_to);
- }
-
- if (msg_data != NULL) {
- add_message_xml(request, F_CRM_DATA, msg_data);
- }
- crm_free(reference);
- crm_free(true_from);
-
- return request;
-}
-
-/*
- * This method adds a copy of xml_response_data
- */
-HA_Message *
-create_reply_adv(HA_Message *original_request,
- crm_data_t *xml_response_data, const char *origin)
-{
- HA_Message *reply = NULL;
-
- const char *host_from= cl_get_string(original_request, F_CRM_HOST_FROM);
- const char *sys_from = cl_get_string(original_request, F_CRM_SYS_FROM);
- const char *sys_to = cl_get_string(original_request, F_CRM_SYS_TO);
- const char *type = cl_get_string(original_request, F_CRM_MSG_TYPE);
- const char *operation= cl_get_string(original_request, F_CRM_TASK);
- const char *crm_msg_reference = cl_get_string(
- original_request, XML_ATTR_REFERENCE);
-
- if (type == NULL) {
- crm_err("Cannot create new_message,"
- " no message type in original message");
- return NULL;
-#if 0
- } else if (strcmp(XML_ATTR_REQUEST, type) != 0) {
- crm_err("Cannot create new_message,"
- " original message was not a request");
- return NULL;
-#endif
- }
- reply = ha_msg_new(10);
-
- ha_msg_add(reply, F_CRM_ORIGIN, origin);
- ha_msg_add(reply, F_TYPE, T_CRM);
- ha_msg_add(reply, F_CRM_VERSION, CRM_VERSION);
- ha_msg_add(reply, F_CRM_MSG_TYPE, XML_ATTR_RESPONSE);
- ha_msg_add(reply, XML_ATTR_REFERENCE, crm_msg_reference);
- ha_msg_add(reply, F_CRM_TASK, operation);
-
- /* since this is a reply, we reverse the from and to */
- ha_msg_add(reply, F_CRM_SYS_TO, sys_from);
- ha_msg_add(reply, F_CRM_SYS_FROM, sys_to);
-
- /* HOSTTO will be ignored if it is to the DC anyway. */
- if(host_from != NULL && strlen(host_from) > 0) {
- ha_msg_add(reply, F_CRM_HOST_TO, host_from);
- }
-
- if (xml_response_data != NULL) {
- add_message_xml(reply, F_CRM_DATA, xml_response_data);
- }
-
- return reply;
-}
-
-
-/*
- * This method adds a copy of xml_response_data
- */
-gboolean
-send_ipc_reply(IPC_Channel *ipc_channel,
- HA_Message *request, crm_data_t *xml_response_data)
-{
- gboolean was_sent = FALSE;
- HA_Message *reply = NULL;
-
- reply = create_reply(request, xml_response_data);
-
- if (reply != NULL) {
- was_sent = send_ipc_message(ipc_channel, reply);
- }
- return was_sent;
-}
-
-ha_msg_input_t *
-new_ha_msg_input(const HA_Message *orig)
-{
- ha_msg_input_t *input_copy = NULL;
- crm_malloc(input_copy, sizeof(ha_msg_input_t));
-
- input_copy->msg = ha_msg_copy(orig);
- input_copy->xml = get_message_xml(input_copy->msg, F_CRM_DATA);
- return input_copy;
-}
-
-ha_msg_input_t *
-new_ipc_msg_input(IPC_Message *orig)
-{
- ha_msg_input_t *input_copy = NULL;
-
- crm_malloc(input_copy, sizeof(ha_msg_input_t));
- input_copy->msg = ipcmsg2hamsg(orig);
- input_copy->xml = get_message_xml(input_copy->msg, F_CRM_DATA);
- return input_copy;
-}
-
-void
-delete_ha_msg_input(ha_msg_input_t *orig)
-{
- if(orig == NULL) {
- return;
- }
- crm_msg_del(orig->msg);
- free_xml(orig->xml);
- crm_free(orig);
-}
diff --git a/crm/common/utils.c b/crm/common/utils.c
deleted file mode 100644
index 9c694ab85e..0000000000
--- a/crm/common/utils.c
+++ /dev/null
@@ -1,879 +0,0 @@
-/* $Id: utils.c,v 1.49 2005/04/12 09:27:32 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
- */
-
-#ifndef _GNU_SOURCE
-# define _GNU_SOURCE
-#endif
-
-#include <sys/param.h>
-#include <stdio.h>
-#include <sys/types.h>
-#include <unistd.h>
-#include <string.h>
-
-#include <stdlib.h>
-
-
-#include <heartbeat.h>
-#include <ha_msg.h>
-#include <clplumbing/cl_log.h>
-#include <clplumbing/cl_signal.h>
-#include <clplumbing/coredumps.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;
-
-void crm_set_env_options(void);
-int crm_logfacility_from_name(const char * 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_malloc(since_epoch, reference_len*(sizeof(char)));
-
- 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_trace("Attempting to decode: [%s]", srcstring);
- if (srcstring != NULL) {
- len = strlen(srcstring);
- while(lpc <= len) {
- if (srcstring[lpc] == separator
- || srcstring[lpc] == '\0') {
- crm_malloc(*name, sizeof(char)*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_malloc(*value, sizeof(char)*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++;
- }
- }
-
- *name = NULL;
- *value = NULL;
-
- return FALSE;
-}
-
-char *
-generate_hash_key(const char *crm_msg_reference, const char *sys)
-{
- int ref_len = strlen(sys?sys:"none") + strlen(crm_msg_reference) + 2;
- char *hash_key = NULL;
- crm_malloc(hash_key, sizeof(char)*(ref_len));
-
- if(hash_key != NULL) {
- sprintf(hash_key, "%s_%s", sys?sys:"none", crm_msg_reference);
- hash_key[ref_len-1] = '\0';
- crm_devel("created hash key: (%s)", hash_key);
- }
- return hash_key;
-}
-
-char *
-generate_hash_value(const char *src_node, const char *src_subsys)
-{
- int ref_len;
- char *hash_value;
-
- if (src_node == NULL || src_subsys == NULL) {
- return NULL;
- }
-
- if (strcmp(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 NULL;
- }
- return hash_value;
- }
-
- ref_len = strlen(src_subsys) + strlen(src_node) + 2;
- crm_malloc(hash_value, sizeof(char)*(ref_len));
- if (!hash_value) {
- crm_err("memory allocation failed in "
- "generate_hash_value()");
- return NULL;
- }
-
- snprintf(hash_value, ref_len-1, "%s_%s", src_node, src_subsys);
- hash_value[ref_len-1] = '\0';/* make sure it is null terminated */
-
- 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_info("Decoding hash value: (%s:%d)", char_value, value_len);
-
- if (strcmp(CRM_SYSTEM_DC, (char*)value) == 0) {
- *node = NULL;
- *subsys = (char*)crm_strdup(char_value);
- if (*subsys == NULL) {
- crm_err("memory allocation failed in "
- "decode_hash_value()");
- return FALSE;
- }
- crm_info("Decoded value: (%s:%d)", *subsys,
- (int)strlen(*subsys));
- return TRUE;
-
- } else if (char_value != NULL) {
- if (decodeNVpair(char_value, '_', node, subsys)) {
- return TRUE;
- } else {
- *node = NULL;
- *subsys = NULL;
- return FALSE;
- }
- }
- return FALSE;
-}
-
-
-char *
-crm_itoa(int an_int)
-{
- int len = 32;
- char *buffer = NULL;
-
- crm_malloc(buffer, sizeof(char)*(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();
-
- cl_log_set_logd_channel_source(NULL, NULL);
- 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 < level) {
- alter_debug(DEBUG_INC);
- }
- while(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, NULL, NULL, "#========= %s message start ==========#", prefix?prefix:"");
- if(level > LOG_DEBUG) {
- cl_log_message(LOG_DEBUG, msg);
- } else {
- cl_log_message(level, msg);
- }
- }
-}
-
-
-void
-do_crm_log(int log_level, const char *function,
- const char *alt_debugfile, const char *fmt, ...)
-{
- int log_as = log_level;
- gboolean do_log = FALSE;
- if(log_level <= (int)crm_log_level) {
- do_log = TRUE;
- if(log_level > LOG_INFO) {
- log_as = LOG_DEBUG;
- }
- }
-
- if(do_log) {
- va_list ap;
- char *buf = NULL;
- int nbytes;
-
- va_start(ap, fmt);
- nbytes=vasprintf(&buf, fmt, ap);
- va_end(ap);
-
- log_level -= LOG_INFO;
- if(log_level > 1) {
- if(function == NULL) {
- cl_log(log_as, "[%d] %s", log_level, buf);
-
- } else {
- cl_log(log_as, "fn(%s [%d]): %s",
- function, log_level, buf);
- }
-
- } else {
- if(function == NULL) {
- cl_log(log_as, "%s", buf);
-
- } else {
- cl_log(log_as, "fn(%s): %s", function, buf);
- }
- }
-
- if(nbytes > MAXLINE) {
- cl_log(LOG_WARNING, "Log from %s() was truncated",
- crm_str(function));
- }
- free(buf);
- }
-}
-
-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;
- }
-
- if(version1 != NULL) {
- rest1 = crm_strdup(version1);
- } else {
- version1 = "<null>";
- }
- if(version2 != NULL) {
- rest2 = crm_strdup(version2);
- } else {
- version2 = "<null>";
- }
-
- 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 = atoi(step1);
- }
- if(step2 != NULL) {
- step2_i = atoi(step2);
- }
-
- if(step1_i < step2_i){
- cmp = -1;
- } else if (step1_i > step2_i){
- cmp = 1;
- }
-
- crm_trace("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_verbose("%s < %s", version1, version2);
- return -1;
-
- } else if(cmp > 0) {
- crm_verbose("%s > %s", version1, version2);
- return 1;
- }
- }
- crm_verbose("%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:
- crm_log_level++;
- crm_debug("Upped log level to %d", crm_log_level);
- break;
-
- case DEBUG_DEC:
- crm_log_level--;
- crm_debug("Reduced log level to %d", 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);
-}
-
-gboolean
-safe_str_eq(const char *a, const char *b)
-{
- if(a == b) {
- return TRUE;
- } else if(a == NULL || b == NULL) {
- return FALSE;
- } else if(strcmp(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(strcmp(a, b) == 0) {
- return FALSE;
- }
- return TRUE;
-}
-
-char *
-crm_strdup(const char *a)
-{
- char *ret = NULL;
- CRM_DEV_ASSERT(a != NULL);
- if(a != NULL) {
- ret = cl_strdup(a);
- } else {
- crm_warn("Cannot dup NULL string");
- }
- return ret;
-}
-
-static GHashTable *crm_uuid_cache = NULL;
-
-void
-set_uuid(ll_cluster_t *hb,crm_data_t *node,const char *attr,const char *uname)
-{
-#if 1
- char *uuid_calc = NULL;
-
- 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_DEV_ASSERT(uname != NULL);
-
- /* avoid blocking calls where possible */
- uuid_calc = g_hash_table_lookup(crm_uuid_cache, uname);
- if(uuid_calc != NULL) {
- set_xml_property_copy(node, attr, uuid_calc);
- return;
- }
-
- crm_malloc(uuid_calc, sizeof(char)*50);
-
- if(uuid_calc != NULL) {
- uuid_t uuid_raw;
- if(hb->llc_ops->get_uuid_by_name(
- hb, uname, uuid_raw) == HA_FAIL) {
- crm_err("Could not calculate UUID for %s", uname);
- crm_free(uuid_calc);
- uuid_calc = crm_strdup(uname);
-
- } else {
- uuid_unparse(uuid_raw, uuid_calc);
- g_hash_table_insert(
- crm_uuid_cache,
- crm_strdup(uname), crm_strdup(uuid_calc));
- }
- set_xml_property_copy(node, attr, uuid_calc);
- }
-
- crm_free(uuid_calc);
-#else
- set_xml_property_copy(node, attr, uname);
-#endif
-}/*memory leak*/ /* BEAM BUG - this is not a memory leak */
-
-extern int use_logging_daemon;
-extern int conn_logd_intval;
-
-void
-crm_set_ha_options(ll_cluster_t *hb_cluster)
-{
-#if 0
- int facility;
- char *param_val = NULL;
- const char *param_name = NULL;
-
- if(hb_cluster == NULL) {
- crm_set_env_options();
- return;
- }
-
- /* change the logging facility to the one used by heartbeat daemon */
- crm_debug("Switching to Heartbeat logger");
- if (( facility =
- hb_cluster->llc_ops->get_logfacility(hb_cluster)) > 0) {
- cl_log_set_facility(facility);
- }
- crm_verbose("Facility: %d", facility);
-
- param_name = KEY_LOGFILE;
- param_val = hb_cluster->llc_ops->get_parameter(hb_cluster, param_name);
- crm_devel("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- cl_log_set_logfile(param_val);
- cl_free(param_val);
- param_val = NULL;
- }
-
- param_name = KEY_DBGFILE;
- param_val = hb_cluster->llc_ops->get_parameter(hb_cluster, param_name);
- crm_devel("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- cl_log_set_debugfile(param_val);
- cl_free(param_val);
- param_val = NULL;
- }
-
- param_name = KEY_DEBUGLEVEL;
- param_val = hb_cluster->llc_ops->get_parameter(hb_cluster, param_name);
- crm_devel("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- int debug_level = atoi(param_val);
- if(debug_level > 0 && (debug_level+LOG_INFO) > (int)crm_log_level) {
- set_crm_log_level(LOG_INFO + debug_level);
- }
- cl_free(param_val);
- param_val = NULL;
- }
-
- param_name = KEY_LOGDAEMON;
- param_val = hb_cluster->llc_ops->get_parameter(hb_cluster, param_name);
- crm_devel("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- crm_str_to_boolean(param_val, &use_logging_daemon);
- if(use_logging_daemon) {
- cl_set_logging_wqueue_maxlen(500);
- }
- cl_free(param_val);
- param_val = NULL;
- }
-
- param_name = KEY_CONNINTVAL;
- param_val = hb_cluster->llc_ops->get_parameter(hb_cluster, param_name);
- crm_devel("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- conn_logd_intval = crm_get_msec(param_val);
- cl_free(param_val);
- param_val = NULL;
- }
-#endif
-}
-
-
-#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);
- crm_debug("%s = %s", param_name, param_val);
- if(param_val != NULL) {
- int debug_level = atoi(param_val);
- if(debug_level > 0 && (debug_level+LOG_INFO) > (int)crm_log_level) {
- set_crm_log_level(LOG_INFO + debug_level);
- }
- 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 = crm_logfacility_from_name(param_val);
- 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) {
- crm_str_to_boolean(param_val, &use_logging_daemon);
- if(use_logging_daemon) {
- cl_set_logging_wqueue_maxlen(500);
- }
- 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) {
- conn_logd_intval = crm_get_msec(param_val);
- param_val = NULL;
- }
-
-}
-
-struct _syslog_code {
- const char *c_name;
- int c_val;
-};
-
-
-struct _syslog_code facilitynames[] =
-{
-#ifdef LOG_AUTH
- { "auth", LOG_AUTH },
- { "security", LOG_AUTH }, /* DEPRECATED */
-#endif
-#ifdef LOG_AUTHPRIV
- { "authpriv", LOG_AUTHPRIV },
-#endif
-#ifdef LOG_CRON
- { "cron", LOG_CRON },
-#endif
-#ifdef LOG_DAEMON
- { "daemon", LOG_DAEMON },
-#endif
-#ifdef LOG_FTP
- { "ftp", LOG_FTP },
-#endif
-#ifdef LOG_KERN
- { "kern", LOG_KERN },
-#endif
-#ifdef LOG_LPR
- { "lpr", LOG_LPR },
-#endif
-#ifdef LOG_MAIL
- { "mail", LOG_MAIL },
-#endif
-
-/* { "mark", INTERNAL_MARK }, * INTERNAL */
-
-#ifdef LOG_NEWS
- { "news", LOG_NEWS },
-#endif
-#ifdef LOG_SYSLOG
- { "syslog", LOG_SYSLOG },
-#endif
-#ifdef LOG_USER
- { "user", LOG_USER },
-#endif
-#ifdef LOG_UUCP
- { "uucp", LOG_UUCP },
-#endif
-#ifdef LOG_LOCAL0
- { "local0", LOG_LOCAL0 },
-#endif
-#ifdef LOG_LOCAL1
- { "local1", LOG_LOCAL1 },
-#endif
-#ifdef LOG_LOCAL2
- { "local2", LOG_LOCAL2 },
-#endif
-#ifdef LOG_LOCAL3
- { "local3", LOG_LOCAL3 },
-#endif
-#ifdef LOG_LOCAL4
- { "local4", LOG_LOCAL4 },
-#endif
-#ifdef LOG_LOCAL5
- { "local5", LOG_LOCAL5 },
-#endif
-#ifdef LOG_LOCAL6
- { "local6", LOG_LOCAL6 },
-#endif
-#ifdef LOG_LOCAL7
- { "local7", LOG_LOCAL7 },
-#endif
- { NULL, -1 }
-};
-
-/* set syslog facility config variable */
-int
-crm_logfacility_from_name(const char * value)
-{
- int lpc;
- for(lpc = 0; facilitynames[lpc].c_name != NULL; lpc++) {
- if(strcmp(value, facilitynames[lpc].c_name) == 0) {
- return facilitynames[lpc].c_val;
- }
- }
- return -1;
-}
-
-gboolean
-crm_is_true(const char * s)
-{
- gboolean ret = FALSE;
- 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
-
-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 (*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);
-}
diff --git a/crm/common/xml.c b/crm/common/xml.c
deleted file mode 100644
index e30493e117..0000000000
--- a/crm/common/xml.c
+++ /dev/null
@@ -1,1654 +0,0 @@
-/* $Id: xml.c,v 1.45 2005/03/15 11:45:52 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 <sys/param.h>
-#include <stdio.h>
-#include <sys/types.h>
-#include <unistd.h>
-#include <time.h>
-#include <string.h>
-
-#include <stdlib.h>
-#include <errno.h>
-#include <fcntl.h>
-
-#include <clplumbing/ipc.h>
-#include <clplumbing/cl_log.h>
-
-#include <crm/crm.h>
-#include <crm/msg_xml.h>
-#include <crm/common/xml.h>
-#include <crm/dmalloc_wrapper.h>
-
-
-void dump_array(
- int log_level, const char *message, const char **array, int depth);
-
-int print_spaces(char *buffer, int spaces);
-
-int log_data_element(
- const char *function, int log_level, int depth, crm_data_t *data, gboolean formatted);
-
-int dump_data_element(
- int depth, char **buffer, crm_data_t *data, gboolean formatted);
-
-#ifndef USE_LIBXML
-
-crm_data_t *parse_xml(const char *input, int *offset);
-int get_tag_name(const char *input);
-int get_attr_name(const char *input);
-int get_attr_value(const char *input);
-
-#endif
-
-crm_data_t *
-find_xml_node(crm_data_t *root, const char * search_path, gboolean must_find)
-{
- if(must_find || root != NULL) {
- crm_validate_data(root);
- }
-
- if(search_path == NULL) {
- crm_warn("Will never find <NULL>");
- return NULL;
- }
-
- xml_child_iter(
- root, a_child, search_path,
-/* crm_insane("returning node (%s).", xmlGetNodePath(a_child)); */
- crm_xml_insane(a_child, "contents\t%s");
- crm_xml_insane(root, "found in\t%s");
- crm_validate_data(a_child);
- return a_child;
- );
-
- if(must_find) {
- crm_warn("Could not find %s in %s.", search_path, xmlGetNodePath(root));
- } else if(root != NULL) {
- crm_devel("Could not find %s in %s.", search_path, xmlGetNodePath(root));
- } else {
- crm_devel("Could not find %s in <NULL>.", search_path);
- }
-
-
- return NULL;
-}
-
-crm_data_t*
-find_xml_node_nested(crm_data_t *root, const char **search_path, int len)
-{
- int j;
- gboolean is_found = TRUE;
- crm_data_t *match = NULL;
- crm_data_t *lastMatch = root;
-
- crm_validate_data(root);
-
- if(search_path == NULL || search_path[0] == NULL) {
- crm_warn("Will never find NULL");
- return NULL;
- }
-
- dump_array(LOG_INSANE, "Looking for.", search_path, len);
-
- for (j=0; j < len; ++j) {
- if (search_path[j] == NULL) {
-/* a NULL also means stop searching */
- break;
- }
-
- match = find_xml_node(lastMatch, search_path[j], FALSE);
- if(match == NULL) {
- is_found = FALSE;
- break;
- } else {
- lastMatch = match;
- }
- }
-
- if (is_found) {
- crm_insane("returning node (%s).",
- xmlGetNodePath(lastMatch));
-
- crm_xml_insane(lastMatch, "found\t%s");
- crm_xml_insane(root, "in \t%s");
-
- crm_validate_data(lastMatch);
- return lastMatch;
- }
-
- dump_array(LOG_WARNING,
- "Could not find the full path to the node you specified.",
- search_path, len);
-
- crm_warn("Closest point was node (%s) starting from %s.",
- xmlGetNodePath(lastMatch), crm_element_name(root));
-
- return NULL;
-
-}
-
-
-
-const char *
-get_xml_attr_nested(crm_data_t *parent,
- const char **node_path, int length,
- const char *attr_name, gboolean error)
-{
- const char *attr_value = NULL;
- crm_data_t *attr_parent = NULL;
-
- if(error || parent != NULL) {
- crm_validate_data(parent);
- }
-
- if(parent == NULL) {
- crm_devel("Can not find attribute %s in NULL parent",attr_name);
- return NULL;
- }
-
- if(attr_name == NULL || strlen(attr_name) == 0) {
- crm_err("Can not find attribute with no name in %s",
- xmlGetNodePath(parent));
- return NULL;
- }
-
- if(length == 0) {
- attr_parent = parent;
-
- } else {
- attr_parent = find_xml_node_nested(parent, node_path, length);
- if(attr_parent == NULL && error) {
- crm_err("No node at the path you specified.");
- return NULL;
- }
- }
-
- attr_value = crm_element_value(attr_parent, attr_name);
- if((attr_value == NULL || strlen(attr_value) == 0) && error) {
- crm_err(
- "No value present for %s at %s",
- attr_name, xmlGetNodePath(attr_parent));
- return NULL;
- }
-
- return attr_value;
-}
-
-
-crm_data_t*
-find_entity(crm_data_t *parent,
- const char *node_name,
- const char *id,
- gboolean siblings)
-{
- crm_validate_data(parent);
- xml_child_iter(
- parent, a_child, node_name,
- if(id == NULL
- || safe_str_eq(id,crm_element_value(a_child,XML_ATTR_ID))){
- crm_devel("returning node (%s).",
- xmlGetNodePath(a_child));
- return a_child;
- }
- );
- if(siblings) {
- abort();
- }
-
-
- crm_debug("node <%s id=%s> not found in %s.",
- node_name, id, xmlGetNodePath(parent));
- return NULL;
-}
-
-void
-copy_in_properties(crm_data_t* target, crm_data_t *src)
-{
- crm_validate_data(src);
- crm_validate_data(target);
- if(src == NULL) {
- crm_warn("No node to copy properties from");
- } else if (target == NULL) {
- crm_err("No node to copy properties into");
- } else {
- xml_prop_iter(
- src, local_prop_name, local_prop_value,
- set_xml_property_copy(
- target, local_prop_name, local_prop_value);
- );
- crm_validate_data(target);
- }
-
- return;
-}
-
-crm_data_t*
-add_node_copy(crm_data_t *new_parent, crm_data_t *xml_node)
-{
- crm_data_t *node_copy = NULL;
-
- crm_validate_data(new_parent);
- crm_validate_data(xml_node);
-
- if(xml_node != NULL && new_parent != NULL) {
-#ifdef USE_LIBXML
- node_copy = copy_xml_node_recursive(xml_node);
- xmlAddChild(new_parent, node_copy);
-#else
- const char *name = crm_element_name(xml_node);
- CRM_DEV_ASSERT(HA_OK == ha_msg_addstruct(
- new_parent, name, xml_node));
-
- node_copy = find_entity(new_parent, crm_element_name(xml_node), ID(xml_node), FALSE);
- crm_validate_data(node_copy);
- crm_update_parents(new_parent);
- crm_validate_data(new_parent);
-#endif
-
- } else if(xml_node == NULL) {
- crm_err("Could not add copy of NULL node");
-
- } else {
- crm_err("Could not add copy of node to NULL parent");
- }
-
- crm_validate_data(node_copy);
- return node_copy;
-}
-
-const char *
-set_xml_property_copy(crm_data_t* node, const char *name, const char *value)
-{
- const char *parent_name = NULL;
-
- if(node != NULL) {
- parent_name = crm_element_name(node);
- }
-
- crm_insane("[%s] Setting %s to %s", crm_str(parent_name), name, value);
-
- if (name == NULL || strlen(name) <= 0) {
-
- } else if(node == NULL) {
-
- } else if(parent_name == NULL && strcmp(name, F_XML_TAGNAME) != 0) {
-
- } else if (value == NULL || strlen(value) <= 0) {
- xml_remove_prop(node, name);
- return NULL;
-
- } else {
-#ifdef USE_LIBXML
- const char *local_name = NULL;
- const char *local_value = NULL;
- local_value = crm_strdup(value);
- local_name = crm_strdup(name);
- xmlUnsetProp(node, local_name);
- xmlSetProp(node, local_name, local_value);
- return xmlGetProp(node, local_name);
-#else
- crm_validate_data(node);
- ha_msg_mod(node, name, value);
- return crm_element_value(node, name);
-#endif
- }
-
- return NULL;
-}
-
-crm_data_t*
-create_xml_node(crm_data_t *parent, const char *name)
-{
- const char *local_name = NULL;
- const char *parent_name = NULL;
- crm_data_t *ret_value = NULL;
-
-
- if (name == NULL || strlen(name) < 1) {
- ret_value = NULL;
- } else {
-#ifdef USE_LIBXML
- local_name = crm_strdup(name);
-
- if(parent == NULL)
- ret_value = xmlNewNode(NULL, local_name);
- else {
- parent_name = parent->name;
- ret_value =
- xmlNewChild(parent, NULL, local_name, NULL);
- }
-#else
- local_name = name;
- ret_value = ha_msg_new(1);
- CRM_DEV_ASSERT(ret_value != NULL);
-
- set_xml_property_copy(ret_value, F_XML_TAGNAME, name);
- crm_validate_data(ret_value);
- if(parent) {
- crm_validate_data(parent);
- parent_name = crm_element_name(parent);
- crm_insane("Attaching %s to parent %s",
- local_name, parent_name);
- CRM_DEV_ASSERT(HA_OK == ha_msg_addstruct(
- parent, name, ret_value));
- crm_msg_del(ret_value);
-
- crm_update_parents(parent);
- crm_validate_data(parent);
- ret_value = parent->values[parent->nfields-1];
- crm_validate_data(ret_value);
- }
-#endif
- }
-
- crm_insane("Created node [%s [%s]]",
- crm_str(parent_name), crm_str(local_name));
-/* set_node_tstamp(ret_value); */
- return ret_value;
-}
-
-void
-free_xml_from_parent(crm_data_t *parent, crm_data_t *a_node)
-{
- CRM_DEV_ASSERT(parent != NULL);
- if(parent == NULL) {
- return;
- } else if(a_node == NULL) {
- return;
- }
- crm_validate_data(parent);
-#ifdef USE_LIBXML
- xmlUnlinkNode(a_node);
- node->doc = NULL;
- free_xml_fn(a_node);
-#else
- cl_msg_remove_value(parent, a_node);
-#endif
- crm_validate_data(parent);
-}
-
-
-void
-free_xml_fn(crm_data_t *a_node)
-{
- if(a_node == NULL) {
- ; /* nothing to do */
-#ifdef USE_LIBXML
- } else if (a_node->doc != NULL) {
- xmlFreeDoc(a_node->doc);
- } else {
- /* make sure the node is unlinked first */
- xmlUnlinkNode(a_node);
- xmlFreeNode(a_node);
-#else
- } else {
- int has_parent = 0;
- crm_validate_data(a_node);
- ha_msg_value_int(a_node, F_XML_PARENT, &has_parent);
-
- /* there is no way in hell we should be deleting anything
- * with a parent and without the parent knowning
- */
- CRM_DEV_ASSERT(has_parent == 0);
- if(has_parent == 0) {
- crm_validate_data(a_node);
- crm_msg_del(a_node);
- }
-#endif
- }
-
- return;
-}
-
-void
-set_node_tstamp(crm_data_t *a_node)
-{
- char *since_epoch = NULL;
- time_t a_time = time(NULL);
-
- crm_validate_data(a_node);
-
- if(a_time == (time_t)-1) {
- cl_perror("set_node_tstamp(): Invalid time returned");
- return;
- }
-
- crm_malloc(since_epoch, 128*(sizeof(char)));
- if(since_epoch != NULL) {
- sprintf(since_epoch, "%ld", (unsigned long)a_time);
-#ifdef USE_LIBXML
- xmlUnsetProp(a_node, XML_ATTR_TSTAMP);
- xmlSetProp(a_node, XML_ATTR_TSTAMP, since_epoch);
-#else
- ha_msg_mod(a_node, XML_ATTR_TSTAMP, since_epoch);
- crm_validate_data(a_node);
- crm_free(since_epoch);
-#endif
- }
-}
-
-crm_data_t*
-copy_xml_node_recursive(crm_data_t *src_node)
-{
- crm_data_t *new_xml = NULL;
-
-#ifdef USE_LIBXML
-# if 1
- return xmlCopyNode(src_node, 1);
-# else
- xmlNodePtr local_node = NULL, local_child = NULL;
-
- if(src_node == NULL || src_node->name == NULL) {
- return NULL;
- }
-
- local_node = create_xml_node(NULL, src_node->name);
-
- copy_in_properties(local_node, src_node);
-
- xml_child_iter(
- src_node, node_iter, NULL,
- local_child = copy_xml_node_recursive(node_iter);
- if(local_child != NULL) {
- xmlAddChild(local_node, local_child);
- crm_insane("Copied node [%s [%s]",
- local_node->name, local_child->name);
- }
- );
-
- crm_insane("Returning [%s]", local_node->name);
- return local_node;
-# endif
-#else
- CRM_DEV_ASSERT(src_node != NULL);
- CRM_DEV_ASSERT(crm_element_name(src_node) != NULL);
-
- if(src_node == NULL) {
- crm_warn("Attempt to dup NULL XML");
- return NULL;
-
- } else if(crm_element_name(src_node) == NULL) {
- crm_xml_err(src_node, "Attempt to dup XML with no name");
- return NULL;
- }
-
- crm_validate_data(src_node);
- new_xml = ha_msg_copy(src_node);
- crm_set_element_parent(new_xml, NULL);
- crm_update_parents(new_xml);
- crm_validate_data(new_xml);
-#endif
- return new_xml;
-}
-
-
-crm_data_t*
-string2xml(const char *input)
-{
-#ifdef USE_LIBXML
- int lpc = 0;
- char ch = 0;
- int input_len = 0;
- gboolean more = TRUE;
- gboolean inTag = FALSE;
- crm_data_t *xml_object = NULL;
- const char *the_xml;
- xmlDocPtr doc;
- xmlBufferPtr xml_buffer = NULL;
-
- if(input == NULL || (input_len = strlen(input)) < 0) {
- return NULL;
- }
-
- xml_buffer = xmlBufferCreate();
-
- for(lpc = 0; (lpc < input_len) && more; lpc++) {
- ch = input[lpc];
- switch(ch) {
- case EOF:
- case 0:
- ch = 0;
- more = FALSE;
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- case '>':
- case '<':
- inTag = TRUE;
- if(ch == '>') inTag = FALSE;
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- case '\n':
- case '\t':
- case ' ':
- ch = ' ';
- if(inTag) {
- xmlBufferAdd(xml_buffer, &ch, 1);
- }
- break;
- default:
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- }
- }
-
-
- xmlInitParser();
- the_xml = xmlBufferContent(xml_buffer);
- doc = xmlParseMemory(the_xml, strlen(the_xml));
- xmlCleanupParser();
-
- if (doc == NULL) {
- crm_err("Malformed XML [xml=%s]", the_xml);
- xmlBufferFree(xml_buffer);
- return NULL;
- }
-
- xmlBufferFree(xml_buffer);
- xml_object = xmlDocGetRootElement(doc);
-
- return xml_object;
-#else
- crm_data_t *output = parse_xml(input, NULL);
- if(output != NULL) {
- crm_update_parents(output);
- crm_validate_data(output);
- }
- return output;
-#endif
-}
-
-crm_data_t *
-stdin2xml(void)
-{
-#ifdef USE_LIBXML
- return file2xml(stdin);
-#else
- int lpc = 0;
- int MAX_XML_BUFFER = 20000;
-
- char ch = 0;
- gboolean more = TRUE;
- gboolean inTag = FALSE;
- FILE *input = stdin;
-
- char *xml_buffer = NULL;
- crm_data_t *xml_obj = NULL;
-
- crm_malloc(xml_buffer, sizeof(char)*(MAX_XML_BUFFER+1));
-
- while (more && lpc < MAX_XML_BUFFER) {
- ch = fgetc(input);
-/* crm_devel("Got [%c]", ch); */
- switch(ch) {
- case EOF:
- case 0:
- ch = 0;
- more = FALSE;
- xml_buffer[lpc++] = ch;
- break;
- case '>':
- case '<':
- inTag = TRUE;
- if(ch == '>') { inTag = FALSE; }
- xml_buffer[lpc++] = ch;
- break;
- case '\n':
- case '\t':
- case ' ':
- ch = ' ';
- if(inTag) {
- xml_buffer[lpc++] = ch;
- }
- break;
- default:
- xml_buffer[lpc++] = ch;
- break;
- }
- }
-
- xml_buffer[MAX_XML_BUFFER] = 0;
- xml_obj = string2xml(xml_buffer);
- crm_free(xml_buffer);
-
- crm_xml_devel(xml_obj, "Created fragment");
- return xml_obj;
-#endif
-}
-
-
-crm_data_t*
-file2xml(FILE *input)
-{
-
-#ifdef USE_LIBXML
- char ch = 0;
- gboolean more = TRUE;
- gboolean inTag = FALSE;
- crm_data_t *xml_object = NULL;
- xmlBufferPtr xml_buffer = xmlBufferCreate();
- const char *the_xml;
- xmlDocPtr doc;
-
- if(input == NULL) {
- crm_err("File pointer was NULL");
- return NULL;
- }
-
- while (more) {
- ch = fgetc(input);
-/* crm_devel("Got [%c]", ch); */
- switch(ch) {
- case EOF:
- case 0:
- ch = 0;
- more = FALSE;
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- case '>':
- case '<':
- inTag = TRUE;
- if(ch == '>') inTag = FALSE;
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- case '\n':
- case '\t':
- case ' ':
- ch = ' ';
- if(inTag) {
- xmlBufferAdd(xml_buffer, &ch, 1);
- }
- break;
- default:
- xmlBufferAdd(xml_buffer, &ch, 1);
- break;
- }
- }
-
- xmlInitParser();
- the_xml = xmlBufferContent(xml_buffer);
- doc = xmlParseMemory(the_xml, strlen(the_xml));
- xmlCleanupParser();
-
- if (doc == NULL) {
- crm_err("Malformed XML [xml=%s]", the_xml);
- xmlBufferFree(xml_buffer);
- return NULL;
- }
- xmlBufferFree(xml_buffer);
- xml_object = xmlDocGetRootElement(doc);
-
- crm_xml_devel(xml_object, "Created fragment");
-
- return xml_object;
-#else
- char *buffer = NULL;
- crm_data_t *new_obj = NULL;
- int start = 0, length = 0, read_len = 0;
-
- /* see how big the file is */
- start = ftell(input);
- fseek(input, 0L, SEEK_END);
- length = ftell(input);
- fseek(input, 0L, start);
-
- if(start != ftell(input)) {
- crm_err("fseek not behaving");
- return NULL;
- }
-
- crm_devel("Reading %d bytes from file", length);
- crm_malloc(buffer, sizeof(char) * (length+1));
- read_len = fread(buffer, sizeof(char), length, input);
- if(read_len != length) {
- crm_err("Calculated and read bytes differ: %d vs. %d",
- length, read_len);
- } else if(length > 0) {
- new_obj = string2xml(buffer);
- } else {
- crm_warn("File contained no XML");
- }
-
- crm_free(buffer);
- return new_obj;
-#endif
-}
-
-void
-dump_array(int log_level, const char *message, const char **array, int depth)
-{
- int j;
-
- if(message != NULL) {
- do_crm_log(log_level, __FUNCTION__, NULL, "%s", message);
- }
-
- do_crm_log(log_level, __FUNCTION__, NULL, "Contents of the array:");
- if(array == NULL || array[0] == NULL || depth == 0) {
- do_crm_log(log_level, __FUNCTION__, NULL, "\t<empty>");
- return;
- }
-
- for (j=0; j < depth && array[j] != NULL; j++) {
- if (array[j] == NULL) { break; }
- do_crm_log(log_level, __FUNCTION__, NULL, "\t--> (%s).", array[j]);
- }
-}
-
-int
-write_xml_file(crm_data_t *xml_node, const char *filename)
-{
- int res = 0;
- char now_str[30];
- time_t now;
-
- crm_devel("Writing XML out to %s", filename);
- crm_validate_data(xml_node);
- if (xml_node == NULL) {
- return -1;
- }
-
- crm_validate_data(xml_node);
- crm_xml_trace(xml_node, "Writing out");
- crm_validate_data(xml_node);
-
- now = time(NULL);
- ctime_r(&now, now_str);
- now_str[24] = EOS; /* replace the newline */
- set_xml_property_copy(xml_node, "last_written", now_str);
- crm_validate_data(xml_node);
-
-#ifdef USE_LIBXML
- if (xml_node->doc == NULL) {
- xmlDocPtr foo = NULL;
- crm_insane("Creating doc pointer for %s", xml_node->name);
- foo = xmlNewDoc("1.0");
- xmlDocSetRootElement(foo, xml_node);
- xmlSetTreeDoc(xml_node, foo);
- }
-
- /* save it.
- * set arg 3 to 0 to disable line breaks,1 to enable
- * res == num bytes saved
- */
- res = xmlSaveFormatFile(filename, xml_node->doc, 1);
- /* for some reason, reading back after saving with
- * line-breaks doesnt go real well
- */
-#else
- {
- FILE *file_output_strm = fopen(filename, "w");
- char *buffer = dump_xml_formatted(xml_node);
- CRM_DEV_ASSERT(buffer != NULL && strlen(buffer) > 0);
- if(file_output_strm == NULL) {
- res = -1;
- crm_err("Cannot write to %s", filename);
-
- } else if(buffer != NULL && strlen(buffer) > 0) {
- res = fprintf(file_output_strm, "%s", buffer);
- }
- if(file_output_strm != NULL) {
- fflush(file_output_strm);
- fclose(file_output_strm);
- }
-
- crm_free(buffer);
- }
-#endif
- crm_devel("Saved %d bytes to the Cib as XML", res);
-
- return res;
-}
-
-void
-print_xml_formatted(int log_level, const char *function,
- crm_data_t *msg, const char *text)
-{
- if(msg == NULL) {
- do_crm_log(log_level, function, NULL, "%s: %s",
- crm_str(text), "<null>");
- return;
- }
-
- crm_validate_data(msg);
- do_crm_log(log_level, function, NULL, "%s:",
- crm_str(text));
- log_data_element(function, log_level, 0, msg, TRUE);
- return;
-}
-
-crm_data_t *
-get_message_xml(const HA_Message *msg, const char *field)
-{
- crm_data_t *xml_node = NULL;
-#ifdef USE_LIBXML
- const char *xml_text = cl_get_string(msg, field);
- xml_node = string2xml(xml_text);
-#else
- crm_data_t *tmp_node = NULL;
- crm_validate_data(msg);
- tmp_node = cl_get_struct(msg, field);
- if(tmp_node != NULL) {
- xml_node = copy_xml_node_recursive(tmp_node);
- }
-#endif
- return xml_node;
-}
-
-gboolean
-add_message_xml(HA_Message *msg, const char *field, crm_data_t *xml)
-{
- crm_validate_data(xml);
-#ifdef USE_LIBXML
- char *buffer = dump_xml_unformatted(xml);
- CRM_DEV_ASSERT(buffer != NULL);
- if(buffer != NULL) {
- CRM_DEV_ASSERT(cl_is_allocated(buffer));
- ha_msg_add(msg, field, buffer);
- crm_devel("Added XML to message");
- CRM_DEV_ASSERT(cl_is_allocated(buffer));
- crm_free(buffer);
- }
-#else
- crm_validate_data(msg);
- ha_msg_addstruct(msg, field, xml);
- crm_update_parents(msg);
-#endif
- return TRUE;
-}
-
-
-char *
-dump_xml_formatted(crm_data_t *an_xml_node)
-{
- char *buffer = NULL;
-#if 0
- int len = 0;
- xmlChar *xml_buffer = NULL;
- xmlDocPtr foo = NULL;
-
- crm_data_t* xml_node = NULL;
-
- xml_node = copy_xml_node_recursive(an_xml_node);
-
- if (xml_node == NULL) {
- return NULL;
-
- } else {
- /* reset the doc pointer */
- crm_insane("Creating doc pointer for %s", xml_node->name);
- foo = xmlNewDoc("1.0");
- xmlDocSetRootElement(foo, xml_node);
- xmlSetTreeDoc(xml_node, foo);
- crm_insane("Doc pointer set for %s", xml_node->name);
- }
-
- crm_insane("Initializing Parser");
- xmlInitParser();
- crm_insane("Dumping data");
- xmlDocDumpFormatMemory(xml_node->doc, &xml_buffer, &len, 1);
- crm_insane("Cleaning up parser");
- xmlCleanupParser();
-
- crm_insane("Copying memory into crm_ space");
- if(xml_buffer != NULL && len > 0) {
- /* copy the text into crm_ memory */
- buffer = crm_strdup(xml_buffer);
- xmlFree(xml_buffer);
- }
- crm_insane("Buffer coppied");
-
- free_xml(xml_node);
-#else
- char *mutable_ptr = NULL;
-/* crm_malloc(buffer, 2*(an_xml_node->stringlen)); */
- crm_malloc(buffer, sizeof(char)*30000);
- mutable_ptr = buffer;
-
- crm_validate_data(an_xml_node);
- CRM_DEV_ASSERT(dump_data_element(
- 0, &mutable_ptr, an_xml_node, TRUE) >= 0);
- if(crm_assert_failed) {
- crm_crit("Could not dump the whole message");
- }
- crm_trace("Dumped: %s", buffer);
-#endif
- return buffer;
-}
-
-char *
-dump_xml_unformatted(crm_data_t *an_xml_node)
-{
- char *buffer = NULL;
-#if 0
- int lpc = 0;
- int len = 0;
- xmlChar *xml_buffer = NULL;
- xmlDocPtr foo = NULL;
-
- crm_data_t* xml_node = NULL;
-
- xml_node = copy_xml_node_recursive(an_xml_node);
-
- if (xml_node == NULL) {
- return NULL;
-
- } else {
- /* reset the doc pointer */
- crm_insane("Creating doc pointer for %s", xml_node->name);
- foo = xmlNewDoc("1.0");
- xmlDocSetRootElement(foo, xml_node);
- xmlSetTreeDoc(xml_node, foo);
- crm_insane("Doc pointer set for %s", xml_node->name);
- }
-
- crm_insane("Initializing Parser");
- xmlInitParser();
- crm_insane("Dumping data");
- xmlDocDumpFormatMemory(xml_node->doc, &xml_buffer, &len, 0);
- crm_insane("Cleaning up parser");
- xmlCleanupParser();
-
- crm_insane("Copying memory into crm_ space");
- if(xml_buffer != NULL && len > 0) {
- /* copy the text into crm_ memory */
- buffer = crm_strdup(xml_buffer);
- xmlFree(xml_buffer);
- }
- crm_insane("Buffer coppied");
-
- free_xml(xml_node);
-
- /* remove <?xml version="1.0"?> and the newline */
-/* for(lpc = 0; lpc < len; lpc++) { */
-/* if(buffer[lpc] == '\n') { */
-/* buffer[lpc] = ' '; */
-/* break; */
-/* } else { */
-/* buffer[lpc] = ' '; */
-/* } */
-/* } */
-/* for(lpc = len - 2; lpc > 0 && lpc < len; lpc++) { */
- for(lpc = 0; lpc < len; lpc++) {
- if(buffer[lpc] == '\n') {
- crm_devel("Reset newline at %d", lpc);
- buffer[lpc] = ' ';
- }
- }
- crm_devel("Processed %d chars for newlines", lpc);
-#else
- char *mutable_ptr = NULL;
-/* crm_malloc(buffer, 2*(an_xml_node->stringlen)); */
- crm_malloc(buffer, sizeof(char)*20000);
- mutable_ptr = buffer;
-
- crm_validate_data(an_xml_node);
- CRM_DEV_ASSERT(dump_data_element(
- 0, &mutable_ptr, an_xml_node, TRUE) >= 0);
- if(crm_assert_failed) {
- crm_crit("Could not dump the whole message");
- }
-
- crm_trace("Dumped: %s", buffer);
-#endif
- return buffer;
-}
-
-#define update_buffer_head(buffer, len) if(len < 0) { \
- (*buffer) = EOS; return -1; \
- } else { \
- buffer += len; \
- }
-
-
-int
-print_spaces(char *buffer, int depth)
-{
- int lpc = 0;
- int spaces = 2*depth;
- /* <= so that we always print 1 space - prevents problems with syslog */
- for(lpc = 0; lpc <= spaces; lpc++) {
- if(sprintf(buffer, "%c", ' ') < 1) {
- return -1;
- }
- buffer += 1;
- }
- return lpc;
-}
-
-int
-log_data_element(
- const char *function, int log_level, int depth,
- crm_data_t *data, gboolean formatted)
-{
- int printed = 0;
- int child_result = 0;
- int has_children = 0;
- char print_buffer[1000];
- char *buffer = print_buffer;
- const char *name = crm_element_name(data);
-
- crm_insane("Dumping %s...", name);
- crm_validate_data(data);
- if(data == NULL) {
- crm_warn("No data to dump as XML");
- return 0;
-
- } else if(name == NULL && depth == 0) {
- xml_child_iter(
- data, a_child, NULL,
- child_result = log_data_element(
- function, log_level, depth, a_child, formatted);
- if(child_result < 0) {
- return child_result;
- }
- );
- return 0;
-
- } else if(name == NULL) {
- crm_err("Cannot dump NULL element at depth %d", depth);
- return -1;
- }
-
- if(formatted) {
- printed = print_spaces(buffer, depth);
- update_buffer_head(buffer, printed);
- }
-
- printed = sprintf(buffer, "<%s", name);
- update_buffer_head(buffer, printed);
-
- xml_prop_iter(
- data, prop_name, prop_value,
-
- if(safe_str_eq(F_XML_TAGNAME, prop_name)) {
- continue;
- } else if(safe_str_eq(F_XML_PARENT, prop_name)) {
- continue;
- }
-
- crm_insane("Dumping <%s %s=\"%s\"...",
- name, prop_name, prop_value);
- printed = sprintf(buffer, " %s=\"%s\"", prop_name, prop_value);
- update_buffer_head(buffer, printed);
- );
-
- xml_child_iter(
- data, child, NULL,
- if(child != NULL) {
- has_children++;
- break;
- }
- );
-
- printed = sprintf(buffer, "%s>", has_children==0?"/":"");
- update_buffer_head(buffer, printed);
- do_crm_log(log_level, function, NULL, "%s", print_buffer);
- buffer = print_buffer;
-
- if(has_children == 0) {
- return 0;
- }
-
- xml_child_iter(
- data, a_child, NULL,
- child_result = log_data_element(
- function, log_level, depth+1, a_child, formatted);
-
- if(child_result < 0) { return -1; }
- );
-
- if(formatted) {
- printed = print_spaces(buffer, depth);
- update_buffer_head(buffer, printed);
- }
- do_crm_log(log_level, function, NULL, "%s</%s>",
- print_buffer, name);
- crm_insane("Dumped %s...", name);
-
- return has_children;
-}
-
-
-int
-dump_data_element(
- int depth, char **buffer, crm_data_t *data, gboolean formatted)
-{
- int printed = 0;
- int child_result = 0;
- int has_children = 0;
- const char *name = crm_element_name(data);
-
- crm_insane("Dumping %s...", name);
- crm_validate_data(data);
- if(buffer == NULL || *buffer == NULL) {
- crm_err("No buffer supplied to dump XML into");
- return -1;
-
- } else if(data == NULL) {
- crm_warn("No data to dump as XML");
- (*buffer)[0] = EOS;
- return 0;
-
- } else if(name == NULL && depth == 0) {
- xml_child_iter(
- data, a_child, NULL,
- child_result = dump_data_element(
- depth, buffer, a_child, formatted);
- if(child_result < 0) {
- return child_result;
- }
- );
- return 0;
-
- } else if(name == NULL) {
- crm_err("Cannot dump NULL element at depth %d", depth);
- return -1;
- }
-
- if(formatted) {
- printed = print_spaces(*buffer, depth);
- update_buffer_head(*buffer, printed);
- }
-
- printed = sprintf(*buffer, "<%s", name);
- update_buffer_head(*buffer, printed);
-
- xml_prop_iter(data, prop_name, prop_value,
- if(safe_str_eq(F_XML_TAGNAME, prop_name)) {
- continue;
- } else if(safe_str_eq(F_XML_PARENT, prop_name)) {
- continue;
- }
- crm_insane("Dumping <%s %s=\"%s\"...",
- name, prop_name, prop_value);
- printed = sprintf(*buffer, " %s=\"%s\"", prop_name, prop_value);
- update_buffer_head(*buffer, printed);
- );
-
- xml_child_iter(
- data, child, NULL,
- if(child != NULL) {
- has_children++;
- break;
- }
- );
-
- printed = sprintf(*buffer, "%s>%s",
- has_children==0?"/":"", formatted?"\n":"");
- update_buffer_head(*buffer, printed);
-
- if(has_children == 0) {
- return 0;
- }
-
- xml_child_iter(
- data, child, NULL,
- child_result = dump_data_element(
- depth+1, buffer, child, formatted);
-
- if(child_result < 0) { return -1; }
- );
-
- if(formatted) {
- printed = print_spaces(*buffer, depth);
- update_buffer_head(*buffer, printed);
- }
- printed = sprintf(*buffer, "</%s>%s", name, formatted?"\n":"");
- update_buffer_head(*buffer, printed);
- crm_insane("Dumped %s...", name);
-
- return has_children;
-}
-
-gboolean
-xml_has_children(crm_data_t *xml_root)
-{
- crm_validate_data(xml_root);
-
-#ifdef USE_LIBXML
- if(xml_root != NULL && xml_root->children != NULL) {
- return TRUE;
- }
-#else
- xml_child_iter(
- xml_root, a_child, NULL,
- return TRUE;
- );
-#endif
- return FALSE;
-}
-
-
-void
-crm_validate_data(const crm_data_t *xml_root)
-{
-#ifdef USE_LIBXML
- CRM_DEV_ASSERT(xml_root != NULL);
-#else
-# ifndef XML_PARANOIA_CHECKS
- CRM_DEV_ASSERT(xml_root != NULL);
-# else
- int lpc = 0;
- CRM_ASSERT(xml_root != NULL);
- CRM_ASSERT(cl_is_allocated(xml_root) == 1);
- CRM_ASSERT(xml_root->nfields < 500);
-
- for (lpc = 0; lpc < xml_root->nfields; lpc++) {
- void *child = xml_root->values[lpc];
- CRM_ASSERT(cl_is_allocated(xml_root->names[lpc]) == 1);
-
- if(child == NULL) {
-
- } else if(xml_root->types[lpc] == FT_STRUCT) {
- crm_validate_data(child);
-
- } else if(xml_root->types[lpc] == FT_STRING) {
- CRM_ASSERT(cl_is_allocated(child) == 1);
-/* } else { */
-/* CRM_DEV_ASSERT(FALSE); */
- }
- }
-# endif
-#endif
-}
-
-
-/* FIXME!! This whole function is evil!! */
-void
-crm_set_element_parent(crm_data_t *data, crm_data_t *parent)
-{
-#ifdef USE_LIBXML
- CRM_DEV_ASSERT(FALSE/* not implemented*/);
-#else
- crm_validate_data(data);
- if(parent != NULL) {
- ha_msg_mod_int(data, F_XML_PARENT, 1);
-
- } else {
- ha_msg_mod_int(data, F_XML_PARENT, 0);
- }
-#endif
-}
-
-const char *
-crm_element_value(crm_data_t *data, const char *name)
-{
-#ifdef USE_LIBXML
- return xmlGetProp(data, name);
-#else
- const char *value = NULL;
- crm_validate_data(data);
- value = cl_get_string(data, name);
- if(value != NULL) {
- cl_is_allocated(value);
- }
- return value;
-#endif
-}
-
-char *
-crm_element_value_copy(crm_data_t *data, const char *name)
-{
- const char *value = NULL;
- char *value_copy = NULL;
-#ifdef USE_LIBXML
- value = xmlGetProp(data, name);
-#else
- crm_validate_data(data);
- value = cl_get_string(data, name);
- if(value != NULL) {
- cl_is_allocated(value);
- }
-#endif
- CRM_DEV_ASSERT(value != NULL);
- if(value != NULL) {
- value_copy = crm_strdup(value);
- }
- return value_copy;
-}
-
-const char *
-crm_element_name(crm_data_t *data)
-{
-#ifdef USE_LIBXML
- return (data ? data->name : NULL);
-#else
- crm_validate_data(data);
- return cl_get_string(data, F_XML_TAGNAME);
-#endif
-}
-
-void
-xml_remove_prop(crm_data_t *obj, const char *name)
-{
-#ifdef USE_LIBXML
- xmlUnsetProp(obj, name);
-#else
- if(crm_element_value(obj, name) != NULL) {
- cl_msg_remove(obj, name);
- }
-#endif
-}
-
-void
-crm_update_parents(crm_data_t *xml_root)
-{
-#ifndef USE_LIBXML
- crm_validate_data(xml_root);
- xml_child_iter(
- xml_root, a_child, NULL,
- crm_set_element_parent(a_child, xml_root);
- crm_update_parents(a_child);
- );
-#endif
-}
-
-
-#ifndef USE_LIBXML
-
-int
-get_tag_name(const char *input)
-{
- int lpc = 0;
- char ch = 0;
- const char *error = NULL;
- gboolean do_special = FALSE;
-
- for(lpc = 0; error == NULL && lpc < (ssize_t)strlen(input); lpc++) {
- ch = input[lpc];
- crm_insane("Processing char %c [%d]", ch, lpc);
-
- switch(ch) {
- case EOF:
- case 0:
- error = "unexpected EOS";
- break;
- case '?':
- if(lpc == 0) {
- /* weird xml tag that we dont care about */
- do_special = TRUE;
- } else {
- return lpc;
- }
- break;
- case '/':
- case '>':
- case '\t':
- case '\n':
- case ' ':
- if(!do_special) {
- return lpc;
- }
- break;
- default:
- if(do_special) {
-
- } else if('a' <= ch && ch <= 'z') {
- } else if('A' <= ch && ch <= 'Z') {
- } else if(ch == '_') {
- } else {
- error = "bad character, not in [a-zA-Z_]";
- }
- break;
- }
- }
- crm_err("Error parsing token near %.15s: %s", input, crm_str(error));
- return -1;
-}
-
-int
-get_attr_name(const char *input)
-{
- int lpc = 0;
- char ch = 0;
- const char *error = NULL;
-
- for(lpc = 0; error == NULL && lpc < (ssize_t)strlen(input); lpc++) {
- ch = input[lpc];
- crm_insane("Processing char %c[%d]", ch, lpc);
-
- switch(ch) {
- case EOF:
- case 0:
- error = "unexpected EOS";
- break;
- case '\t':
- case '\n':
- case ' ':
- error = "unexpected whitespace";
- break;
- case '=':
- return lpc;
- default:
- if('a' <= ch && ch <= 'z') {
- } else if('A' <= ch && ch <= 'Z') {
- } else if(ch == '_') {
- } else {
- error = "bad character, not in [a-zA-Z_]";
- }
- break;
- }
- }
- crm_err("Error parsing token near %.15s: %s", input, crm_str(error));
- return -1;
-}
-
-int
-get_attr_value(const char *input)
-{
- int lpc = 0;
- char ch = 0;
- const char *error = NULL;
-
- for(lpc = 0; error == NULL && lpc < (ssize_t)strlen(input); lpc++) {
- ch = input[lpc];
- crm_insane("Processing char %c [%d]", ch, lpc);
-
- switch(ch) {
- case EOF:
- case 0:
- error = "unexpected EOS";
- break;
- case '\\':
- if(input[lpc+1] == '"') {
- /* skip over the next char */
- lpc++;
- break;
- }
- /*fall through*/
- case '"':
- return lpc;
- default:
- break;
- }
- }
- crm_err("Error parsing token near %.15s: %s", input, crm_str(error));
- return -1;
-}
-
-
-crm_data_t*
-parse_xml(const char *input, int *offset)
-{
- int len = 0, lpc = 0;
- char ch = 0;
- char *tag_name = NULL;
- char *attr_name = NULL;
- char *attr_value = NULL;
- gboolean more = TRUE;
- const char *error = NULL;
- const char *our_input = input;
- crm_data_t *new_obj = NULL;
-
- if(offset != NULL) {
- our_input = input + (*offset);
- }
-
- len = strlen(our_input);
- while(lpc < len) {
- if(our_input[lpc] != '<') {
-
- } else if(our_input[lpc+1] == '!') {
- crm_err("XML Comments are not supported");
- crm_insane("Skipping char %c", our_input[lpc]);
- lpc++;
-
- } else if(our_input[lpc+1] == '?') {
- crm_insane("Skipping char %c", our_input[lpc]);
- lpc++;
- } else {
- lpc++;
- our_input += lpc;
- break;
- }
- crm_insane("Skipping char %c", our_input[lpc]);
- lpc++;
- }
-
- len = get_tag_name(our_input);
- if(len < 0) {
- return NULL;
- }
- crm_malloc(tag_name, len+1);
- strncpy(tag_name, our_input, len+1);
- tag_name[len] = EOS;
- crm_devel("Processing tag %s", tag_name);
-
- new_obj = ha_msg_new(1);
- CRM_DEV_ASSERT(cl_is_allocated(new_obj) == 1);
-
- ha_msg_add(new_obj, F_XML_TAGNAME, tag_name);
- lpc = len;
-
- for(; more && error == NULL && lpc < (ssize_t)strlen(input); lpc++) {
- ch = our_input[lpc];
- crm_insane("Processing char %c[%d]", ch, lpc);
- switch(ch) {
- case EOF:
- case 0:
- error = "unexpected EOS";
- break;
- case '/':
- if(our_input[lpc+1] == '>') {
- more = FALSE;
- }
- break;
- case '<':
- if(our_input[lpc+1] != '/') {
- crm_data_t *child = NULL;
- crm_devel("Start parsing child...");
- child = parse_xml(our_input, &lpc);
- if(child == NULL) {
- error = "error parsing child";
- } else {
- CRM_DEV_ASSERT(cl_is_allocated(child) == 1);
- ha_msg_addstruct(
- new_obj, crm_element_name(child), child);
- crm_devel("Finished parsing child: %s",
- crm_element_name(child));
-/* lpc++; /\* > *\/ */
- }
-
- } else {
- lpc += 2; /* </ */
- len = get_tag_name(our_input+lpc);
- if(len < 0) {
- error = "couldnt find tag";
- } else if(strncmp(our_input+lpc, tag_name, len) == 0) {
- more = FALSE;
- lpc += len;
-/* lpc++; /\* > *\/ */
- if(our_input[lpc] != '>') {
- error = "clase tag cannot contain attrs";
- }
- crm_devel("Finished parsing ourselves: %s",
- crm_element_name(new_obj));
-
- } else {
- error = "Mismatching close tag";
- crm_err("Expected: %s", tag_name);
- }
- }
- break;
- case '=':
- lpc++; /* = */
- /*fall through*/
- case '"':
- lpc++; /* " */
- len = get_attr_value(our_input+lpc);
- if(len < 0) {
- error = "couldnt find attr_value";
- } else {
- crm_malloc(attr_value, len+1);
- strncpy(attr_value, our_input+lpc, len+1);
- attr_value[len] = EOS;
- lpc += len;
-/* lpc++; /\* " *\/ */
-
- crm_devel("creating nvpair: <%s %s=\"%s\"...",
- tag_name,
- crm_str(attr_name),
- crm_str(attr_value));
-
- ha_msg_add(new_obj, attr_name, attr_value);
- crm_free(attr_name);
- crm_free(attr_value);
- }
- break;
- case '>':
- case ' ':
- case '\t':
- case '\n':
- break;
- default:
- len = get_attr_name(our_input+lpc);
- if(len < 0) {
- error = "couldnt find attr_name";
- } else {
- crm_malloc(attr_name, len+1);
- strncpy(attr_name, our_input+lpc, len+1);
- attr_name[len] = EOS;
- lpc += len;
- crm_trace("found attr name: %s", attr_name);
- lpc--; /* make sure the '=' is seen next time around */
- }
- break;
- }
- }
-
- if(error) {
- crm_err("Error parsing token: %s", error);
- crm_err("Error at or before: %s", our_input+lpc-3);
- return NULL;
- }
-
- crm_devel("Finished processing %s tag", tag_name);
- crm_free(tag_name);
- if(offset != NULL) {
- (*offset) += lpc;
- }
-
- CRM_DEV_ASSERT(cl_is_allocated(new_obj) == 1);
- return new_obj;
-}
-
-
-#endif
-

File Metadata

Mime Type
text/x-diff
Expires
Thu, Jul 10, 1:34 AM (1 d, 25 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2009520
Default Alt Text
(80 KB)

Event Timeline