21 #include <sys/param.h>
32 unpack_action(
synapse_t * parent, xmlNode * xml_action)
35 xmlNode *action_copy = NULL;
39 crm_err(
"Actions must have an id!");
52 action->
xml = action_copy;
67 value = g_hash_table_lookup(action->
params,
"CRM_meta_timeout");
72 value = g_hash_table_lookup(action->
params,
"CRM_meta_interval");
77 value = g_hash_table_lookup(action->
params,
"CRM_meta_can_fail");
88 unpack_synapse(
crm_graph_t * new_graph, xmlNode * xml_synapse)
90 const char *value = NULL;
91 xmlNode *inputs = NULL;
92 xmlNode *action_set = NULL;
95 CRM_CHECK(xml_synapse != NULL,
return NULL);
96 crm_trace(
"looking in synapse %s",
ID(xml_synapse));
98 new_synapse = calloc(1,
sizeof(
synapse_t));
112 for (action_set = __xml_first_child(xml_synapse); action_set != NULL;
113 action_set = __xml_next(action_set)) {
114 if (
crm_str_eq((
const char *)action_set->name,
"action_set", TRUE)) {
115 xmlNode *action = NULL;
117 for (action = __xml_first_child(action_set); action != NULL;
118 action = __xml_next(action)) {
119 crm_action_t *new_action = unpack_action(new_synapse, action);
123 if (new_action == NULL) {
126 crm_trace(
"Adding action %d to synapse %d", new_action->
id, new_synapse->
id);
128 new_synapse->
actions = g_list_append(new_synapse->
actions, new_action);
133 crm_trace(
"look for inputs in synapse %s",
ID(xml_synapse));
135 for (inputs = __xml_first_child(xml_synapse); inputs != NULL; inputs = __xml_next(inputs)) {
136 if (
crm_str_eq((
const char *)inputs->name,
"inputs", TRUE)) {
137 xmlNode *trigger = NULL;
139 for (trigger = __xml_first_child(inputs); trigger != NULL;
140 trigger = __xml_next(trigger)) {
141 xmlNode *input = NULL;
143 for (input = __xml_first_child(trigger); input != NULL; input = __xml_next(input)) {
144 crm_action_t *new_input = unpack_action(new_synapse, input);
146 if (new_input == NULL) {
150 crm_trace(
"Adding input %d to synapse %d", new_input->
id, new_synapse->
id);
152 new_synapse->
inputs = g_list_append(new_synapse->
inputs, new_input);
175 const char *t_id = NULL;
176 const char *time = NULL;
177 xmlNode *synapse = NULL;
189 new_graph->
source = strdup(reference);
191 new_graph->
source = strdup(
"unknown");
194 if (xml_graph != NULL) {
219 for (synapse = __xml_first_child(xml_graph); synapse != NULL; synapse = __xml_next(synapse)) {
220 if (
crm_str_eq((
const char *)synapse->name,
"synapse", TRUE)) {
221 synapse_t *new_synapse = unpack_synapse(new_graph, synapse);
223 if (new_synapse != NULL) {
229 crm_debug(
"Unpacked transition %d: %d actions in %d synapses",
243 g_hash_table_destroy(action->
params);
253 while (g_list_length(synapse->
actions) > 0) {
257 destroy_action(action);
260 while (g_list_length(synapse->
inputs) > 0) {
263 synapse->
inputs = g_list_remove(synapse->
inputs, action);
264 destroy_action(action);
275 while (g_list_length(graph->
synapses) > 0) {
279 destroy_synapse(synapse);
292 const char *name = NULL;
293 const char *value = NULL;
294 xmlNode *action_resource = NULL;
305 op->
rsc_id = strdup(
ID(action_resource));
311 op->
t_run = time(NULL);
317 g_hash_table_iter_init(&iter, action->
params);
318 while (g_hash_table_iter_next(&iter, (
void **)&name, (
void **)&value)) {
319 g_hash_table_insert(op->
params, strdup(name), strdup(value));
322 for (xop = __xml_first_child(resource); xop != NULL; xop = __xml_next(xop)) {
326 crm_debug(
"Got call_id=%d for %s", tmp,
ID(resource));
#define CRM_CHECK(expr, failure_action)
GHashTable * xml2list(xmlNode *parent)
enum transition_action completion_action
long long crm_get_msec(const char *input)
#define XML_GRAPH_TAG_RSC_OP
int crm_parse_int(const char *text, const char *default_text)
void g_hash_destroy_str(gpointer data)
#define XML_GRAPH_TAG_CRM_EVENT
crm_action_timer_t * timer
#define XML_GRAPH_TAG_PSEUDO_EVENT
#define XML_CIB_ATTR_PRIORITY
xmlNode * copy_xml(xmlNode *src_node)
#define XML_LRM_ATTR_TASK
#define crm_warn(fmt, args...)
#define crm_debug(fmt, args...)
#define XML_CIB_TAG_RESOURCE
#define crm_trace(fmt, args...)
Wrappers for and extensions to libxml2.
#define crm_log_xml_warn(xml, text)
int crm_element_value_int(xmlNode *data, const char *name, int *dest)
const char * crm_element_value(xmlNode *data, const char *name)
crm_graph_t * unpack_graph(xmlNode *xml_graph, const char *reference)
void free_xml(xmlNode *child)
gboolean crm_str_eq(const char *a, const char *b, gboolean use_case)
int crm_str_to_boolean(const char *s, int *ret)
#define crm_err(fmt, args...)
#define XML_LRM_ATTR_CALLID
xmlNode * first_named_child(xmlNode *parent, const char *name)
#define crm_log_xml_trace(xml, text)
CRM_TRACE_INIT_DATA(pe_status)
#define safe_str_eq(a, b)
void destroy_graph(crm_graph_t *graph)
lrmd_event_data_t * convert_graph_action(xmlNode *resource, crm_action_t *action, int status, int rc)