21 #include <sys/param.h> 32 unpack_action(
synapse_t * parent, xmlNode * xml_action)
38 crm_err(
"Actions must have an id!");
67 value = g_hash_table_lookup(action->
params,
"CRM_meta_timeout");
73 value = g_hash_table_lookup(action->
params,
"CRM_meta_start_delay");
78 value = g_hash_table_lookup(action->
params,
"CRM_meta_interval");
83 value = g_hash_table_lookup(action->
params,
"CRM_meta_can_fail");
94 unpack_synapse(
crm_graph_t * new_graph, xmlNode * xml_synapse)
96 const char *value = NULL;
97 xmlNode *inputs = NULL;
98 xmlNode *action_set = NULL;
101 CRM_CHECK(xml_synapse != NULL,
return NULL);
102 crm_trace(
"looking in synapse %s",
ID(xml_synapse));
104 new_synapse = calloc(1,
sizeof(
synapse_t));
118 for (action_set = __xml_first_child(xml_synapse); action_set != NULL;
119 action_set = __xml_next(action_set)) {
120 if (
crm_str_eq((
const char *)action_set->name,
"action_set", TRUE)) {
121 xmlNode *action = NULL;
123 for (action = __xml_first_child(action_set); action != NULL;
124 action = __xml_next(action)) {
125 crm_action_t *new_action = unpack_action(new_synapse, action);
129 if (new_action == NULL) {
132 crm_trace(
"Adding action %d to synapse %d", new_action->
id, new_synapse->
id);
134 new_synapse->
actions = g_list_append(new_synapse->
actions, new_action);
139 crm_trace(
"look for inputs in synapse %s",
ID(xml_synapse));
141 for (inputs = __xml_first_child(xml_synapse); inputs != NULL; inputs = __xml_next(inputs)) {
142 if (
crm_str_eq((
const char *)inputs->name,
"inputs", TRUE)) {
143 xmlNode *trigger = NULL;
145 for (trigger = __xml_first_child(inputs); trigger != NULL;
146 trigger = __xml_next(trigger)) {
147 xmlNode *input = NULL;
149 for (input = __xml_first_child(trigger); input != NULL; input = __xml_next(input)) {
150 crm_action_t *new_input = unpack_action(new_synapse, input);
152 if (new_input == NULL) {
156 crm_trace(
"Adding input %d to synapse %d", new_input->
id, new_synapse->
id);
158 new_synapse->
inputs = g_list_append(new_synapse->
inputs, new_input);
181 const char *t_id = NULL;
182 const char *time = NULL;
183 xmlNode *synapse = NULL;
195 new_graph->
source = strdup(reference);
197 new_graph->
source = strdup(
"unknown");
200 if (xml_graph != NULL) {
225 for (synapse = __xml_first_child(xml_graph); synapse != NULL; synapse = __xml_next(synapse)) {
226 if (
crm_str_eq((
const char *)synapse->name,
"synapse", TRUE)) {
227 synapse_t *new_synapse = unpack_synapse(new_graph, synapse);
229 if (new_synapse != NULL) {
235 crm_debug(
"Unpacked transition %d: %d actions in %d synapses",
249 g_hash_table_destroy(action->
params);
259 while (g_list_length(synapse->
actions) > 0) {
263 destroy_action(action);
266 while (g_list_length(synapse->
inputs) > 0) {
269 synapse->
inputs = g_list_remove(synapse->
inputs, action);
270 destroy_action(action);
281 while (g_list_length(graph->
synapses) > 0) {
285 destroy_synapse(synapse);
298 const char *name = NULL;
299 const char *value = NULL;
300 xmlNode *action_resource = NULL;
311 op->
rsc_id = strdup(
ID(action_resource));
317 op->
t_run = time(NULL);
323 g_hash_table_iter_init(&iter, action->
params);
324 while (g_hash_table_iter_next(&iter, (
void **)&name, (
void **)&value)) {
325 g_hash_table_insert(op->
params, strdup(name), strdup(value));
328 for (xop = __xml_first_child(resource); xop != NULL; xop = __xml_next(xop)) {
332 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)
#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_perror(level, fmt, args...)
Log a system error message.
#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)
void g_hash_destroy_str(gpointer data)
lrmd_event_data_t * convert_graph_action(xmlNode *resource, crm_action_t *action, int status, int rc)