graph 41 crmd/te_actions.c te_start_action_timer(crm_graph_t * graph, crm_action_t * action) graph 47 crmd/te_actions.c action->timer->source_id = g_timeout_add(action->timer->timeout + graph->network_delay, graph 54 crmd/te_actions.c te_pseudo_action(crm_graph_t * graph, crm_action_t * pseudo) graph 86 crmd/te_actions.c update_graph(graph, pseudo); graph 161 crmd/te_actions.c te_fence_node(crm_graph_t * graph, crm_action_t * action) graph 221 crmd/te_actions.c te_crm_command(crm_graph_t * graph, crm_action_t * action) graph 265 crmd/te_actions.c graph->completion_action = tg_shutdown; graph 266 crmd/te_actions.c graph->abort_reason = "local shutdown"; graph 268 crmd/te_actions.c update_graph(graph, action); graph 293 crmd/te_actions.c update_graph(graph, action); graph 299 crmd/te_actions.c action->id, task, on_node, action->timeout, graph->network_delay); graph 300 crmd/te_actions.c action->timeout = graph->network_delay; graph 302 crmd/te_actions.c te_start_action_timer(graph, action); graph 401 crmd/te_actions.c te_rsc_command(crm_graph_t * graph, crm_action_t * action) graph 508 crmd/te_actions.c action->id, task, task_uuid, on_node, action->timeout, graph->network_delay); graph 509 crmd/te_actions.c action->timeout = graph->network_delay; graph 512 crmd/te_actions.c te_start_action_timer(graph, action); graph 606 crmd/te_actions.c te_should_perform_action_on(crm_graph_t * graph, crm_action_t * action, const char *target) graph 635 crmd/te_actions.c } else if(graph->migration_limit > 0 && r->migrate_jobs >= graph->migration_limit) { graph 638 crmd/te_actions.c target, graph->migration_limit, r->migrate_jobs, id); graph 649 crmd/te_actions.c te_should_perform_action(crm_graph_t * graph, crm_action_t * action) graph 669 crmd/te_actions.c if(te_should_perform_action_on(graph, action, target) == FALSE) { graph 679 crmd/te_actions.c return te_should_perform_action_on(graph, action, target); graph 703 crmd/te_actions.c notify_crmd(crm_graph_t * graph) graph 710 crmd/te_actions.c CRM_CHECK(graph->complete, graph->complete = TRUE); graph 712 crmd/te_actions.c switch (graph->completion_action) { graph 752 crmd/te_actions.c crm_debug("Transition %d status: %s - %s", graph->id, type, crm_str(graph->abort_reason)); graph 754 crmd/te_actions.c graph->abort_reason = NULL; graph 755 crmd/te_actions.c graph->completion_action = tg_done; graph 35 crmd/te_events.c fail_incompletable_actions(crm_graph_t * graph, const char *down_node) graph 45 crmd/te_events.c if (graph == NULL || graph->complete) { graph 49 crmd/te_events.c gIter = graph->synapses; graph 86 crmd/te_events.c update_graph(graph, action); graph 127 crmd/te_utils.c fail_incompletable_stonith(crm_graph_t * graph) graph 133 crmd/te_utils.c if (graph == NULL) { graph 137 crmd/te_utils.c for (lpc = graph->synapses; lpc != NULL; lpc = lpc->next) { graph 156 crmd/te_utils.c update_graph(graph, action); graph 40 crmd/tengine.h extern gboolean fail_incompletable_actions(crm_graph_t * graph, const char *down_node); graph 57 crmd/tengine.h extern void notify_crmd(crm_graph_t * graph); graph 126 include/crm/pengine/status.h xmlNode *graph; graph 121 include/crm/transition.h gboolean(*pseudo) (crm_graph_t * graph, crm_action_t * action); graph 122 include/crm/transition.h gboolean(*rsc) (crm_graph_t * graph, crm_action_t * action); graph 123 include/crm/transition.h gboolean(*crmd) (crm_graph_t * graph, crm_action_t * action); graph 124 include/crm/transition.h gboolean(*stonith) (crm_graph_t * graph, crm_action_t * action); graph 125 include/crm/transition.h gboolean(*allowed) (crm_graph_t * graph, crm_action_t * action); graph 141 include/crm/transition.h int run_graph(crm_graph_t * graph); graph 142 include/crm/transition.h gboolean update_graph(crm_graph_t * graph, crm_action_t * action); graph 143 include/crm/transition.h void destroy_graph(crm_graph_t * graph); graph 145 include/crm/transition.h void print_graph(unsigned int log_level, crm_graph_t * graph); graph 147 include/crm/transition.h bool update_abort_priority(crm_graph_t * graph, int priority, graph 218 lib/pengine/status.c free_xml(data_set->graph); graph 102 lib/transition/graph.c update_graph(crm_graph_t * graph, crm_action_t * action) graph 108 lib/transition/graph.c for (lpc = graph->synapses; lpc != NULL; lpc = lpc->next) { graph 131 lib/transition/graph.c should_fire_synapse(crm_graph_t * graph, synapse_t * synapse) graph 162 lib/transition/graph.c } else if (synapse->priority < graph->abort_priority) { graph 163 lib/transition/graph.c crm_trace("Skipping synapse %d: abort level %d", synapse->id, graph->abort_priority); graph 164 lib/transition/graph.c graph->skipped++; graph 167 lib/transition/graph.c } else if(graph_fns->allowed && graph_fns->allowed(graph, a) == FALSE) { graph 177 lib/transition/graph.c initiate_action(crm_graph_t * graph, crm_action_t * action) graph 189 lib/transition/graph.c return graph_fns->pseudo(graph, action); graph 193 lib/transition/graph.c return graph_fns->rsc(graph, action); graph 203 lib/transition/graph.c return graph_fns->stonith(graph, action); graph 207 lib/transition/graph.c return graph_fns->crmd(graph, action); graph 215 lib/transition/graph.c fire_synapse(crm_graph_t * graph, synapse_t * synapse) graph 232 lib/transition/graph.c passed = initiate_action(graph, action); graph 247 lib/transition/graph.c run_graph(crm_graph_t * graph) graph 258 lib/transition/graph.c if (graph == NULL) { graph 262 lib/transition/graph.c graph->fired = 0; graph 263 lib/transition/graph.c graph->pending = 0; graph 264 lib/transition/graph.c graph->skipped = 0; graph 265 lib/transition/graph.c graph->completed = 0; graph 266 lib/transition/graph.c graph->incomplete = 0; graph 267 lib/transition/graph.c crm_trace("Entering graph %d callback", graph->id); graph 270 lib/transition/graph.c for (lpc = graph->synapses; lpc != NULL; lpc = lpc->next) { graph 275 lib/transition/graph.c graph->completed++; graph 279 lib/transition/graph.c graph->pending++; graph 284 lib/transition/graph.c for (lpc = graph->synapses; lpc != NULL; lpc = lpc->next) { graph 287 lib/transition/graph.c if (graph->batch_limit > 0 && graph->pending >= graph->batch_limit) { graph 288 lib/transition/graph.c crm_debug("Throttling output: batch limit (%d) reached", graph->batch_limit); graph 291 lib/transition/graph.c graph->skipped++; graph 299 lib/transition/graph.c if (should_fire_synapse(graph, synapse)) { graph 301 lib/transition/graph.c graph->fired++; graph 302 lib/transition/graph.c if(fire_synapse(graph, synapse) == FALSE) { graph 305 lib/transition/graph.c graph->abort_priority = INFINITY; graph 306 lib/transition/graph.c graph->incomplete++; graph 307 lib/transition/graph.c graph->fired--; graph 311 lib/transition/graph.c graph->pending++; graph 316 lib/transition/graph.c graph->incomplete++; graph 320 lib/transition/graph.c if (graph->pending == 0 && graph->fired == 0) { graph 321 lib/transition/graph.c graph->complete = TRUE; graph 326 lib/transition/graph.c if (graph->incomplete != 0 && graph->abort_priority <= 0) { graph 331 lib/transition/graph.c } else if (graph->skipped != 0) { graph 335 lib/transition/graph.c } else if (graph->fired == 0) { graph 342 lib/transition/graph.c graph->id, graph->completed, graph->pending, graph->fired, graph 343 lib/transition/graph.c graph->skipped, graph->incomplete, graph->source, status); graph 280 lib/transition/unpack.c destroy_graph(crm_graph_t * graph) graph 282 lib/transition/unpack.c if (graph == NULL) { graph 285 lib/transition/unpack.c while (g_list_length(graph->synapses) > 0) { graph 286 lib/transition/unpack.c synapse_t *synapse = g_list_nth_data(graph->synapses, 0); graph 288 lib/transition/unpack.c graph->synapses = g_list_remove(graph->synapses, synapse); graph 292 lib/transition/unpack.c free(graph->source); graph 293 lib/transition/unpack.c free(graph); graph 31 lib/transition/utils.c pseudo_action_dummy(crm_graph_t * graph, crm_action_t * action) graph 49 lib/transition/utils.c graph->abort_priority = INFINITY; graph 52 lib/transition/utils.c update_graph(graph, action); graph 120 lib/transition/utils.c find_action(crm_graph_t * graph, int id) graph 124 lib/transition/utils.c if (graph == NULL) { graph 128 lib/transition/utils.c for (sIter = graph->synapses; sIter != NULL; sIter = sIter->next) { graph 144 lib/transition/utils.c print_synapse(unsigned int log_level, crm_graph_t * graph, synapse_t * synapse) graph 174 lib/transition/utils.c } else if (find_action(graph, input->id)) { graph 201 lib/transition/utils.c if (find_action(graph, input->id) == NULL) { graph 223 lib/transition/utils.c print_graph(unsigned int log_level, crm_graph_t * graph) graph 227 lib/transition/utils.c if (graph == NULL || graph->num_actions == 0) { graph 236 lib/transition/utils.c graph->id, graph->num_actions, graph 237 lib/transition/utils.c graph->batch_limit, graph->network_delay); graph 239 lib/transition/utils.c for (lpc = graph->synapses; lpc != NULL; lpc = lpc->next) { graph 242 lib/transition/utils.c print_synapse(log_level, graph, synapse); graph 263 lib/transition/utils.c update_abort_priority(crm_graph_t * graph, int priority, graph 268 lib/transition/utils.c if (graph == NULL) { graph 272 lib/transition/utils.c if (graph->abort_priority < priority) { graph 273 lib/transition/utils.c crm_debug("Abort priority upgraded from %d to %d", graph->abort_priority, priority); graph 274 lib/transition/utils.c graph->abort_priority = priority; graph 275 lib/transition/utils.c if (graph->abort_reason != NULL) { graph 276 lib/transition/utils.c crm_debug("'%s' abort superseded by %s", graph->abort_reason, abort_reason); graph 278 lib/transition/utils.c graph->abort_reason = abort_reason; graph 282 lib/transition/utils.c if (graph->completion_action < action) { graph 284 lib/transition/utils.c abort2text(graph->completion_action), abort2text(action), abort_reason); graph 285 lib/transition/utils.c graph->completion_action = action; graph 2393 pengine/allocate.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); graph 2396 pengine/allocate.c crm_xml_add(data_set->graph, "cluster-delay", value); graph 2399 pengine/allocate.c crm_xml_add(data_set->graph, "stonith-timeout", value); graph 2401 pengine/allocate.c crm_xml_add(data_set->graph, "failed-stop-offset", "INFINITY"); graph 2404 pengine/allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "INFINITY"); graph 2406 pengine/allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "1"); graph 2410 pengine/allocate.c crm_xml_add(data_set->graph, "batch-limit", value); graph 2412 pengine/allocate.c crm_xml_add_int(data_set->graph, "transition_id", transition_id); graph 2416 pengine/allocate.c crm_xml_add(data_set->graph, "migration-limit", value); graph 2435 pengine/allocate.c crm_log_xml_trace(data_set->graph, "created resource-driven action list"); graph 2473 pengine/allocate.c crm_log_xml_trace(data_set->graph, "created generic action list"); graph 1714 pengine/graph.c syn = create_xml_node(data_set->graph, "synapse"); graph 111 pengine/pengine.c data_set.graph = create_xml_node(NULL, XML_TAG_GRAPH); graph 112 pengine/pengine.c crm_xml_add_int(data_set.graph, "transition_id", 0); graph 113 pengine/pengine.c crm_xml_add_int(data_set.graph, "cluster-delay", 0); graph 151 pengine/pengine.c reply = create_reply(msg, data_set.graph); graph 179 pengine/pengine.c write_xml_fd(data_set.graph, graph_file, graph_file_fd, FALSE); graph 300 pengine/pengine.c return data_set->graph; graph 355 pengine/ptest.c msg_buffer = dump_xml_formatted(data_set.graph); graph 479 pengine/ptest.c transition = unpack_graph(data_set.graph, "ptest"); graph 881 tools/crm_simulate.c write_xml_file(data_set.graph, graph_file, FALSE); graph 608 tools/fake_transition.c exec_pseudo_action(crm_graph_t * graph, crm_action_t * action) graph 616 tools/fake_transition.c update_graph(graph, action); graph 621 tools/fake_transition.c exec_rsc_action(crm_graph_t * graph, crm_action_t * action) graph 722 tools/fake_transition.c graph->abort_priority = INFINITY; graph 742 tools/fake_transition.c update_graph(graph, action); graph 747 tools/fake_transition.c exec_crmd_action(crm_graph_t * graph, crm_action_t * action) graph 760 tools/fake_transition.c update_graph(graph, action); graph 765 tools/fake_transition.c exec_stonith_action(crm_graph_t * graph, crm_action_t * action) graph 796 tools/fake_transition.c update_graph(graph, action); graph 821 tools/fake_transition.c transition = unpack_graph(data_set->graph, crm_system_name);