data_set 428 daemons/execd/cts-exec-helper.c pe_working_set_t *data_set = NULL; data_set 439 daemons/execd/cts-exec-helper.c data_set = pe_new_working_set(); data_set 440 daemons/execd/cts-exec-helper.c if (data_set == NULL) { data_set 444 daemons/execd/cts-exec-helper.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 459 daemons/execd/cts-exec-helper.c data_set->input = cib_xml_copy; data_set 460 daemons/execd/cts-exec-helper.c data_set->now = crm_time_new(NULL); data_set 462 daemons/execd/cts-exec-helper.c cluster_status(data_set); data_set 464 daemons/execd/cts-exec-helper.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 474 daemons/execd/cts-exec-helper.c params = pe_rsc_params(rsc, NULL, data_set); data_set 477 daemons/execd/cts-exec-helper.c get_meta_attributes(meta, rsc, NULL, data_set); data_set 504 daemons/execd/cts-exec-helper.c pe_free_working_set(data_set); data_set 660 daemons/fenced/pacemaker-fenced.c static void cib_device_update(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 671 daemons/fenced/pacemaker-fenced.c cib_device_update(gIter->data, data_set); data_set 742 daemons/fenced/pacemaker-fenced.c rsc_params = pe_rsc_params(rsc, node, data_set); data_set 743 daemons/fenced/pacemaker-fenced.c get_meta_attributes(rsc->meta, rsc, node, data_set); data_set 24 include/crm/pengine/complex.h pe_working_set_t *data_set); data_set 26 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); data_set 28 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); data_set 32 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); data_set 213 include/crm/pengine/internal.h bool pe_can_fence(pe_working_set_t *data_set, pe_node_t *node); data_set 219 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 226 include/crm/pengine/internal.h void native_add_running(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set, gboolean failed); data_set 228 include/crm/pengine/internal.h gboolean native_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 229 include/crm/pengine/internal.h gboolean group_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 230 include/crm/pengine/internal.h gboolean clone_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 231 include/crm/pengine/internal.h gboolean pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 289 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 293 include/crm/pengine/internal.h extern time_t get_effective_time(pe_working_set_t * data_set); data_set 306 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 310 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 341 include/crm/pengine/internal.h extern pe_action_t *get_pseudo_op(const char *name, pe_working_set_t * data_set); data_set 351 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 353 include/crm/pengine/internal.h #define pe__show_node_weights(level, rsc, text, nodes, data_set) \ data_set 355 include/crm/pengine/internal.h (level), (rsc), (text), (nodes), (data_set)) data_set 364 include/crm/pengine/internal.h gboolean optional, gboolean foo, pe_working_set_t * data_set); data_set 369 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 374 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 379 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 385 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 390 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 395 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 400 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 405 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 410 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 413 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 430 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 438 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 441 include/crm/pengine/internal.h extern pe_ticket_t *ticket_new(const char *ticket_id, pe_working_set_t * data_set); data_set 491 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 496 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 498 include/crm/pengine/internal.h pe_action_t *pe_fence_op(pe_node_t * node, const char *op, bool optional, const char *reason, bool priority_delay, pe_working_set_t * data_set); data_set 500 include/crm/pengine/internal.h pe_resource_t * rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t * data_set); data_set 507 include/crm/pengine/internal.h void pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag); data_set 514 include/crm/pengine/internal.h void pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, const char *reason, bool priority_delay); data_set 517 include/crm/pengine/internal.h const char *score, pe_working_set_t * data_set); data_set 524 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 526 include/crm/pengine/internal.h pe_working_set_t *data_set, data_set 533 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 535 include/crm/pengine/internal.h enum pe_check_parameters, pe_working_set_t *data_set); data_set 536 include/crm/pengine/internal.h void pe__foreach_param_check(pe_working_set_t *data_set, data_set 540 include/crm/pengine/internal.h void pe__free_param_checks(pe_working_set_t *data_set); data_set 543 include/crm/pengine/internal.h void pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set); data_set 554 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 558 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 560 include/crm/pengine/internal.h GList *pe__rscs_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 561 include/crm/pengine/internal.h GList *pe__unames_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 562 include/crm/pengine/internal.h bool pe__rsc_has_tag(pe_working_set_t *data_set, const char *rsc, const char *tag); data_set 563 include/crm/pengine/internal.h bool pe__uname_has_tag(pe_working_set_t *data_set, const char *node, const char *tag); data_set 567 include/crm/pengine/internal.h GList * pe__build_node_name_list(pe_working_set_t *data_set, const char *s); data_set 568 include/crm/pengine/internal.h GList * pe__build_rsc_list(pe_working_set_t *data_set, const char *s); data_set 27 include/crm/pengine/remote_internal.h const pe_working_set_t *data_set); data_set 28 include/crm/pengine/remote_internal.h pe_resource_t *pe__resource_contains_guest_node(const pe_working_set_t *data_set, data_set 30 include/crm/pengine/remote_internal.h void pe_foreach_guest_node(const pe_working_set_t *data_set, const pe_node_t *host, data_set 32 include/crm/pengine/status.h gboolean cluster_status(pe_working_set_t * data_set); data_set 34 include/crm/pengine/status.h void pe_free_working_set(pe_working_set_t *data_set); data_set 35 include/crm/pengine/status.h void set_working_set_defaults(pe_working_set_t * data_set); data_set 36 include/crm/pengine/status.h void cleanup_calculations(pe_working_set_t * data_set); data_set 37 include/crm/pengine/status.h void pe_reset_working_set(pe_working_set_t *data_set); data_set 44 include/crm/pengine/status.h pe_working_set_t * data_set); data_set 131 include/pacemaker.h pe_working_set_t *data_set); data_set 162 include/pacemaker.h int pcmk_simulate(xmlNodePtr *xml, pe_working_set_t *data_set, data_set 19 include/pcmki/pcmki_resource.h pe_working_set_t *data_set); data_set 60 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 75 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 76 include/pcmki/pcmki_sched_allocate.h extern void native_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 77 include/pcmki/pcmki_sched_allocate.h extern void native_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 80 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 83 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 87 include/pcmki/pcmki_sched_allocate.h extern void native_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 89 include/pcmki/pcmki_sched_allocate.h gboolean force, pe_working_set_t * data_set); data_set 93 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 94 include/pcmki/pcmki_sched_allocate.h extern void group_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 95 include/pcmki/pcmki_sched_allocate.h extern void group_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 98 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 101 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 104 include/pcmki/pcmki_sched_allocate.h extern void group_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 108 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 110 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 113 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 115 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 119 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 123 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 127 include/pcmki/pcmki_sched_allocate.h void pcmk__bundle_expand(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 131 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 132 include/pcmki/pcmki_sched_allocate.h extern void clone_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 133 include/pcmki/pcmki_sched_allocate.h extern void clone_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 136 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 139 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 142 include/pcmki/pcmki_sched_allocate.h extern void clone_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 144 include/pcmki/pcmki_sched_allocate.h gboolean force, pe_working_set_t * data_set); data_set 149 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 150 include/pcmki/pcmki_sched_allocate.h void create_promotable_actions(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 151 include/pcmki/pcmki_sched_allocate.h void promote_demote_constraints(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 152 include/pcmki/pcmki_sched_allocate.h void promotable_constraints(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 155 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 160 include/pcmki/pcmki_sched_allocate.h void LogNodeActions(pe_working_set_t * data_set); data_set 161 include/pcmki/pcmki_sched_allocate.h void LogActions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 162 include/pcmki/pcmki_sched_allocate.h void pcmk__bundle_log_actions(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 169 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 175 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 182 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 184 include/pcmki/pcmki_sched_allocate.h gboolean update_action(pe_action_t *action, pe_working_set_t *data_set); data_set 188 include/pcmki/pcmki_sched_allocate.h pe_resource_t * rsc, GList *children, notify_data_t **start_notify, notify_data_t **stop_notify, pe_working_set_t * data_set); data_set 17 include/pcmki/pcmki_sched_notif.h pe_working_set_t *data_set); data_set 23 include/pcmki/pcmki_sched_notif.h pe_working_set_t *data_set); data_set 26 include/pcmki/pcmki_sched_notif.h pe_working_set_t *data_set); data_set 32 include/pcmki/pcmki_sched_notif.h pe_working_set_t *data_set); data_set 31 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 45 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 58 include/pcmki/pcmki_sched_utils.h extern void process_utilization(pe_resource_t * rsc, pe_node_t ** prefer, pe_working_set_t * data_set); data_set 59 include/pcmki/pcmki_sched_utils.h pe_action_t *create_pseudo_resource_op(pe_resource_t * rsc, const char *task, bool optional, bool runnable, pe_working_set_t *data_set); data_set 62 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 63 include/pcmki/pcmki_sched_utils.h pe_action_t *sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set); data_set 72 include/pcmki/pcmki_sched_utils.h void modify_configuration(pe_working_set_t *data_set, cib_t *cib, data_set 75 include/pcmki/pcmki_sched_utils.h enum transition_status run_simulation(pe_working_set_t * data_set, cib_t *cib, GList *op_fail_list); data_set 80 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set, data_set 68 include/pcmki/pcmki_scheduler.h extern gboolean stage0(pe_working_set_t * data_set); data_set 69 include/pcmki/pcmki_scheduler.h extern gboolean probe_resources(pe_working_set_t * data_set); data_set 70 include/pcmki/pcmki_scheduler.h extern gboolean stage2(pe_working_set_t * data_set); data_set 71 include/pcmki/pcmki_scheduler.h extern gboolean stage4(pe_working_set_t * data_set); data_set 72 include/pcmki/pcmki_scheduler.h extern gboolean stage5(pe_working_set_t * data_set); data_set 73 include/pcmki/pcmki_scheduler.h extern gboolean stage6(pe_working_set_t * data_set); data_set 74 include/pcmki/pcmki_scheduler.h extern gboolean stage8(pe_working_set_t * data_set); data_set 76 include/pcmki/pcmki_scheduler.h void pcmk__unpack_constraints(pe_working_set_t *data_set); data_set 78 include/pcmki/pcmki_scheduler.h extern void graph_element_from_action(pe_action_t * action, pe_working_set_t * data_set); data_set 79 include/pcmki/pcmki_scheduler.h extern void add_maintenance_update(pe_working_set_t *data_set); data_set 80 include/pcmki/pcmki_scheduler.h xmlNode *pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input, data_set 31 include/pcmki/pcmki_simulate.h int pcmk__write_sim_dotfile(pe_working_set_t *data_set, const char *dot_file, data_set 47 include/pcmki/pcmki_simulate.h void pcmk__profile_file(const char *xml_file, long long repeat, pe_working_set_t *data_set, data_set 64 include/pcmki/pcmki_simulate.h void pcmk__profile_dir(const char *dir, long long repeat, pe_working_set_t *data_set, data_set 80 include/pcmki/pcmki_simulate.h void pcmk__set_effective_date(pe_working_set_t *data_set, bool print_original, char *use_date); data_set 112 include/pcmki/pcmki_simulate.h int pcmk__simulate(pe_working_set_t *data_set, pcmk__output_t *out, data_set 24 lib/pacemaker/libpacemaker_private.h void pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set); data_set 29 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 32 lib/pacemaker/libpacemaker_private.h void pcmk__fence_guest(pe_node_t *node, pe_working_set_t *data_set); data_set 39 lib/pacemaker/libpacemaker_private.h const pe_working_set_t *data_set); data_set 46 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 49 lib/pacemaker/libpacemaker_private.h bool pcmk__valid_resource_or_tag(pe_working_set_t *data_set, const char *id, data_set 54 lib/pacemaker/libpacemaker_private.h bool convert_rsc, pe_working_set_t *data_set); data_set 57 lib/pacemaker/libpacemaker_private.h void pcmk__create_internal_constraints(pe_working_set_t *data_set); data_set 63 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 69 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 72 lib/pacemaker/libpacemaker_private.h void pcmk__apply_locations(pe_working_set_t *data_set); data_set 103 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_colocation(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 109 lib/pacemaker/libpacemaker_private.h bool influence, pe_working_set_t *data_set); data_set 113 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 119 lib/pacemaker/libpacemaker_private.h enum pe_ordering type, pe_working_set_t *data_set); data_set 122 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_ordering(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 125 lib/pacemaker/libpacemaker_private.h void pcmk__disable_invalid_orderings(pe_working_set_t *data_set); data_set 130 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 133 lib/pacemaker/libpacemaker_private.h void pcmk__apply_orderings(pe_working_set_t *data_set); data_set 147 lib/pacemaker/libpacemaker_private.h flags, data_set) \ data_set 151 lib/pacemaker/libpacemaker_private.h NULL, (flags), (data_set)) data_set 153 lib/pacemaker/libpacemaker_private.h #define pcmk__order_starts(rsc1, rsc2, type, data_set) \ data_set 155 lib/pacemaker/libpacemaker_private.h (rsc2), CRMD_ACTION_START, (type), (data_set)) data_set 157 lib/pacemaker/libpacemaker_private.h #define pcmk__order_stops(rsc1, rsc2, type, data_set) \ data_set 159 lib/pacemaker/libpacemaker_private.h (rsc2), CRMD_ACTION_STOP, (type), (data_set)) data_set 162 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 165 lib/pacemaker/libpacemaker_private.h void pcmk__order_probes(pe_working_set_t *data_set); data_set 171 lib/pacemaker/libpacemaker_private.h void pcmk__order_remote_connection_actions(pe_working_set_t *data_set); data_set 181 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 179 lib/pacemaker/pcmk_graph_producer.c pe_action_wrapper_t *order, pe_working_set_t *data_set) data_set 212 lib/pacemaker/pcmk_graph_producer.c pe_order_implies_then, data_set); data_set 229 lib/pacemaker/pcmk_graph_producer.c pe_order_restart, data_set); data_set 239 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 255 lib/pacemaker/pcmk_graph_producer.c pe_order_promoted_implies_first, data_set); data_set 267 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 301 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 312 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 329 lib/pacemaker/pcmk_graph_producer.c pe_order_implies_first_migratable, data_set); data_set 341 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 351 lib/pacemaker/pcmk_graph_producer.c first_flags, pe_action_runnable, pe_order_optional, data_set); data_set 362 lib/pacemaker/pcmk_graph_producer.c data_set); data_set 423 lib/pacemaker/pcmk_graph_producer.c update_action(pe_action_t *then, pe_working_set_t *data_set) data_set 546 lib/pacemaker/pcmk_graph_producer.c then_flags, other, data_set); data_set 576 lib/pacemaker/pcmk_graph_producer.c update_action(other->action, data_set); data_set 578 lib/pacemaker/pcmk_graph_producer.c update_action(first, data_set); data_set 595 lib/pacemaker/pcmk_graph_producer.c pcmk__block_colocated_starts(then, data_set); data_set 597 lib/pacemaker/pcmk_graph_producer.c update_action(then, data_set); data_set 601 lib/pacemaker/pcmk_graph_producer.c update_action(other->action, data_set); data_set 647 lib/pacemaker/pcmk_graph_producer.c add_maintenance_nodes(xmlNode *xml, const pe_working_set_t *data_set) data_set 654 lib/pacemaker/pcmk_graph_producer.c for (gIter = data_set->nodes; gIter != NULL; data_set 684 lib/pacemaker/pcmk_graph_producer.c add_maintenance_update(pe_working_set_t *data_set) data_set 688 lib/pacemaker/pcmk_graph_producer.c if (add_maintenance_nodes(NULL, data_set)) { data_set 690 lib/pacemaker/pcmk_graph_producer.c action = get_pseudo_op(CRM_OP_MAINTENANCE_NODES, data_set); data_set 709 lib/pacemaker/pcmk_graph_producer.c const pe_working_set_t *data_set) data_set 711 lib/pacemaker/pcmk_graph_producer.c CRM_CHECK(xml && action && action->node && data_set, return); data_set 727 lib/pacemaker/pcmk_graph_producer.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); data_set 776 lib/pacemaker/pcmk_graph_producer.c action2xml(pe_action_t * action, gboolean as_input, pe_working_set_t *data_set) data_set 969 lib/pacemaker/pcmk_graph_producer.c GHashTable *params = pe_rsc_params(action->rsc, action->node, data_set); data_set 971 lib/pacemaker/pcmk_graph_producer.c pcmk__substitute_remote_addr(action->rsc, params, data_set); data_set 980 lib/pacemaker/pcmk_graph_producer.c action->node, data_set); data_set 989 lib/pacemaker/pcmk_graph_producer.c GHashTable *params = pe_rsc_params(action->rsc, NULL, data_set); data_set 1043 lib/pacemaker/pcmk_graph_producer.c add_downed_nodes(action_xml, action, data_set); data_set 1047 lib/pacemaker/pcmk_graph_producer.c add_maintenance_nodes(action_xml, data_set); data_set 1504 lib/pacemaker/pcmk_graph_producer.c graph_element_from_action(pe_action_t *action, pe_working_set_t *data_set) data_set 1528 lib/pacemaker/pcmk_graph_producer.c syn = create_xml_node(data_set->graph, "synapse"); data_set 1532 lib/pacemaker/pcmk_graph_producer.c crm_xml_add_int(syn, XML_ATTR_ID, data_set->num_synapse); data_set 1533 lib/pacemaker/pcmk_graph_producer.c data_set->num_synapse++; data_set 1545 lib/pacemaker/pcmk_graph_producer.c xml_action = action2xml(action, FALSE, data_set); data_set 1554 lib/pacemaker/pcmk_graph_producer.c xml_action = action2xml(input->action, TRUE, data_set); data_set 548 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 551 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(data_set); data_set 558 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 561 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 570 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 573 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(data_set); data_set 581 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 584 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 1494 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1507 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "cluster-summary", data_set, data_set 1511 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-list", data_set->nodes, unames, data_set 1517 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "resource-list", data_set, show_opts, data_set 1523 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-attribute-list", data_set, data_set 1531 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-summary", data_set, unames, data_set 1537 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1539 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "failed-action-list", data_set, unames, data_set 1566 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ticket-list", data_set, rc == pcmk_rc_ok)); data_set 1571 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ban-list", data_set, prefix, resources, data_set 1612 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1622 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1626 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, data_set 1635 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, full_show_opts, data_set 1641 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, FALSE, data_set 1649 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1655 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1657 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1669 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, FALSE); data_set 1674 lib/pacemaker/pcmk_output.c out->message(out, "ban-list", data_set, prefix, resources, show_opts, data_set 1687 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1698 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1702 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, data_set 1708 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, show_opts, TRUE, unames, data_set 1714 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, FALSE, data_set 1722 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1728 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1730 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1780 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, FALSE); data_set 1785 lib/pacemaker/pcmk_output.c out->message(out, "ban-list", data_set, prefix, resources, show_opts, data_set 31 lib/pacemaker/pcmk_resource.c best_op(pe_resource_t *rsc, pe_node_t *node, pe_working_set_t *data_set) data_set 39 lib/pacemaker/pcmk_resource.c history = get_xpath_object(xpath, data_set->input, LOG_NEVER); data_set 86 lib/pacemaker/pcmk_resource.c pe_working_set_t *data_set) data_set 94 lib/pacemaker/pcmk_resource.c if ((out == NULL) || (rsc == NULL) || (node == NULL) || (data_set == NULL)) { data_set 103 lib/pacemaker/pcmk_resource.c xml_op = best_op(rsc, node, data_set); data_set 117 lib/pacemaker/pcmk_resource.c overrides, true, data_set); data_set 127 lib/pacemaker/pcmk_resource.c pe_working_set_t *data_set) data_set 137 lib/pacemaker/pcmk_resource.c rc = pcmk__resource_digests(out, rsc, node, overrides, data_set); data_set 30 lib/pacemaker/pcmk_sched_allocate.c void set_alloc_actions(pe_working_set_t * data_set); data_set 31 lib/pacemaker/pcmk_sched_allocate.c extern void ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set); data_set 32 lib/pacemaker/pcmk_sched_allocate.c extern gboolean DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set); data_set 99 lib/pacemaker/pcmk_sched_allocate.c gboolean active_here, pe_working_set_t * data_set) data_set 124 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, node, "Device definition changed", NULL, data_set); data_set 146 lib/pacemaker/pcmk_sched_allocate.c const char *reason, pe_working_set_t * data_set) data_set 165 lib/pacemaker/pcmk_sched_allocate.c cancel = pe_cancel_op(rsc, task, interval_ms, active_node, data_set); data_set 168 lib/pacemaker/pcmk_sched_allocate.c pe_order_optional, data_set); data_set 173 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t * data_set) data_set 196 lib/pacemaker/pcmk_sched_allocate.c && pcmk_is_set(data_set->flags, pe_flag_stop_action_orphans)) { data_set 197 lib/pacemaker/pcmk_sched_allocate.c CancelXmlOp(rsc, xml_op, active_node, "orphan", data_set); data_set 224 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, xml_op, active_node, data_set); data_set 226 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_sanitized)) { data_set 234 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 235 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 249 lib/pacemaker/pcmk_sched_allocate.c required = custom_action(rsc, key, task, NULL, FALSE, TRUE, data_set); data_set 251 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed", NULL, data_set); data_set 258 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed (reload)", NULL, data_set); data_set 267 lib/pacemaker/pcmk_sched_allocate.c ReloadRsc(rsc, active_node, data_set); data_set 270 lib/pacemaker/pcmk_sched_allocate.c op = custom_action(rsc, key, task, active_node, TRUE, TRUE, data_set); data_set 278 lib/pacemaker/pcmk_sched_allocate.c ReloadRsc(rsc, active_node, data_set); data_set 290 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 306 lib/pacemaker/pcmk_sched_allocate.c enum pe_check_parameters check, pe_working_set_t *data_set) data_set 313 lib/pacemaker/pcmk_sched_allocate.c if (check_action_definition(rsc, node, rsc_op, data_set) data_set 315 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 322 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, rsc_op, node, data_set); data_set 338 lib/pacemaker/pcmk_sched_allocate.c pe__clear_failcount(rsc, node, reason, data_set); data_set 343 lib/pacemaker/pcmk_sched_allocate.c check_actions_for(xmlNode * rsc_entry, pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set) data_set 364 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 371 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, FALSE, data_set)) { data_set 372 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 381 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, TRUE, data_set)) { data_set 382 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 416 lib/pacemaker/pcmk_sched_allocate.c CancelXmlOp(rsc, rsc_op, node, "maintenance mode", data_set); data_set 424 lib/pacemaker/pcmk_sched_allocate.c if (pe__bundle_needs_remote_name(rsc, data_set)) { data_set 433 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 435 lib/pacemaker/pcmk_sched_allocate.c } else if (check_action_definition(rsc, node, rsc_op, data_set) data_set 437 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 439 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 448 lib/pacemaker/pcmk_sched_allocate.c gboolean partial, pe_working_set_t * data_set) data_set 458 lib/pacemaker/pcmk_sched_allocate.c if (data_set == NULL) { data_set 461 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 504 lib/pacemaker/pcmk_sched_allocate.c check_actions(pe_working_set_t * data_set) data_set 509 lib/pacemaker/pcmk_sched_allocate.c xmlNode *status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 522 lib/pacemaker/pcmk_sched_allocate.c node = pe_find_node_id(data_set->nodes, id); data_set 536 lib/pacemaker/pcmk_sched_allocate.c || pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 552 lib/pacemaker/pcmk_sched_allocate.c result = find_rsc_list(NULL, NULL, rsc_id, TRUE, FALSE, data_set); data_set 559 lib/pacemaker/pcmk_sched_allocate.c check_actions_for(rsc_entry, rsc, node, data_set); data_set 584 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set) data_set 592 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(child_rsc, node, data_set); data_set 605 lib/pacemaker/pcmk_sched_allocate.c || pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 608 lib/pacemaker/pcmk_sched_allocate.c resource_location(sticky_rsc, node, rsc->stickiness, "stickiness", data_set); data_set 639 lib/pacemaker/pcmk_sched_allocate.c if (pcmk__threshold_reached(rsc, node, data_set, &failed)) { data_set 641 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 661 lib/pacemaker/pcmk_sched_allocate.c set_alloc_actions(pe_working_set_t * data_set) data_set 664 lib/pacemaker/pcmk_sched_allocate.c GList *gIter = data_set->resources; data_set 696 lib/pacemaker/pcmk_sched_allocate.c apply_system_health(pe_working_set_t * data_set) data_set 699 lib/pacemaker/pcmk_sched_allocate.c const char *health_strategy = pe_pref(data_set->config_hash, "node-health-strategy"); data_set 732 lib/pacemaker/pcmk_sched_allocate.c base_health = char2score(pe_pref(data_set->config_hash, data_set 750 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 765 lib/pacemaker/pcmk_sched_allocate.c GList *gIter2 = data_set->resources; data_set 771 lib/pacemaker/pcmk_sched_allocate.c node, data_set); data_set 780 lib/pacemaker/pcmk_sched_allocate.c stage0(pe_working_set_t * data_set) data_set 782 lib/pacemaker/pcmk_sched_allocate.c if (data_set->input == NULL) { data_set 786 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_have_status)) { data_set 788 lib/pacemaker/pcmk_sched_allocate.c cluster_status(data_set); data_set 791 lib/pacemaker/pcmk_sched_allocate.c set_alloc_actions(data_set); data_set 792 lib/pacemaker/pcmk_sched_allocate.c apply_system_health(data_set); data_set 793 lib/pacemaker/pcmk_sched_allocate.c pcmk__unpack_constraints(data_set); data_set 802 lib/pacemaker/pcmk_sched_allocate.c probe_resources(pe_working_set_t * data_set) data_set 806 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 813 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, node, "the connection is unrecoverable", FALSE); data_set 827 lib/pacemaker/pcmk_sched_allocate.c CRM_OP_REPROBE, node, FALSE, TRUE, data_set); data_set 833 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter2 = data_set->resources; gIter2 != NULL; gIter2 = gIter2->next) { data_set 836 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->create_probe(rsc, node, probe_node_complete, FALSE, data_set); data_set 861 lib/pacemaker/pcmk_sched_allocate.c shutdown_time(pe_node_t *node, pe_working_set_t *data_set) data_set 873 lib/pacemaker/pcmk_sched_allocate.c return result? result : get_effective_time(data_set); data_set 877 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_lock(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 883 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(rsc->children, (GFunc) apply_shutdown_lock, data_set); data_set 891 lib/pacemaker/pcmk_sched_allocate.c || pe__resource_is_remote_conn(rsc, data_set)) { data_set 906 lib/pacemaker/pcmk_sched_allocate.c pe__clear_resource_history(rsc, rsc->lock_node, data_set); data_set 921 lib/pacemaker/pcmk_sched_allocate.c rsc->lock_time = shutdown_time(node, data_set); data_set 931 lib/pacemaker/pcmk_sched_allocate.c if (data_set->shutdown_lock > 0) { data_set 932 lib/pacemaker/pcmk_sched_allocate.c time_t lock_expiration = rsc->lock_time + data_set->shutdown_lock; data_set 937 lib/pacemaker/pcmk_sched_allocate.c pe__update_recheck_time(++lock_expiration, data_set); data_set 944 lib/pacemaker/pcmk_sched_allocate.c for (GList *item = data_set->nodes; item != NULL; item = item->next) { data_set 949 lib/pacemaker/pcmk_sched_allocate.c XML_CONFIG_ATTR_SHUTDOWN_LOCK, data_set); data_set 962 lib/pacemaker/pcmk_sched_allocate.c stage2(pe_working_set_t * data_set) data_set 966 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 967 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(data_set->resources, (GFunc) apply_shutdown_lock, data_set); data_set 970 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_no_compat)) { data_set 972 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 977 lib/pacemaker/pcmk_sched_allocate.c data_set->max_valid_nodes++; data_set 982 lib/pacemaker/pcmk_sched_allocate.c pcmk__apply_locations(data_set); data_set 984 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 989 lib/pacemaker/pcmk_sched_allocate.c gIter2 = data_set->resources; data_set 993 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(rsc, node, data_set); data_set 1005 lib/pacemaker/pcmk_sched_allocate.c stage4(pe_working_set_t * data_set) data_set 1007 lib/pacemaker/pcmk_sched_allocate.c check_actions(data_set); data_set 1149 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(pe_working_set_t * data_set) data_set 1153 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 1158 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1165 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->allocate(rsc, rsc->partial_migration_target, data_set); data_set 1170 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1177 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->allocate(rsc, NULL, data_set); data_set 1183 lib/pacemaker/pcmk_sched_allocate.c cleanup_orphans(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1187 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1192 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 1197 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1204 lib/pacemaker/pcmk_sched_allocate.c pe_order_optional, data_set); data_set 1210 lib/pacemaker/pcmk_sched_allocate.c stage5(pe_working_set_t * data_set) data_set 1212 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 1215 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk__str_eq(data_set->placement_strategy, "default", pcmk__str_casei)) { data_set 1216 lib/pacemaker/pcmk_sched_allocate.c GList *nodes = g_list_copy(data_set->nodes); data_set 1218 lib/pacemaker/pcmk_sched_allocate.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 1219 lib/pacemaker/pcmk_sched_allocate.c data_set->resources = data_set 1220 lib/pacemaker/pcmk_sched_allocate.c g_list_sort_with_data(data_set->resources, sort_rsc_process_order, nodes); data_set 1225 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 1229 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 1237 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(data_set); data_set 1239 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 1243 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 1249 lib/pacemaker/pcmk_sched_allocate.c pe__foreach_param_check(data_set, check_params); data_set 1250 lib/pacemaker/pcmk_sched_allocate.c pe__free_param_checks(data_set); data_set 1252 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 1288 lib/pacemaker/pcmk_sched_allocate.c probe_resources(data_set); data_set 1292 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 1293 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1300 lib/pacemaker/pcmk_sched_allocate.c cleanup_orphans(rsc, data_set); data_set 1307 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1310 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->create_actions(rsc, data_set); data_set 1338 lib/pacemaker/pcmk_sched_allocate.c any_managed_resources(pe_working_set_t * data_set) data_set 1341 lib/pacemaker/pcmk_sched_allocate.c GList *gIter = data_set->resources; data_set 1357 lib/pacemaker/pcmk_sched_allocate.c stage6(pe_working_set_t * data_set) data_set 1370 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_remote_connection_actions(data_set); data_set 1373 lib/pacemaker/pcmk_sched_allocate.c if (any_managed_resources(data_set) == FALSE) { data_set 1379 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1387 lib/pacemaker/pcmk_sched_allocate.c && pe_can_fence(data_set, node)) { data_set 1388 lib/pacemaker/pcmk_sched_allocate.c pcmk__fence_guest(node, data_set); data_set 1396 lib/pacemaker/pcmk_sched_allocate.c && need_stonith && pe_can_fence(data_set, node)) { data_set 1398 lib/pacemaker/pcmk_sched_allocate.c stonith_op = pe_fence_op(node, NULL, FALSE, "node is unclean", FALSE, data_set); data_set 1401 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_vs_fence(stonith_op, data_set); data_set 1409 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing) data_set 1430 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *down_op = sched_shutdown_op(node, data_set); data_set 1448 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1452 lib/pacemaker/pcmk_sched_allocate.c } else if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 1480 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)) { data_set 1531 lib/pacemaker/pcmk_sched_allocate.c order_first_probes_imply_stops(pe_working_set_t * data_set) data_set 1535 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->ordering_constraints; gIter != NULL; gIter = gIter->next) { data_set 1658 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t * data_set) data_set 1733 lib/pacemaker/pcmk_sched_allocate.c FALSE, data_set); data_set 1783 lib/pacemaker/pcmk_sched_allocate.c order_first_probe_then_restart_repromote(probe, after_wrapper->action, data_set); data_set 1787 lib/pacemaker/pcmk_sched_allocate.c static void clear_actions_tracking_flag(pe_working_set_t * data_set) data_set 1791 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 1801 lib/pacemaker/pcmk_sched_allocate.c order_first_rsc_probes(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1806 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(rsc->children, (GFunc) order_first_rsc_probes, data_set); data_set 1821 lib/pacemaker/pcmk_sched_allocate.c order_first_probe_then_restart_repromote(probe, after_wrapper->action, data_set); data_set 1822 lib/pacemaker/pcmk_sched_allocate.c clear_actions_tracking_flag(data_set); data_set 1830 lib/pacemaker/pcmk_sched_allocate.c order_first_probes(pe_working_set_t * data_set) data_set 1834 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1837 lib/pacemaker/pcmk_sched_allocate.c order_first_rsc_probes(rsc, data_set); data_set 1840 lib/pacemaker/pcmk_sched_allocate.c order_first_probes_imply_stops(data_set); data_set 1844 lib/pacemaker/pcmk_sched_allocate.c order_then_probes(pe_working_set_t * data_set) data_set 1849 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1961 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_probes(pe_working_set_t *data_set) data_set 1963 lib/pacemaker/pcmk_sched_allocate.c order_first_probes(data_set); data_set 1964 lib/pacemaker/pcmk_sched_allocate.c order_then_probes(data_set); data_set 2006 lib/pacemaker/pcmk_sched_allocate.c stage8(pe_working_set_t * data_set) data_set 2015 lib/pacemaker/pcmk_sched_allocate.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 2017 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "cluster-delay"); data_set 2018 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "cluster-delay", value); data_set 2020 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 2021 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "stonith-timeout", value); data_set 2023 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-stop-offset", "INFINITY"); data_set 2025 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)) { data_set 2026 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "INFINITY"); data_set 2028 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "1"); data_set 2031 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "batch-limit"); data_set 2032 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "batch-limit", value); data_set 2034 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add_int(data_set->graph, "transition_id", transition_id); data_set 2036 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "migration-limit"); data_set 2038 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "migration-limit", value); data_set 2041 lib/pacemaker/pcmk_sched_allocate.c if (data_set->recheck_by > 0) { data_set 2045 lib/pacemaker/pcmk_sched_allocate.c (long long) data_set->recheck_by); data_set 2046 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "recheck-by", recheck_epoch); data_set 2055 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->resources; data_set 2060 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->expand(rsc, data_set); data_set 2063 lib/pacemaker/pcmk_sched_allocate.c crm_log_xml_trace(data_set->graph, "created resource-driven action list"); data_set 2066 lib/pacemaker/pcmk_sched_allocate.c add_maintenance_update(data_set); data_set 2071 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->actions; data_set 2087 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 2088 lib/pacemaker/pcmk_sched_allocate.c || data_set->no_quorum_policy == no_quorum_ignore) { data_set 2098 lib/pacemaker/pcmk_sched_allocate.c graph_element_from_action(action, data_set); data_set 2101 lib/pacemaker/pcmk_sched_allocate.c crm_log_xml_trace(data_set->graph, "created generic action list"); data_set 2108 lib/pacemaker/pcmk_sched_allocate.c LogNodeActions(pe_working_set_t * data_set) data_set 2110 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 2113 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 35 lib/pacemaker/pcmk_sched_bundle.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 37 lib/pacemaker/pcmk_sched_bundle.c int max, int per_host_max, pe_working_set_t * data_set); data_set 67 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 80 lib/pacemaker/pcmk_sched_bundle.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 81 lib/pacemaker/pcmk_sched_bundle.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 84 lib/pacemaker/pcmk_sched_bundle.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 85 lib/pacemaker/pcmk_sched_bundle.c containers = g_list_sort_with_data(containers, sort_clone_instance, data_set); data_set 87 lib/pacemaker/pcmk_sched_bundle.c bundle_data->nreplicas_per_host, data_set); data_set 100 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->allocate(replica->ip, prefer, data_set); data_set 112 lib/pacemaker/pcmk_sched_bundle.c NULL, true, data_set); data_set 119 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 132 lib/pacemaker/pcmk_sched_bundle.c data_set, NULL)) { data_set 141 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 160 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->allocate(bundle_data->child, prefer, data_set); data_set 169 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_create_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 185 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->create_actions(replica->ip, data_set); data_set 189 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 192 lib/pacemaker/pcmk_sched_bundle.c replica->remote->cmds->create_actions(replica->remote, data_set); data_set 196 lib/pacemaker/pcmk_sched_bundle.c clone_create_pseudo_actions(rsc, containers, NULL, NULL, data_set); data_set 199 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->create_actions(bundle_data->child, data_set); data_set 203 lib/pacemaker/pcmk_sched_bundle.c create_pseudo_resource_op(rsc, RSC_PROMOTE, TRUE, TRUE, data_set); data_set 204 lib/pacemaker/pcmk_sched_bundle.c action = create_pseudo_resource_op(rsc, RSC_PROMOTED, TRUE, TRUE, data_set); data_set 208 lib/pacemaker/pcmk_sched_bundle.c create_pseudo_resource_op(rsc, RSC_DEMOTE, TRUE, TRUE, data_set); data_set 209 lib/pacemaker/pcmk_sched_bundle.c action = create_pseudo_resource_op(rsc, RSC_DEMOTED, TRUE, TRUE, data_set); data_set 219 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 230 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 233 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 239 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 243 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 248 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 252 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 264 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 268 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 272 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 275 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 278 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 281 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 284 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->internal_constraints(replica->ip, data_set); data_set 289 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 292 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 296 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 306 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 318 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->internal_constraints(bundle_data->child, data_set); data_set 320 lib/pacemaker/pcmk_sched_bundle.c promote_demote_constraints(rsc, data_set); data_set 326 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 332 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 338 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 344 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 381 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 394 lib/pacemaker/pcmk_sched_bundle.c scratch = sort_nodes_by_weight(scratch, NULL, data_set); data_set 414 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 467 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 486 lib/pacemaker/pcmk_sched_bundle.c FALSE, data_set); data_set 492 lib/pacemaker/pcmk_sched_bundle.c constraint, data_set); data_set 518 lib/pacemaker/pcmk_sched_bundle.c constraint, data_set); data_set 640 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 659 lib/pacemaker/pcmk_sched_bundle.c current, data_set); data_set 762 lib/pacemaker/pcmk_sched_bundle.c filter, type, data_set); data_set 814 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 822 lib/pacemaker/pcmk_sched_bundle.c filter, type, data_set); data_set 830 lib/pacemaker/pcmk_sched_bundle.c type, data_set); data_set 844 lib/pacemaker/pcmk_sched_bundle.c then_child_action, node, flags, filter, type, data_set); data_set 850 lib/pacemaker/pcmk_sched_bundle.c update_action(next->action, data_set); data_set 894 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_expand(pe_resource_t *rsc, pe_working_set_t * data_set) data_set 903 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->expand(bundle_data->child, data_set); data_set 912 lib/pacemaker/pcmk_sched_bundle.c && pe__bundle_needs_remote_name(replica->remote, data_set)) { data_set 926 lib/pacemaker/pcmk_sched_bundle.c data_set, data_set 935 lib/pacemaker/pcmk_sched_bundle.c NULL, data_set); data_set 955 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->expand(replica->ip, data_set); data_set 958 lib/pacemaker/pcmk_sched_bundle.c replica->container->cmds->expand(replica->container, data_set); data_set 961 lib/pacemaker/pcmk_sched_bundle.c replica->remote->cmds->expand(replica->remote, data_set); data_set 969 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t * data_set) data_set 985 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 990 lib/pacemaker/pcmk_sched_bundle.c force, data_set); data_set 995 lib/pacemaker/pcmk_sched_bundle.c force, data_set); data_set 1026 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 1034 lib/pacemaker/pcmk_sched_bundle.c data_set)) { data_set 1053 lib/pacemaker/pcmk_sched_bundle.c pe_order_probe, data_set); data_set 1066 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_log_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1079 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->ip, data_set); data_set 1082 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->container, data_set); data_set 1085 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->remote, data_set); data_set 1088 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->child, data_set); data_set 20 lib/pacemaker/pcmk_sched_clone.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 98 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 210 lib/pacemaker/pcmk_sched_clone.c list1 = sort_nodes_by_weight(list1, current_node1, data_set); data_set 211 lib/pacemaker/pcmk_sched_clone.c list2 = sort_nodes_by_weight(list2, current_node2, data_set); data_set 253 lib/pacemaker/pcmk_sched_clone.c sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 408 lib/pacemaker/pcmk_sched_clone.c rc = order_instance_by_colocation(resource1, resource2, data_set); data_set 474 lib/pacemaker/pcmk_sched_clone.c int limit, pe_working_set_t *data_set) data_set 511 lib/pacemaker/pcmk_sched_clone.c chosen = rsc->cmds->allocate(rsc, prefer, data_set); data_set 572 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set); data_set 576 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set) data_set 640 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 665 lib/pacemaker/pcmk_sched_clone.c resource_location(child, NULL, -INFINITY, "clone:limit_reached", data_set); data_set 668 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 681 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 711 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 726 lib/pacemaker/pcmk_sched_clone.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 727 lib/pacemaker/pcmk_sched_clone.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 730 lib/pacemaker/pcmk_sched_clone.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 731 lib/pacemaker/pcmk_sched_clone.c rsc->children = g_list_sort_with_data(rsc->children, sort_clone_instance, data_set); data_set 732 lib/pacemaker/pcmk_sched_clone.c distribute_children(rsc, rsc->children, nodes, clone_data->clone_max, clone_data->clone_node_max, data_set); data_set 736 lib/pacemaker/pcmk_sched_clone.c pcmk__set_instance_roles(rsc, data_set); data_set 831 lib/pacemaker/pcmk_sched_clone.c child_ordering_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 872 lib/pacemaker/pcmk_sched_clone.c clone_create_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 877 lib/pacemaker/pcmk_sched_clone.c clone_create_pseudo_actions(rsc, rsc->children, &clone_data->start_notify, &clone_data->stop_notify,data_set); data_set 878 lib/pacemaker/pcmk_sched_clone.c child_ordering_constraints(rsc, data_set); data_set 880 lib/pacemaker/pcmk_sched_clone.c create_promotable_actions(rsc, data_set); data_set 886 lib/pacemaker/pcmk_sched_clone.c pe_resource_t * rsc, GList *children, notify_data_t **start_notify, notify_data_t **stop_notify, pe_working_set_t * data_set) data_set 906 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 917 lib/pacemaker/pcmk_sched_clone.c start = create_pseudo_resource_op(rsc, RSC_START, !child_starting, TRUE, data_set); data_set 918 lib/pacemaker/pcmk_sched_clone.c started = create_pseudo_resource_op(rsc, RSC_STARTED, !child_starting, FALSE, data_set); data_set 926 lib/pacemaker/pcmk_sched_clone.c *start_notify = create_notification_boundaries(rsc, RSC_START, start, started, data_set); data_set 930 lib/pacemaker/pcmk_sched_clone.c stop = create_pseudo_resource_op(rsc, RSC_STOP, !child_stopping, TRUE, data_set); data_set 931 lib/pacemaker/pcmk_sched_clone.c stopped = create_pseudo_resource_op(rsc, RSC_STOPPED, !child_stopping, TRUE, data_set); data_set 938 lib/pacemaker/pcmk_sched_clone.c *stop_notify = create_notification_boundaries(rsc, RSC_STOP, stop, stopped, data_set); data_set 947 lib/pacemaker/pcmk_sched_clone.c clone_internal_constraints(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 957 lib/pacemaker/pcmk_sched_clone.c pe_order_optional, data_set); data_set 959 lib/pacemaker/pcmk_sched_clone.c pe_order_runnable_left, data_set); data_set 961 lib/pacemaker/pcmk_sched_clone.c pe_order_runnable_left, data_set); data_set 965 lib/pacemaker/pcmk_sched_clone.c pe_order_optional, data_set); data_set 967 lib/pacemaker/pcmk_sched_clone.c pe_order_runnable_left, data_set); data_set 977 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 981 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 983 lib/pacemaker/pcmk_sched_clone.c pe_order_implies_then_printed, data_set); data_set 986 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 990 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 992 lib/pacemaker/pcmk_sched_clone.c pe_order_implies_then_printed, data_set); data_set 994 lib/pacemaker/pcmk_sched_clone.c pcmk__order_stops(child_rsc, last_rsc, pe_order_optional, data_set); data_set 1000 lib/pacemaker/pcmk_sched_clone.c promotable_constraints(rsc, data_set); data_set 1061 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1074 lib/pacemaker/pcmk_sched_clone.c scratch = sort_nodes_by_weight(scratch, NULL, data_set); data_set 1095 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1107 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1131 lib/pacemaker/pcmk_sched_clone.c promotable_colocation_rh(dependent, primary, constraint, data_set); data_set 1164 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1169 lib/pacemaker/pcmk_sched_clone.c constraint, data_set); data_set 1209 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1324 lib/pacemaker/pcmk_sched_clone.c clone_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1335 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->start_notify, data_set); data_set 1336 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->start_notify, data_set); data_set 1341 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->stop_notify, data_set); data_set 1342 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->stop_notify, data_set); data_set 1347 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->promote_notify, data_set); data_set 1348 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->promote_notify, data_set); data_set 1353 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->demote_notify, data_set); data_set 1354 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->demote_notify, data_set); data_set 1363 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->expand(child_rsc, data_set); data_set 1366 lib/pacemaker/pcmk_sched_clone.c native_expand(rsc, data_set); data_set 1425 lib/pacemaker/pcmk_sched_clone.c gboolean force, pe_working_set_t *data_set) data_set 1435 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1444 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1471 lib/pacemaker/pcmk_sched_clone.c return child->cmds->create_probe(child, node, complete, force, data_set); data_set 1476 lib/pacemaker/pcmk_sched_clone.c gboolean force, pe_working_set_t * data_set) data_set 1506 lib/pacemaker/pcmk_sched_clone.c any_created = probe_unique_clone(rsc, node, complete, force, data_set); data_set 1509 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 22 lib/pacemaker/pcmk_sched_colocation.c __rsc = pcmk__find_constraint_resource(data_set->resources, __name); \ data_set 134 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 171 lib/pacemaker/pcmk_sched_colocation.c pe_order_anti_colocation, data_set); data_set 194 lib/pacemaker/pcmk_sched_colocation.c bool influence, pe_working_set_t *data_set) data_set 245 lib/pacemaker/pcmk_sched_colocation.c data_set->colocation_constraints = g_list_append(data_set->colocation_constraints, data_set 250 lib/pacemaker/pcmk_sched_colocation.c new_con->primary_role, data_set); data_set 252 lib/pacemaker/pcmk_sched_colocation.c new_con->dependent_role, data_set); data_set 287 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 327 lib/pacemaker/pcmk_sched_colocation.c influence_s), data_set); data_set 345 lib/pacemaker/pcmk_sched_colocation.c influence_s), data_set); data_set 379 lib/pacemaker/pcmk_sched_colocation.c influence, data_set); data_set 387 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 427 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 437 lib/pacemaker/pcmk_sched_colocation.c role_2, influence, data_set); data_set 448 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 468 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 476 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 497 lib/pacemaker/pcmk_sched_colocation.c pe_resource_t *dependent = pcmk__find_constraint_resource(data_set->resources, data_set 499 lib/pacemaker/pcmk_sched_colocation.c pe_resource_t *primary = pcmk__find_constraint_resource(data_set->resources, data_set 526 lib/pacemaker/pcmk_sched_colocation.c dependent = find_clone_instance(dependent, dependent_instance, data_set); data_set 536 lib/pacemaker/pcmk_sched_colocation.c primary = find_clone_instance(primary, primary_instance, data_set); data_set 557 lib/pacemaker/pcmk_sched_colocation.c unpack_influence(id, dependent, influence_s), data_set); data_set 563 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 593 lib/pacemaker/pcmk_sched_colocation.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 605 lib/pacemaker/pcmk_sched_colocation.c if (!pcmk__valid_resource_or_tag(data_set, dependent_id, &dependent, data_set 612 lib/pacemaker/pcmk_sched_colocation.c if (!pcmk__valid_resource_or_tag(data_set, primary_id, &primary, data_set 638 lib/pacemaker/pcmk_sched_colocation.c true, data_set)) { data_set 655 lib/pacemaker/pcmk_sched_colocation.c true, data_set)) { data_set 688 lib/pacemaker/pcmk_sched_colocation.c pcmk__unpack_colocation(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 707 lib/pacemaker/pcmk_sched_colocation.c data_set) != pcmk_rc_ok) { data_set 718 lib/pacemaker/pcmk_sched_colocation.c set = expand_idref(set, data_set->input); data_set 726 lib/pacemaker/pcmk_sched_colocation.c unpack_colocation_set(set, score_i, id, influence_s, data_set); data_set 729 lib/pacemaker/pcmk_sched_colocation.c colocate_rsc_sets(id, last, set, score_i, influence_s, data_set); data_set 740 lib/pacemaker/pcmk_sched_colocation.c unpack_simple_colocation(xml_obj, id, influence_s, data_set); data_set 746 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 758 lib/pacemaker/pcmk_sched_colocation.c pcmk__block_colocated_starts(action, data_set); data_set 759 lib/pacemaker/pcmk_sched_colocation.c update_action(action, data_set); data_set 773 lib/pacemaker/pcmk_sched_colocation.c pcmk__block_colocated_starts(pe_action_t *action, pe_working_set_t *data_set) data_set 810 lib/pacemaker/pcmk_sched_colocation.c mark_start_blocked(colocate_with->dependent, action->rsc, data_set); data_set 31 lib/pacemaker/pcmk_sched_constraints.c evaluate_lifetime(xmlNode *lifetime, pe_working_set_t *data_set) data_set 36 lib/pacemaker/pcmk_sched_constraints.c result = pe_evaluate_rules(lifetime, NULL, data_set->now, next_change); data_set 40 lib/pacemaker/pcmk_sched_constraints.c pe__update_recheck_time(recheck, data_set); data_set 56 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_constraints(pe_working_set_t *data_set) data_set 59 lib/pacemaker/pcmk_sched_constraints.c data_set->input); data_set 84 lib/pacemaker/pcmk_sched_constraints.c if ((lifetime != NULL) && !evaluate_lifetime(lifetime, data_set)) { data_set 88 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_ordering(xml_obj, data_set); data_set 91 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_colocation(xml_obj, data_set); data_set 94 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_location(xml_obj, data_set); data_set 97 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_rsc_ticket(xml_obj, data_set); data_set 140 lib/pacemaker/pcmk_sched_constraints.c find_constraint_tag(pe_working_set_t *data_set, const char *id, pe_tag_t **tag) data_set 145 lib/pacemaker/pcmk_sched_constraints.c if (g_hash_table_lookup_extended(data_set->template_rsc_sets, id, data_set 155 lib/pacemaker/pcmk_sched_constraints.c if (g_hash_table_lookup_extended(data_set->tags, id, data_set 182 lib/pacemaker/pcmk_sched_constraints.c pcmk__valid_resource_or_tag(pe_working_set_t *data_set, const char *id, data_set 186 lib/pacemaker/pcmk_sched_constraints.c *rsc = pcmk__find_constraint_resource(data_set->resources, id); data_set 192 lib/pacemaker/pcmk_sched_constraints.c if ((tag != NULL) && find_constraint_tag(data_set, id, tag)) { data_set 214 lib/pacemaker/pcmk_sched_constraints.c pcmk__expand_tags_in_sets(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 238 lib/pacemaker/pcmk_sched_constraints.c if (!pcmk__valid_resource_or_tag(data_set, ID(xml_rsc), &rsc, data_set 333 lib/pacemaker/pcmk_sched_constraints.c bool convert_rsc, pe_working_set_t *data_set) data_set 357 lib/pacemaker/pcmk_sched_constraints.c if (!pcmk__valid_resource_or_tag(data_set, id, &rsc, &tag)) { data_set 412 lib/pacemaker/pcmk_sched_constraints.c pcmk__create_internal_constraints(pe_working_set_t *data_set) data_set 415 lib/pacemaker/pcmk_sched_constraints.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 418 lib/pacemaker/pcmk_sched_constraints.c rsc->cmds->internal_constraints(rsc, data_set); data_set 56 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 110 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 200 lib/pacemaker/pcmk_sched_fencing.c create_secondary_notification(action, rsc, stonith_op, data_set); data_set 225 lib/pacemaker/pcmk_sched_fencing.c pe_order_optional, data_set); data_set 276 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 284 lib/pacemaker/pcmk_sched_fencing.c rsc_stonith_ordering(child_rsc, stonith_op, data_set); data_set 293 lib/pacemaker/pcmk_sched_fencing.c order_start_vs_fencing(rsc, stonith_op, data_set); data_set 294 lib/pacemaker/pcmk_sched_fencing.c order_stop_vs_fencing(rsc, stonith_op, data_set); data_set 310 lib/pacemaker/pcmk_sched_fencing.c pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set) data_set 312 lib/pacemaker/pcmk_sched_fencing.c CRM_CHECK(stonith_op && data_set, return); data_set 313 lib/pacemaker/pcmk_sched_fencing.c for (GList *r = data_set->resources; r != NULL; r = r->next) { data_set 314 lib/pacemaker/pcmk_sched_fencing.c rsc_stonith_ordering((pe_resource_t *) r->data, stonith_op, data_set); data_set 330 lib/pacemaker/pcmk_sched_fencing.c enum pe_ordering order, pe_working_set_t *data_set) data_set 339 lib/pacemaker/pcmk_sched_fencing.c if (pcmk__is_unfence_device(rsc, data_set) data_set 346 lib/pacemaker/pcmk_sched_fencing.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); data_set 355 lib/pacemaker/pcmk_sched_fencing.c trigger_unfencing(NULL, node, reason, NULL, data_set); data_set 369 lib/pacemaker/pcmk_sched_fencing.c pcmk__fence_guest(pe_node_t *node, pe_working_set_t *data_set) data_set 400 lib/pacemaker/pcmk_sched_fencing.c FALSE, data_set); data_set 409 lib/pacemaker/pcmk_sched_fencing.c NULL, FALSE, data_set); data_set 450 lib/pacemaker/pcmk_sched_fencing.c pcmk__order_vs_fence(stonith_op, data_set); data_set 482 lib/pacemaker/pcmk_sched_fencing.c const pe_working_set_t *data_set) data_set 485 lib/pacemaker/pcmk_sched_fencing.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing); data_set 86 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 114 lib/pacemaker/pcmk_sched_group.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 115 lib/pacemaker/pcmk_sched_group.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 123 lib/pacemaker/pcmk_sched_group.c node = child_rsc->cmds->allocate(child_rsc, prefer, data_set); data_set 142 lib/pacemaker/pcmk_sched_group.c group_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 153 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 161 lib/pacemaker/pcmk_sched_group.c RSC_STARTED, NULL, TRUE /* !group_data->child_starting */ , TRUE, data_set); data_set 168 lib/pacemaker/pcmk_sched_group.c RSC_STOPPED, NULL, TRUE /* !group_data->child_stopping */ , TRUE, data_set); data_set 173 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, demote_key(rsc), RSC_DEMOTE, NULL, TRUE, TRUE, data_set); data_set 176 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, demoted_key(rsc), RSC_DEMOTED, NULL, TRUE, TRUE, data_set); data_set 179 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, promote_key(rsc), RSC_PROMOTE, NULL, TRUE, TRUE, data_set); data_set 182 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, promoted_key(rsc), RSC_PROMOTED, NULL, TRUE, TRUE, data_set); data_set 225 lib/pacemaker/pcmk_sched_group.c group_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 236 lib/pacemaker/pcmk_sched_group.c pe_order_optional, data_set); data_set 238 lib/pacemaker/pcmk_sched_group.c pe_order_runnable_left, data_set); data_set 240 lib/pacemaker/pcmk_sched_group.c pe_order_runnable_left, data_set); data_set 250 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 262 lib/pacemaker/pcmk_sched_group.c data_set); data_set 268 lib/pacemaker/pcmk_sched_group.c data_set); data_set 271 lib/pacemaker/pcmk_sched_group.c RSC_DEMOTED, stopped, data_set); data_set 274 lib/pacemaker/pcmk_sched_group.c RSC_PROMOTED, started, data_set); data_set 279 lib/pacemaker/pcmk_sched_group.c data_set); data_set 284 lib/pacemaker/pcmk_sched_group.c data_set); data_set 286 lib/pacemaker/pcmk_sched_group.c stop|pe_order_implies_first_printed, data_set); data_set 289 lib/pacemaker/pcmk_sched_group.c stopped, data_set); data_set 291 lib/pacemaker/pcmk_sched_group.c started, data_set); data_set 295 lib/pacemaker/pcmk_sched_group.c start|pe_order_implies_first_printed, data_set); data_set 300 lib/pacemaker/pcmk_sched_group.c data_set); data_set 304 lib/pacemaker/pcmk_sched_group.c pcmk__order_starts(last_rsc, child_rsc, start, data_set); data_set 306 lib/pacemaker/pcmk_sched_group.c pe_order_optional|pe_order_restart, data_set); data_set 310 lib/pacemaker/pcmk_sched_group.c RSC_PROMOTE, start, data_set); data_set 313 lib/pacemaker/pcmk_sched_group.c data_set); data_set 317 lib/pacemaker/pcmk_sched_group.c pcmk__order_starts(rsc, child_rsc, pe_order_none, data_set); data_set 321 lib/pacemaker/pcmk_sched_group.c data_set); data_set 333 lib/pacemaker/pcmk_sched_group.c data_set); data_set 345 lib/pacemaker/pcmk_sched_group.c pcmk__order_stops(rsc, last_rsc, stop_stop_flags, data_set); data_set 347 lib/pacemaker/pcmk_sched_group.c stop_stopped_flags, data_set); data_set 351 lib/pacemaker/pcmk_sched_group.c stop_stop_flags, data_set); data_set 353 lib/pacemaker/pcmk_sched_group.c stop_stopped_flags, data_set); data_set 361 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 383 lib/pacemaker/pcmk_sched_group.c data_set); data_set 397 lib/pacemaker/pcmk_sched_group.c data_set); data_set 404 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 424 lib/pacemaker/pcmk_sched_group.c data_set); data_set 430 lib/pacemaker/pcmk_sched_group.c data_set); data_set 445 lib/pacemaker/pcmk_sched_group.c data_set); data_set 497 lib/pacemaker/pcmk_sched_group.c enum pe_ordering type, pe_working_set_t *data_set) data_set 504 lib/pacemaker/pcmk_sched_group.c data_set); data_set 513 lib/pacemaker/pcmk_sched_group.c data_set); data_set 550 lib/pacemaker/pcmk_sched_group.c group_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 555 lib/pacemaker/pcmk_sched_group.c native_expand(rsc, data_set); data_set 560 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->expand(child_rsc, data_set); data_set 53 lib/pacemaker/pcmk_sched_location.c pe_working_set_t *data_set, data_set 71 lib/pacemaker/pcmk_sched_location.c rule_xml = expand_idref(rule_xml, data_set->input); data_set 99 lib/pacemaker/pcmk_sched_location.c data_set); data_set 130 lib/pacemaker/pcmk_sched_location.c match_L = pcmk__copy_node_list(data_set->nodes, true); data_set 138 lib/pacemaker/pcmk_sched_location.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 143 lib/pacemaker/pcmk_sched_location.c .params = pe_rsc_params(rsc, node, data_set), data_set 148 lib/pacemaker/pcmk_sched_location.c data_set->now, next_change, &match_data); data_set 201 lib/pacemaker/pcmk_sched_location.c const char *score, pe_working_set_t *data_set, data_set 222 lib/pacemaker/pcmk_sched_location.c pe_node_t *match = pe_find_node(data_set->nodes, node); data_set 228 lib/pacemaker/pcmk_sched_location.c data_set); data_set 243 lib/pacemaker/pcmk_sched_location.c data_set, re_match_data); data_set 257 lib/pacemaker/pcmk_sched_location.c pe__update_recheck_time(t, data_set); data_set 290 lib/pacemaker/pcmk_sched_location.c unpack_simple_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 298 lib/pacemaker/pcmk_sched_location.c rsc_lh = pcmk__find_constraint_resource(data_set->resources, value); data_set 299 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, rsc_lh, NULL, NULL, data_set, NULL); data_set 322 lib/pacemaker/pcmk_sched_location.c for (rIter = data_set->resources; rIter; rIter = rIter->next) { data_set 345 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, data_set 351 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, NULL); data_set 368 lib/pacemaker/pcmk_sched_location.c pe_working_set_t *data_set) data_set 389 lib/pacemaker/pcmk_sched_location.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 400 lib/pacemaker/pcmk_sched_location.c if (!pcmk__valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh)) { data_set 416 lib/pacemaker/pcmk_sched_location.c false, data_set)) { data_set 441 lib/pacemaker/pcmk_sched_location.c unpack_location_set(xmlNode *location, xmlNode *set, pe_working_set_t *data_set) data_set 465 lib/pacemaker/pcmk_sched_location.c resource = pcmk__find_constraint_resource(data_set->resources, data_set 473 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(location, resource, role, local_score, data_set, data_set 481 lib/pacemaker/pcmk_sched_location.c pcmk__unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 489 lib/pacemaker/pcmk_sched_location.c if (unpack_location_tags(xml_obj, &expanded_xml, data_set) != pcmk_rc_ok) { data_set 502 lib/pacemaker/pcmk_sched_location.c set = expand_idref(set, data_set->input); data_set 504 lib/pacemaker/pcmk_sched_location.c || (unpack_location_set(xml_obj, set, data_set) != pcmk_rc_ok)) { data_set 519 lib/pacemaker/pcmk_sched_location.c unpack_simple_location(xml_obj, data_set); data_set 541 lib/pacemaker/pcmk_sched_location.c pe_node_t *node, pe_working_set_t *data_set) data_set 583 lib/pacemaker/pcmk_sched_location.c data_set->placement_constraints = g_list_prepend(data_set->placement_constraints, data_set 598 lib/pacemaker/pcmk_sched_location.c pcmk__apply_locations(pe_working_set_t *data_set) data_set 600 lib/pacemaker/pcmk_sched_location.c for (GList *iter = data_set->placement_constraints; data_set 29 lib/pacemaker/pcmk_sched_messages.c log_resource_details(pe_working_set_t *data_set) data_set 31 lib/pacemaker/pcmk_sched_messages.c pcmk__output_t *out = data_set->priv; data_set 41 lib/pacemaker/pcmk_sched_messages.c for (GList *item = data_set->resources; item != NULL; item = item->next) { data_set 55 lib/pacemaker/pcmk_sched_messages.c log_all_actions(pe_working_set_t *data_set) data_set 60 lib/pacemaker/pcmk_sched_messages.c pcmk__output_t *prev_out = data_set->priv; data_set 68 lib/pacemaker/pcmk_sched_messages.c data_set->priv = out; data_set 71 lib/pacemaker/pcmk_sched_messages.c LogNodeActions(data_set); data_set 73 lib/pacemaker/pcmk_sched_messages.c g_list_foreach(data_set->resources, (GFunc) LogActions, data_set); data_set 79 lib/pacemaker/pcmk_sched_messages.c data_set->priv = prev_out; data_set 91 lib/pacemaker/pcmk_sched_messages.c pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input, data_set 96 lib/pacemaker/pcmk_sched_messages.c CRM_ASSERT(xml_input || pcmk_is_set(data_set->flags, pe_flag_have_status)); data_set 98 lib/pacemaker/pcmk_sched_messages.c if (!pcmk_is_set(data_set->flags, pe_flag_have_status)) { data_set 99 lib/pacemaker/pcmk_sched_messages.c set_working_set_defaults(data_set); data_set 100 lib/pacemaker/pcmk_sched_messages.c data_set->input = xml_input; data_set 101 lib/pacemaker/pcmk_sched_messages.c data_set->now = now; data_set 107 lib/pacemaker/pcmk_sched_messages.c if (data_set->now == NULL) { data_set 108 lib/pacemaker/pcmk_sched_messages.c data_set->now = crm_time_new(NULL); data_set 112 lib/pacemaker/pcmk_sched_messages.c stage0(data_set); data_set 113 lib/pacemaker/pcmk_sched_messages.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location) && data_set 115 lib/pacemaker/pcmk_sched_messages.c log_resource_details(data_set); data_set 119 lib/pacemaker/pcmk_sched_messages.c stage2(data_set); data_set 121 lib/pacemaker/pcmk_sched_messages.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 125 lib/pacemaker/pcmk_sched_messages.c pcmk__create_internal_constraints(data_set); data_set 128 lib/pacemaker/pcmk_sched_messages.c stage4(data_set); data_set 131 lib/pacemaker/pcmk_sched_messages.c stage5(data_set); data_set 134 lib/pacemaker/pcmk_sched_messages.c stage6(data_set); data_set 136 lib/pacemaker/pcmk_sched_messages.c pcmk__apply_orderings(data_set); data_set 137 lib/pacemaker/pcmk_sched_messages.c log_all_actions(data_set); data_set 140 lib/pacemaker/pcmk_sched_messages.c stage8(data_set); data_set 145 lib/pacemaker/pcmk_sched_messages.c gIter = data_set->actions; data_set 158 lib/pacemaker/pcmk_sched_messages.c return data_set->graph; data_set 33 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 35 lib/pacemaker/pcmk_sched_native.c xmlNode *operation, pe_working_set_t *data_set); data_set 37 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 39 lib/pacemaker/pcmk_sched_native.c xmlNode *operation, pe_working_set_t *data_set); data_set 41 lib/pacemaker/pcmk_sched_native.c void ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set); data_set 42 lib/pacemaker/pcmk_sched_native.c gboolean DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set); data_set 43 lib/pacemaker/pcmk_sched_native.c gboolean StopRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 44 lib/pacemaker/pcmk_sched_native.c gboolean StartRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 45 lib/pacemaker/pcmk_sched_native.c gboolean DemoteRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 47 lib/pacemaker/pcmk_sched_native.c pe_working_set_t * data_set); data_set 48 lib/pacemaker/pcmk_sched_native.c gboolean RoleError(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 49 lib/pacemaker/pcmk_sched_native.c gboolean NullOp(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 69 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 89 lib/pacemaker/pcmk_sched_native.c native_choose_node(pe_resource_t * rsc, pe_node_t * prefer, pe_working_set_t * data_set) data_set 98 lib/pacemaker/pcmk_sched_native.c process_utilization(rsc, &prefer, data_set); data_set 110 lib/pacemaker/pcmk_sched_native.c nodes = sort_nodes_by_weight(nodes, pe__current_node(rsc), data_set); data_set 495 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 503 lib/pacemaker/pcmk_sched_native.c rsc->parent->cmds->allocate(rsc->parent, prefer, data_set); data_set 516 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(true, rsc, "Pre-alloc", rsc->allowed_nodes, data_set); data_set 533 lib/pacemaker/pcmk_sched_native.c primary->cmds->allocate(primary, NULL, data_set); data_set 534 lib/pacemaker/pcmk_sched_native.c rsc->cmds->rsc_colocation_lh(rsc, primary, constraint, data_set); data_set 547 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(true, rsc, "Post-coloc", rsc->allowed_nodes, data_set); data_set 567 lib/pacemaker/pcmk_sched_native.c resource_location(rsc, NULL, -INFINITY, XML_RSC_ATTR_TARGET_ROLE, data_set); data_set 570 lib/pacemaker/pcmk_sched_native.c && !pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 571 lib/pacemaker/pcmk_sched_native.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 577 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 578 lib/pacemaker/pcmk_sched_native.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 579 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 580 lib/pacemaker/pcmk_sched_native.c && !pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 603 lib/pacemaker/pcmk_sched_native.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 608 lib/pacemaker/pcmk_sched_native.c && native_choose_node(rsc, prefer, data_set)) { data_set 627 lib/pacemaker/pcmk_sched_native.c pe_node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 699 lib/pacemaker/pcmk_sched_native.c xmlNode * operation, pe_working_set_t * data_set) data_set 792 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); data_set 814 lib/pacemaker/pcmk_sched_native.c pe_order_runnable_left, data_set); data_set 826 lib/pacemaker/pcmk_sched_native.c mon = custom_action(rsc, key, name, node, is_optional, TRUE, data_set); data_set 857 lib/pacemaker/pcmk_sched_native.c data_set); data_set 861 lib/pacemaker/pcmk_sched_native.c data_set); data_set 866 lib/pacemaker/pcmk_sched_native.c data_set); data_set 871 lib/pacemaker/pcmk_sched_native.c data_set); data_set 877 lib/pacemaker/pcmk_sched_native.c Recurring(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, pe_working_set_t * data_set) data_set 888 lib/pacemaker/pcmk_sched_native.c RecurringOp(rsc, start, node, operation, data_set); data_set 896 lib/pacemaker/pcmk_sched_native.c xmlNode * operation, pe_working_set_t * data_set) data_set 961 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); data_set 968 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_runnable_left, data_set); data_set 976 lib/pacemaker/pcmk_sched_native.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1008 lib/pacemaker/pcmk_sched_native.c stopped_mon = custom_action(rsc, strdup(key), name, stop_node, is_optional, TRUE, data_set); data_set 1052 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1089 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, pe_working_set_t * data_set) data_set 1100 lib/pacemaker/pcmk_sched_native.c RecurringOp_Stopped(rsc, start, node, operation, data_set); data_set 1107 lib/pacemaker/pcmk_sched_native.c handle_migration_actions(pe_resource_t * rsc, pe_node_t *current, pe_node_t *chosen, pe_working_set_t * data_set) data_set 1122 lib/pacemaker/pcmk_sched_native.c RSC_MIGRATE, current, TRUE, TRUE, data_set); data_set 1126 lib/pacemaker/pcmk_sched_native.c RSC_MIGRATED, chosen, TRUE, TRUE, data_set); data_set 1143 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 1152 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 1157 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1163 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1167 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1195 lib/pacemaker/pcmk_sched_native.c native_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1233 lib/pacemaker/pcmk_sched_native.c pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)? "and cleanup " : "", data_set 1237 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 1238 lib/pacemaker/pcmk_sched_native.c DeleteRsc(rsc, dangling_source, FALSE, data_set); data_set 1347 lib/pacemaker/pcmk_sched_native.c if (rsc_action_matrix[role][next_role] (rsc, current, !need_stop, data_set) == FALSE) { data_set 1366 lib/pacemaker/pcmk_sched_native.c data_set) == FALSE) { data_set 1379 lib/pacemaker/pcmk_sched_native.c if (rsc_action_matrix[role][next_role] (rsc, chosen, FALSE, data_set) == FALSE) { data_set 1395 lib/pacemaker/pcmk_sched_native.c Recurring(rsc, start, chosen, data_set); data_set 1396 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(rsc, start, chosen, data_set); data_set 1401 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(rsc, NULL, NULL, data_set); data_set 1422 lib/pacemaker/pcmk_sched_native.c handle_migration_actions(rsc, current, chosen, data_set); data_set 1454 lib/pacemaker/pcmk_sched_native.c allowed_nodes_as_list(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1470 lib/pacemaker/pcmk_sched_native.c native_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1490 lib/pacemaker/pcmk_sched_native.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing) data_set 1495 lib/pacemaker/pcmk_sched_native.c && !pcmk__str_eq(data_set->placement_strategy, data_set 1502 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1510 lib/pacemaker/pcmk_sched_native.c pe_order_promoted_implies_first, data_set); data_set 1514 lib/pacemaker/pcmk_sched_native.c pe_order_runnable_left, data_set); data_set 1521 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1525 lib/pacemaker/pcmk_sched_native.c allowed_nodes = allowed_nodes_as_list(rsc, data_set); data_set 1533 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); data_set 1555 lib/pacemaker/pcmk_sched_native.c pe_order_optional|pe_order_same_node, data_set); data_set 1560 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1568 lib/pacemaker/pcmk_sched_native.c rsc->id, data_set->placement_strategy); data_set 1575 lib/pacemaker/pcmk_sched_native.c pe_action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1584 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1591 lib/pacemaker/pcmk_sched_native.c pe_action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1600 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1604 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_load, data_set); data_set 1631 lib/pacemaker/pcmk_sched_native.c RSC_STOP, pe_order_optional, data_set); data_set 1643 lib/pacemaker/pcmk_sched_native.c remote_rsc = pe__resource_contains_guest_node(data_set, data_set 1674 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1679 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_implies_first, data_set); data_set 1687 lib/pacemaker/pcmk_sched_native.c rsc->container, NULL, NULL, true, data_set); data_set 1702 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 1717 lib/pacemaker/pcmk_sched_native.c primary->cmds->rsc_colocation_rh(dependent, primary, constraint, data_set); data_set 1723 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 1850 lib/pacemaker/pcmk_sched_native.c enum pe_ordering type, pe_working_set_t *data_set) data_set 1973 lib/pacemaker/pcmk_sched_native.c update_action(then, data_set); data_set 1997 lib/pacemaker/pcmk_sched_native.c native_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 2008 lib/pacemaker/pcmk_sched_native.c graph_element_from_action(action, data_set); data_set 2014 lib/pacemaker/pcmk_sched_native.c child_rsc->cmds->expand(child_rsc, data_set); data_set 2033 lib/pacemaker/pcmk_sched_native.c LogActions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 2035 lib/pacemaker/pcmk_sched_native.c pcmk__output_t *out = data_set->priv; data_set 2043 lib/pacemaker/pcmk_sched_native.c pcmk__bundle_log_actions(rsc, data_set); data_set 2048 lib/pacemaker/pcmk_sched_native.c g_list_foreach(rsc->children, (GFunc) LogActions, data_set); data_set 2073 lib/pacemaker/pcmk_sched_native.c StopRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2106 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 2107 lib/pacemaker/pcmk_sched_native.c DeleteRsc(rsc, current, optional, data_set); data_set 2111 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(current, "on", TRUE, NULL, FALSE, data_set); data_set 2124 lib/pacemaker/pcmk_sched_native.c StartRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2132 lib/pacemaker/pcmk_sched_native.c pcmk__order_vs_unfence(rsc, next, start, pe_order_implies_then, data_set); data_set 2143 lib/pacemaker/pcmk_sched_native.c PromoteRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2184 lib/pacemaker/pcmk_sched_native.c DemoteRsc(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2202 lib/pacemaker/pcmk_sched_native.c RoleError(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2211 lib/pacemaker/pcmk_sched_native.c NullOp(pe_resource_t * rsc, pe_node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2219 lib/pacemaker/pcmk_sched_native.c DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set) data_set 2241 lib/pacemaker/pcmk_sched_native.c data_set); data_set 2245 lib/pacemaker/pcmk_sched_native.c data_set); data_set 2252 lib/pacemaker/pcmk_sched_native.c gboolean force, pe_working_set_t * data_set) data_set 2270 lib/pacemaker/pcmk_sched_native.c if (!force && !pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 2284 lib/pacemaker/pcmk_sched_native.c && pe__resource_contains_guest_node(data_set, rsc)) { data_set 2304 lib/pacemaker/pcmk_sched_native.c any_created = child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set) data_set 2388 lib/pacemaker/pcmk_sched_native.c pe_order_optional, data_set); data_set 2410 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 2421 lib/pacemaker/pcmk_sched_native.c probe = custom_action(rsc, key, RSC_STATUS, node, FALSE, TRUE, data_set); data_set 2424 lib/pacemaker/pcmk_sched_native.c pcmk__order_vs_unfence(rsc, node, probe, pe_order_optional, data_set); data_set 2441 lib/pacemaker/pcmk_sched_native.c if (pcmk__is_unfence_device(rsc, data_set) || !pe_rsc_is_clone(top)) { data_set 2457 lib/pacemaker/pcmk_sched_native.c data_set); data_set 2461 lib/pacemaker/pcmk_sched_native.c pe_order_optional, data_set); data_set 2465 lib/pacemaker/pcmk_sched_native.c if (!pcmk__is_unfence_device(rsc, data_set)) { data_set 2479 lib/pacemaker/pcmk_sched_native.c ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set) data_set 2488 lib/pacemaker/pcmk_sched_native.c ReloadRsc(child_rsc, node, data_set); data_set 2526 lib/pacemaker/pcmk_sched_native.c FALSE, TRUE, data_set); data_set 2531 lib/pacemaker/pcmk_sched_native.c data_set); data_set 2534 lib/pacemaker/pcmk_sched_native.c data_set); data_set 207 lib/pacemaker/pcmk_sched_notif.c notify_data_t * n_data, pe_working_set_t * data_set) data_set 238 lib/pacemaker/pcmk_sched_notif.c TRUE, data_set); data_set 252 lib/pacemaker/pcmk_sched_notif.c pe_post_notify(pe_resource_t * rsc, pe_node_t * node, notify_data_t * n_data, pe_working_set_t * data_set) data_set 262 lib/pacemaker/pcmk_sched_notif.c notify = pe_notify(rsc, node, n_data->post, n_data->post_done, n_data, data_set); data_set 291 lib/pacemaker/pcmk_sched_notif.c pe_action_t * end, pe_working_set_t * data_set) data_set 318 lib/pacemaker/pcmk_sched_notif.c TRUE, data_set); data_set 331 lib/pacemaker/pcmk_sched_notif.c TRUE, data_set); data_set 350 lib/pacemaker/pcmk_sched_notif.c TRUE, data_set); data_set 370 lib/pacemaker/pcmk_sched_notif.c TRUE, data_set); data_set 518 lib/pacemaker/pcmk_sched_notif.c pe_working_set_t *data_set) data_set 596 lib/pacemaker/pcmk_sched_notif.c expand_node_list(data_set->nodes, &node_list, &metal_list); data_set 599 lib/pacemaker/pcmk_sched_notif.c expand_node_list(data_set->nodes, &node_list, NULL); data_set 637 lib/pacemaker/pcmk_sched_notif.c create_notifications(pe_resource_t * rsc, notify_data_t * n_data, pe_working_set_t * data_set) data_set 649 lib/pacemaker/pcmk_sched_notif.c create_notifications(child, n_data, data_set); data_set 728 lib/pacemaker/pcmk_sched_notif.c pe_notify(rsc, current_node, n_data->pre, n_data->pre_done, n_data, data_set); data_set 731 lib/pacemaker/pcmk_sched_notif.c pe_post_notify(rsc, current_node, n_data, data_set); data_set 761 lib/pacemaker/pcmk_sched_notif.c pe_notify(rsc, rsc->allocated_to, n_data->pre, n_data->pre_done, n_data, data_set); data_set 763 lib/pacemaker/pcmk_sched_notif.c pe_post_notify(rsc, rsc->allocated_to, n_data, data_set); data_set 790 lib/pacemaker/pcmk_sched_notif.c pe_working_set_t *data_set) data_set 796 lib/pacemaker/pcmk_sched_notif.c data_set); data_set 800 lib/pacemaker/pcmk_sched_notif.c create_notifications(uber_parent(rsc), n_data, data_set); data_set 32 lib/pacemaker/pcmk_sched_ordering.c __rsc = pcmk__find_constraint_resource(data_set->resources, __name); \ data_set 223 lib/pacemaker/pcmk_sched_ordering.c const char *instance_attr, pe_working_set_t *data_set) data_set 235 lib/pacemaker/pcmk_sched_ordering.c rsc = pcmk__find_constraint_resource(data_set->resources, rsc_id); data_set 249 lib/pacemaker/pcmk_sched_ordering.c rsc = find_clone_instance(rsc, instance_id, data_set); data_set 319 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 323 lib/pacemaker/pcmk_sched_ordering.c pe_action_t *clone_min_met = get_pseudo_op(task, data_set); data_set 342 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 348 lib/pacemaker/pcmk_sched_ordering.c NULL, flags|pe_order_runnable_left, data_set); data_set 387 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 400 lib/pacemaker/pcmk_sched_ordering.c action_first, flags, data_set); data_set 405 lib/pacemaker/pcmk_sched_ordering.c unpack_simple_rsc_order(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 429 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 436 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 466 lib/pacemaker/pcmk_sched_ordering.c cons_weight, min_required_before, data_set); data_set 469 lib/pacemaker/pcmk_sched_ordering.c action_then, cons_weight, data_set); data_set 474 lib/pacemaker/pcmk_sched_ordering.c rsc_then, action_then, data_set); data_set 503 lib/pacemaker/pcmk_sched_ordering.c handle_migration_ordering(pe__ordering_t *order, pe_working_set_t *data_set) data_set 548 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 564 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 583 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 591 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 606 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 621 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 629 lib/pacemaker/pcmk_sched_ordering.c NULL, flags, data_set); data_set 669 lib/pacemaker/pcmk_sched_ordering.c enum pe_ordering type, pe_working_set_t *data_set) data_set 687 lib/pacemaker/pcmk_sched_ordering.c order->id = data_set->order_id++; data_set 713 lib/pacemaker/pcmk_sched_ordering.c (data_set->order_id - 1), data_set 717 lib/pacemaker/pcmk_sched_ordering.c data_set->ordering_constraints = g_list_prepend(data_set->ordering_constraints, data_set 719 lib/pacemaker/pcmk_sched_ordering.c handle_migration_ordering(order, data_set); data_set 734 lib/pacemaker/pcmk_sched_ordering.c const char *parent_symmetrical_s, pe_working_set_t *data_set) data_set 797 lib/pacemaker/pcmk_sched_ordering.c then_key, NULL, flags, data_set); data_set 803 lib/pacemaker/pcmk_sched_ordering.c flags, data_set); data_set 828 lib/pacemaker/pcmk_sched_ordering.c flags, data_set); data_set 853 lib/pacemaker/pcmk_sched_ordering.c enum pe_order_kind kind, pe_working_set_t *data_set, data_set 905 lib/pacemaker/pcmk_sched_ordering.c pe_action_t *unordered_action = get_pseudo_op(task, data_set); data_set 922 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 935 lib/pacemaker/pcmk_sched_ordering.c NULL, flags|pe_order_runnable_left, data_set); data_set 985 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 993 lib/pacemaker/pcmk_sched_ordering.c flags, data_set); data_set 1002 lib/pacemaker/pcmk_sched_ordering.c flags, data_set); data_set 1016 lib/pacemaker/pcmk_sched_ordering.c action_2, flags, data_set); data_set 1037 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 1054 lib/pacemaker/pcmk_sched_ordering.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 1066 lib/pacemaker/pcmk_sched_ordering.c if (!pcmk__valid_resource_or_tag(data_set, id_first, &rsc_first, data_set 1073 lib/pacemaker/pcmk_sched_ordering.c if (!pcmk__valid_resource_or_tag(data_set, id_then, &rsc_then, &tag_then)) { data_set 1091 lib/pacemaker/pcmk_sched_ordering.c true, data_set)) { data_set 1108 lib/pacemaker/pcmk_sched_ordering.c true, data_set)) { data_set 1141 lib/pacemaker/pcmk_sched_ordering.c pcmk__unpack_ordering(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 1157 lib/pacemaker/pcmk_sched_ordering.c if (unpack_order_tags(xml_obj, &expanded_xml, data_set) != pcmk_rc_ok) { data_set 1169 lib/pacemaker/pcmk_sched_ordering.c set = expand_idref(set, data_set->input); data_set 1171 lib/pacemaker/pcmk_sched_ordering.c || (unpack_order_set(set, kind, invert, data_set) != pcmk_rc_ok)) { data_set 1181 lib/pacemaker/pcmk_sched_ordering.c if (order_rsc_sets(id, last, set, kind, data_set, data_set 1190 lib/pacemaker/pcmk_sched_ordering.c && (order_rsc_sets(id, set, last, kind, data_set, data_set 1209 lib/pacemaker/pcmk_sched_ordering.c return unpack_simple_rsc_order(xml_obj, data_set); data_set 1245 lib/pacemaker/pcmk_sched_ordering.c pcmk__disable_invalid_orderings(pe_working_set_t *data_set) data_set 1247 lib/pacemaker/pcmk_sched_ordering.c for (GList *iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 1272 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 1274 lib/pacemaker/pcmk_sched_ordering.c for (GList *iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 1319 lib/pacemaker/pcmk_sched_ordering.c pe_order_optional|pe_order_runnable_left, data_set); data_set 1413 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 1461 lib/pacemaker/pcmk_sched_ordering.c lh_action = custom_action(lh_rsc, key, op_type, NULL, TRUE, TRUE, data_set); data_set 1491 lib/pacemaker/pcmk_sched_ordering.c pcmk__apply_orderings(pe_working_set_t *data_set) data_set 1501 lib/pacemaker/pcmk_sched_ordering.c data_set->ordering_constraints = g_list_reverse(data_set->ordering_constraints); data_set 1503 lib/pacemaker/pcmk_sched_ordering.c for (GList *gIter = data_set->ordering_constraints; data_set 1510 lib/pacemaker/pcmk_sched_ordering.c rsc_order_first(rsc, order, data_set); data_set 1525 lib/pacemaker/pcmk_sched_ordering.c g_list_foreach(data_set->actions, (GFunc) pcmk__block_colocated_starts, data_set 1526 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 1529 lib/pacemaker/pcmk_sched_ordering.c pcmk__order_probes(data_set); data_set 1531 lib/pacemaker/pcmk_sched_ordering.c crm_trace("Updating %d actions", g_list_length(data_set->actions)); data_set 1532 lib/pacemaker/pcmk_sched_ordering.c g_list_foreach(data_set->actions, (GFunc) update_action, data_set); data_set 1534 lib/pacemaker/pcmk_sched_ordering.c pcmk__disable_invalid_orderings(data_set); data_set 20 lib/pacemaker/pcmk_sched_promotable.c extern gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 27 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t * data_set) data_set 34 lib/pacemaker/pcmk_sched_promotable.c type, data_set); data_set 41 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 45 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 55 lib/pacemaker/pcmk_sched_promotable.c pcmk__order_starts(last, child, type, data_set); data_set 57 lib/pacemaker/pcmk_sched_promotable.c type, data_set); data_set 67 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t * data_set) data_set 74 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 81 lib/pacemaker/pcmk_sched_promotable.c pe_order_implies_then_printed, data_set); data_set 85 lib/pacemaker/pcmk_sched_promotable.c pe_order_implies_first_printed, data_set); data_set 92 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 98 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 257 lib/pacemaker/pcmk_sched_promotable.c sort_promotable_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 287 lib/pacemaker/pcmk_sched_promotable.c return sort_clone_instance(a, b, data_set); data_set 291 lib/pacemaker/pcmk_sched_promotable.c promotion_order(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 314 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Before", rsc->allowed_nodes, data_set); data_set 335 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Middle", rsc->allowed_nodes, data_set); data_set 386 lib/pacemaker/pcmk_sched_promotable.c resource_location(rsc, NULL, -INFINITY, "__stateful_without_ticket__", data_set); data_set 390 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "After", rsc->allowed_nodes, data_set); data_set 416 lib/pacemaker/pcmk_sched_promotable.c sort_promotable_instance, data_set); data_set 663 lib/pacemaker/pcmk_sched_promotable.c pcmk__set_instance_roles(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 744 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 755 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Pre merge", rsc->allowed_nodes, data_set); data_set 756 lib/pacemaker/pcmk_sched_promotable.c promotion_order(rsc, data_set); data_set 764 lib/pacemaker/pcmk_sched_promotable.c if (pcmk_is_set(data_set->flags, pe_flag_show_scores) && !pcmk__is_daemon) { data_set 765 lib/pacemaker/pcmk_sched_promotable.c if (data_set->priv != NULL) { data_set 766 lib/pacemaker/pcmk_sched_promotable.c pcmk__output_t *out = data_set->priv; data_set 794 lib/pacemaker/pcmk_sched_promotable.c && !pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 795 lib/pacemaker/pcmk_sched_promotable.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 816 lib/pacemaker/pcmk_sched_promotable.c create_promotable_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 838 lib/pacemaker/pcmk_sched_promotable.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 848 lib/pacemaker/pcmk_sched_promotable.c action = create_pseudo_resource_op(rsc, RSC_PROMOTE, !any_promoting, TRUE, data_set); data_set 849 lib/pacemaker/pcmk_sched_promotable.c action_complete = create_pseudo_resource_op(rsc, RSC_PROMOTED, !any_promoting, TRUE, data_set); data_set 853 lib/pacemaker/pcmk_sched_promotable.c rsc, NULL, last_promote_rsc, data_set); data_set 857 lib/pacemaker/pcmk_sched_promotable.c create_notification_boundaries(rsc, RSC_PROMOTE, action, action_complete, data_set); data_set 861 lib/pacemaker/pcmk_sched_promotable.c action = create_pseudo_resource_op(rsc, RSC_DEMOTE, !any_demoting, TRUE, data_set); data_set 862 lib/pacemaker/pcmk_sched_promotable.c action_complete = create_pseudo_resource_op(rsc, RSC_DEMOTED, !any_demoting, TRUE, data_set); data_set 865 lib/pacemaker/pcmk_sched_promotable.c child_demoting_constraints(clone_data, pe_order_optional, rsc, NULL, last_demote_rsc, data_set); data_set 869 lib/pacemaker/pcmk_sched_promotable.c create_notification_boundaries(rsc, RSC_DEMOTE, action, action_complete, data_set); data_set 899 lib/pacemaker/pcmk_sched_promotable.c promote_demote_constraints(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 903 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 907 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 911 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 915 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 919 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 923 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 927 lib/pacemaker/pcmk_sched_promotable.c pe_order_optional, data_set); data_set 932 lib/pacemaker/pcmk_sched_promotable.c promotable_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 940 lib/pacemaker/pcmk_sched_promotable.c promote_demote_constraints(rsc, data_set); data_set 947 lib/pacemaker/pcmk_sched_promotable.c RSC_PROMOTE, pe_order_optional, data_set); data_set 950 lib/pacemaker/pcmk_sched_promotable.c rsc, child_rsc, last_rsc, data_set); data_set 953 lib/pacemaker/pcmk_sched_promotable.c rsc, child_rsc, last_rsc, data_set); data_set 988 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t *data_set) data_set 1031 lib/pacemaker/pcmk_sched_promotable.c FALSE, data_set); data_set 63 lib/pacemaker/pcmk_sched_remote.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 65 lib/pacemaker/pcmk_sched_remote.c if ((lh_rsc != NULL) && (rh_action != NULL) && (data_set != NULL)) { data_set 69 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 75 lib/pacemaker/pcmk_sched_remote.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 77 lib/pacemaker/pcmk_sched_remote.c if ((lh_action != NULL) && (rh_rsc != NULL) && (data_set != NULL)) { data_set 80 lib/pacemaker/pcmk_sched_remote.c pe_order_preserve|extra, data_set); data_set 178 lib/pacemaker/pcmk_sched_remote.c apply_remote_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 219 lib/pacemaker/pcmk_sched_remote.c order_start_then_action(remote_rsc, action, order_opts, data_set); data_set 225 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_first, data_set); data_set 234 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, data_set 244 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_first, data_set); data_set 251 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 264 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 276 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_then, data_set); data_set 286 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, data_set 297 lib/pacemaker/pcmk_sched_remote.c pe_order_runnable_left, data_set); data_set 301 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 309 lib/pacemaker/pcmk_sched_remote.c apply_container_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 333 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, "container failed", FALSE); data_set 356 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 360 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 382 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 395 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_then, data_set); data_set 399 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 412 lib/pacemaker/pcmk_sched_remote.c pcmk__order_remote_connection_actions(pe_working_set_t *data_set) data_set 414 lib/pacemaker/pcmk_sched_remote.c if (!pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 420 lib/pacemaker/pcmk_sched_remote.c for (GList *gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 438 lib/pacemaker/pcmk_sched_remote.c NULL, pe_order_optional, data_set); data_set 482 lib/pacemaker/pcmk_sched_remote.c pe_order_optional, data_set); data_set 498 lib/pacemaker/pcmk_sched_remote.c apply_container_ordering(action, data_set); data_set 502 lib/pacemaker/pcmk_sched_remote.c apply_remote_ordering(action, data_set); data_set 664 lib/pacemaker/pcmk_sched_remote.c pe_working_set_t *data_set) data_set 670 lib/pacemaker/pcmk_sched_remote.c GHashTable *base = pe_rsc_params(rsc, NULL, data_set); data_set 51 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 65 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 79 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 86 lib/pacemaker/pcmk_sched_tickets.c "__loss_of_ticket__", data_set); data_set 96 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 100 lib/pacemaker/pcmk_sched_tickets.c pe_fence_node(data_set, (pe_node_t *) gIter->data, data_set 121 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 129 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 137 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 163 lib/pacemaker/pcmk_sched_tickets.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 216 lib/pacemaker/pcmk_sched_tickets.c data_set->ticket_constraints = g_list_append(data_set->ticket_constraints, data_set 220 lib/pacemaker/pcmk_sched_tickets.c constraints_for_ticket(rsc_lh, new_rsc_ticket, data_set); data_set 227 lib/pacemaker/pcmk_sched_tickets.c const char *loss_policy, pe_working_set_t *data_set) data_set 249 lib/pacemaker/pcmk_sched_tickets.c resource = pcmk__find_constraint_resource(data_set->resources, data_set 258 lib/pacemaker/pcmk_sched_tickets.c rsc_ticket_new(set_id, resource, ticket, role, loss_policy, data_set); data_set 265 lib/pacemaker/pcmk_sched_tickets.c unpack_simple_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 297 lib/pacemaker/pcmk_sched_tickets.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 310 lib/pacemaker/pcmk_sched_tickets.c rsc_lh = pcmk__find_constraint_resource(data_set->resources, id_lh); data_set 326 lib/pacemaker/pcmk_sched_tickets.c rsc_lh = find_clone_instance(rsc_lh, instance_lh, data_set); data_set 335 lib/pacemaker/pcmk_sched_tickets.c rsc_ticket_new(id, rsc_lh, ticket, state_lh, loss_policy, data_set); data_set 341 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 364 lib/pacemaker/pcmk_sched_tickets.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 375 lib/pacemaker/pcmk_sched_tickets.c if (!pcmk__valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh)) { data_set 391 lib/pacemaker/pcmk_sched_tickets.c false, data_set)) { data_set 413 lib/pacemaker/pcmk_sched_tickets.c pcmk__unpack_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 436 lib/pacemaker/pcmk_sched_tickets.c if (data_set->tickets == NULL) { data_set 437 lib/pacemaker/pcmk_sched_tickets.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 444 lib/pacemaker/pcmk_sched_tickets.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 448 lib/pacemaker/pcmk_sched_tickets.c ticket = ticket_new(ticket_str, data_set); data_set 455 lib/pacemaker/pcmk_sched_tickets.c data_set) != pcmk_rc_ok) { data_set 467 lib/pacemaker/pcmk_sched_tickets.c set = expand_idref(set, data_set->input); data_set 470 lib/pacemaker/pcmk_sched_tickets.c data_set) != pcmk_rc_ok)) { data_set 484 lib/pacemaker/pcmk_sched_tickets.c unpack_simple_rsc_ticket(xml_obj, data_set); data_set 392 lib/pacemaker/pcmk_sched_transition.c modify_configuration(pe_working_set_t * data_set, cib_t *cib, pcmk_injections_t *injections) data_set 403 lib/pacemaker/pcmk_sched_transition.c out = data_set->priv; data_set 555 lib/pacemaker/pcmk_sched_transition.c rsc = pe_find_resource(data_set->resources, resource); data_set 796 lib/pacemaker/pcmk_sched_transition.c run_simulation(pe_working_set_t * data_set, cib_t *cib, GList *op_fail_list) data_set 808 lib/pacemaker/pcmk_sched_transition.c out = data_set->priv; data_set 818 lib/pacemaker/pcmk_sched_transition.c transition = pcmk__unpack_graph(data_set->graph, crm_system_name); data_set 821 lib/pacemaker/pcmk_sched_transition.c fake_resource_list = data_set->resources; data_set 843 lib/pacemaker/pcmk_sched_transition.c pe_reset_working_set(data_set); data_set 844 lib/pacemaker/pcmk_sched_transition.c data_set->input = cib_object; data_set 275 lib/pacemaker/pcmk_sched_utilization.c process_utilization(pe_resource_t * rsc, pe_node_t ** prefer, pe_working_set_t * data_set) data_set 277 lib/pacemaker/pcmk_sched_utilization.c CRM_CHECK(rsc && prefer && data_set, return); data_set 278 lib/pacemaker/pcmk_sched_utilization.c if (!pcmk__str_eq(data_set->placement_strategy, "default", pcmk__str_casei)) { data_set 322 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 350 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 354 lib/pacemaker/pcmk_sched_utilization.c pe__show_node_weights(true, rsc, "Post-utilization", rsc->allowed_nodes, data_set); data_set 100 lib/pacemaker/pcmk_sched_utils.c pe_working_set_t *data_set; data_set 151 lib/pacemaker/pcmk_sched_utils.c if (pcmk__str_eq(nw->data_set->placement_strategy, "minimal", pcmk__str_casei)) { data_set 155 lib/pacemaker/pcmk_sched_utils.c if (pcmk__str_eq(nw->data_set->placement_strategy, "balanced", pcmk__str_casei)) { data_set 200 lib/pacemaker/pcmk_sched_utils.c pe_working_set_t *data_set) data_set 202 lib/pacemaker/pcmk_sched_utils.c struct node_weight_s nw = { active_node, data_set }; data_set 427 lib/pacemaker/pcmk_sched_utils.c create_pseudo_resource_op(pe_resource_t * rsc, const char *task, bool optional, bool runnable, pe_working_set_t *data_set) data_set 430 lib/pacemaker/pcmk_sched_utils.c task, NULL, optional, TRUE, data_set); data_set 453 lib/pacemaker/pcmk_sched_utils.c pe_node_t *node, pe_working_set_t *data_set) data_set 462 lib/pacemaker/pcmk_sched_utils.c data_set); data_set 487 lib/pacemaker/pcmk_sched_utils.c sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set) data_set 493 lib/pacemaker/pcmk_sched_utils.c node, FALSE, TRUE, data_set); data_set 495 lib/pacemaker/pcmk_sched_utils.c pcmk__order_stops_before_shutdown(node, shutdown_op, data_set); data_set 758 lib/pacemaker/pcmk_sched_utils.c pe_working_set_t *data_set, pe_resource_t **failed) data_set 776 lib/pacemaker/pcmk_sched_utils.c data_set); data_set 100 lib/pacemaker/pcmk_simulate.c print_cluster_status(pe_working_set_t * data_set, unsigned int show_opts, data_set 103 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 112 lib/pacemaker/pcmk_simulate.c out->message(out, "cluster-status", data_set, 0, NULL, FALSE, data_set 122 lib/pacemaker/pcmk_simulate.c print_transition_summary(pe_working_set_t *data_set, bool print_spacer) data_set 124 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 128 lib/pacemaker/pcmk_simulate.c LogNodeActions(data_set); data_set 129 lib/pacemaker/pcmk_simulate.c g_list_foreach(data_set->resources, (GFunc) LogActions, data_set); data_set 134 lib/pacemaker/pcmk_simulate.c reset(pe_working_set_t *data_set, xmlNodePtr input, pcmk__output_t *out, data_set 137 lib/pacemaker/pcmk_simulate.c data_set->input = input; data_set 138 lib/pacemaker/pcmk_simulate.c data_set->priv = out; data_set 139 lib/pacemaker/pcmk_simulate.c pcmk__set_effective_date(data_set, true, use_date); data_set 141 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_sanitized); data_set 144 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 147 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 152 lib/pacemaker/pcmk_simulate.c pcmk__write_sim_dotfile(pe_working_set_t *data_set, const char *dot_file, data_set 163 lib/pacemaker/pcmk_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 204 lib/pacemaker/pcmk_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 249 lib/pacemaker/pcmk_simulate.c pcmk__profile_file(const char *xml_file, long long repeat, pe_working_set_t *data_set, char *use_date) data_set 251 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 278 lib/pacemaker/pcmk_simulate.c data_set->input = input; data_set 279 lib/pacemaker/pcmk_simulate.c pcmk__set_effective_date(data_set, false, use_date); data_set 280 lib/pacemaker/pcmk_simulate.c pcmk__schedule_actions(data_set, input, NULL); data_set 281 lib/pacemaker/pcmk_simulate.c pe_reset_working_set(data_set); data_set 289 lib/pacemaker/pcmk_simulate.c pcmk__profile_dir(const char *dir, long long repeat, pe_working_set_t *data_set, char *use_date) data_set 291 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 316 lib/pacemaker/pcmk_simulate.c pcmk__profile_file(buffer, repeat, data_set, use_date); data_set 327 lib/pacemaker/pcmk_simulate.c pcmk__set_effective_date(pe_working_set_t *data_set, bool print_original, char *use_date) data_set 329 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 334 lib/pacemaker/pcmk_simulate.c crm_element_value_epoch(data_set->input, "execution-date", &original_date); data_set 337 lib/pacemaker/pcmk_simulate.c data_set->now = crm_time_new(use_date); data_set 339 lib/pacemaker/pcmk_simulate.c crm_time_log(LOG_NOTICE, "Pretending 'now' is", data_set->now, data_set 344 lib/pacemaker/pcmk_simulate.c data_set->now = crm_time_new(NULL); data_set 345 lib/pacemaker/pcmk_simulate.c crm_time_set_timet(data_set->now, &original_date); data_set 348 lib/pacemaker/pcmk_simulate.c char *when = crm_time_as_string(data_set->now, data_set 358 lib/pacemaker/pcmk_simulate.c pcmk__simulate(pe_working_set_t *data_set, pcmk__output_t *out, pcmk_injections_t *injections, data_set 373 lib/pacemaker/pcmk_simulate.c reset(data_set, input, out, use_date, flags); data_set 374 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 377 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 378 lib/pacemaker/pcmk_simulate.c printed = out->message(out, "maint-mode", data_set->flags); data_set 381 lib/pacemaker/pcmk_simulate.c if (data_set->disabled_resources || data_set->blocked_resources) { data_set 385 lib/pacemaker/pcmk_simulate.c data_set->disabled_resources, data_set->ninstances, data_set 386 lib/pacemaker/pcmk_simulate.c data_set->blocked_resources); data_set 392 lib/pacemaker/pcmk_simulate.c print_cluster_status(data_set, pcmk_is_set(flags, pcmk_sim_show_pending) ? pcmk_show_pending : 0, data_set 405 lib/pacemaker/pcmk_simulate.c modify_configuration(data_set, cib, injections); data_set 414 lib/pacemaker/pcmk_simulate.c cleanup_calculations(data_set); data_set 415 lib/pacemaker/pcmk_simulate.c reset(data_set, input, out, use_date, flags); data_set 416 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 431 lib/pacemaker/pcmk_simulate.c if (pcmk_all_flags_set(data_set->flags, pe_flag_show_scores|pe_flag_show_utilization)) { data_set 435 lib/pacemaker/pcmk_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_scores)) { data_set 439 lib/pacemaker/pcmk_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 450 lib/pacemaker/pcmk_simulate.c data_set->priv = logger_out; data_set 453 lib/pacemaker/pcmk_simulate.c pcmk__schedule_actions(data_set, input, local_date); data_set 460 lib/pacemaker/pcmk_simulate.c data_set->priv = out; data_set 466 lib/pacemaker/pcmk_simulate.c rc = write_xml_file(data_set->graph, graph_file, FALSE); data_set 474 lib/pacemaker/pcmk_simulate.c rc = pcmk__write_sim_dotfile(data_set, dot_file, data_set 484 lib/pacemaker/pcmk_simulate.c print_transition_summary(data_set, printed == pcmk_rc_ok); data_set 492 lib/pacemaker/pcmk_simulate.c if (run_simulation(data_set, cib, injections->op_fail) != transition_complete) { data_set 497 lib/pacemaker/pcmk_simulate.c pcmk__set_effective_date(data_set, true, use_date); data_set 500 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 503 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 506 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 507 lib/pacemaker/pcmk_simulate.c print_cluster_status(data_set, 0, section_opts, "Revised Cluster Status", true); data_set 521 lib/pacemaker/pcmk_simulate.c pcmk_simulate(xmlNodePtr *xml, pe_working_set_t *data_set, pcmk_injections_t *injections, data_set 536 lib/pacemaker/pcmk_simulate.c rc = pcmk__simulate(data_set, out, injections, flags, section_opts, data_set 128 lib/pengine/bundle.c pe__bundle_replica_t *replica, pe_working_set_t *data_set) data_set 162 lib/pengine/bundle.c if (!common_unpack(xml_ip, &replica->ip, parent, data_set)) { data_set 174 lib/pengine/bundle.c pe_working_set_t *data_set) data_set 328 lib/pengine/bundle.c if (!common_unpack(xml_container, &replica->container, parent, data_set)) { data_set 338 lib/pengine/bundle.c pe_working_set_t *data_set) data_set 495 lib/pengine/bundle.c data_set)) { data_set 504 lib/pengine/bundle.c pe__bundle_replica_t *replica, pe_working_set_t *data_set) data_set 664 lib/pengine/bundle.c if (!common_unpack(xml_container, &replica->container, parent, data_set)) { data_set 694 lib/pengine/bundle.c pe_working_set_t *data_set) data_set 705 lib/pengine/bundle.c if (pe_find_resource(data_set->resources, id) != NULL) { data_set 711 lib/pengine/bundle.c CRM_ASSERT(pe_find_resource(data_set->resources, id) == NULL); data_set 747 lib/pengine/bundle.c node = pe_find_node(data_set->nodes, uname); data_set 750 lib/pengine/bundle.c data_set); data_set 773 lib/pengine/bundle.c g_list_foreach(data_set->resources, (GFunc) disallow_node, (gpointer) uname); data_set 794 lib/pengine/bundle.c if (!common_unpack(xml_remote, &replica->remote, parent, data_set)) { data_set 833 lib/pengine/bundle.c pe__bundle_replica_t *replica, pe_working_set_t *data_set) data_set 838 lib/pengine/bundle.c if (!create_docker_resource(parent, data, replica, data_set)) { data_set 844 lib/pengine/bundle.c if (!create_podman_resource(parent, data, replica, data_set)) { data_set 850 lib/pengine/bundle.c if (!create_rkt_resource(parent, data, replica, data_set)) { data_set 858 lib/pengine/bundle.c if (create_ip_resource(parent, data, replica, data_set) == FALSE) { data_set 861 lib/pengine/bundle.c if(create_remote_resource(parent, data, replica, data_set) == FALSE) { data_set 943 lib/pengine/bundle.c pe__bundle_needs_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 953 lib/pengine/bundle.c params = pe_rsc_params(rsc, NULL, data_set); data_set 961 lib/pengine/bundle.c pe__add_bundle_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set, data_set 969 lib/pengine/bundle.c if (!pe__bundle_needs_remote_name(rsc, data_set)) { data_set 1007 lib/pengine/bundle.c pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1195 lib/pengine/bundle.c if (common_unpack(xml_resource, &new_rsc, rsc, data_set) == FALSE) { data_set 1303 lib/pengine/bundle.c if (!create_container(rsc, bundle_data, replica, data_set)) { data_set 66 lib/pengine/clone.c pe_working_set_t *data_set) data_set 79 lib/pengine/clone.c g_list_length(data_set->nodes)); data_set 84 lib/pengine/clone.c find_clone_instance(pe_resource_t * rsc, const char *sub_id, pe_working_set_t * data_set) data_set 102 lib/pengine/clone.c pe__create_clone_child(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 128 lib/pengine/clone.c if (common_unpack(child_copy, &child_rsc, rsc, data_set) == FALSE) { data_set 154 lib/pengine/clone.c clone_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 220 lib/pengine/clone.c clone_data->clone_max = QB_MAX(1, g_list_length(data_set->nodes)); data_set 277 lib/pengine/clone.c if (pe__create_clone_child(rsc, data_set) == NULL) { data_set 284 lib/pengine/clone.c if (pe__create_clone_child(rsc, data_set) == NULL) { data_set 1016 lib/pengine/clone.c pe_working_set_t *data_set) data_set 1022 lib/pengine/clone.c if (clone_data->clone_max == g_list_length(data_set->nodes)) { data_set 100 lib/pengine/complex.c expand_parents_fixed_nvpairs(pe_resource_t * rsc, pe_rule_eval_data_t * rule_data, GHashTable * meta_hash, pe_working_set_t * data_set) data_set 114 lib/pengine/complex.c rule_data, parent_orig_meta, NULL, FALSE, data_set); data_set 141 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) data_set 152 lib/pengine/complex.c .now = data_set->now, data_set 170 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set); data_set 175 lib/pengine/complex.c expand_parents_fixed_nvpairs(rsc, &rule_data, meta_hash, data_set); data_set 179 lib/pengine/complex.c pe__unpack_dataset_nvpairs(data_set->rsc_defaults, XML_TAG_META_SETS, data_set 180 lib/pengine/complex.c &rule_data, meta_hash, NULL, FALSE, data_set); data_set 191 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) data_set 196 lib/pengine/complex.c .now = data_set->now, data_set 207 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set); data_set 211 lib/pengine/complex.c get_rsc_attributes(meta_hash, rsc->parent, node, data_set); data_set 215 lib/pengine/complex.c pe__unpack_dataset_nvpairs(data_set->rsc_defaults, XML_TAG_ATTR_SETS, data_set 216 lib/pengine/complex.c &rule_data, meta_hash, NULL, FALSE, data_set); data_set 223 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) data_set 228 lib/pengine/complex.c .now = data_set->now, data_set 234 lib/pengine/complex.c pe_eval_versioned_attributes(data_set->input, rsc->xml, XML_TAG_ATTR_SETS, data_set 239 lib/pengine/complex.c pe_get_versioned_attributes(meta_hash, rsc->parent, node, data_set); data_set 243 lib/pengine/complex.c pe_eval_versioned_attributes(data_set->input, data_set->rsc_defaults, data_set 268 lib/pengine/complex.c unpack_template(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 301 lib/pengine/complex.c cib_resources = get_xpath_object("//"XML_CIB_TAG_RESOURCES, data_set->input, LOG_TRACE); data_set 382 lib/pengine/complex.c add_template_rsc(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 408 lib/pengine/complex.c if (add_tag_ref(data_set->template_rsc_sets, template_ref, id) == FALSE) { data_set 457 lib/pengine/complex.c pe_rsc_params(pe_resource_t *rsc, pe_node_t *node, pe_working_set_t *data_set) data_set 468 lib/pengine/complex.c if ((rsc == NULL) || (data_set == NULL)) { data_set 485 lib/pengine/complex.c get_rsc_attributes(params_on_node, rsc, node, data_set); data_set 494 lib/pengine/complex.c pe_resource_t * parent, pe_working_set_t * data_set) data_set 509 lib/pengine/complex.c .now = data_set->now, data_set 527 lib/pengine/complex.c if (unpack_template(xml_obj, &expanded_xml, data_set) == FALSE) { data_set 532 lib/pengine/complex.c (*rsc)->cluster = data_set; data_set 549 lib/pengine/complex.c (*rsc)->ops_xml = expand_idref(ops, data_set->input); data_set 578 lib/pengine/complex.c get_meta_attributes((*rsc)->meta, *rsc, NULL, data_set); data_set 579 lib/pengine/complex.c (*rsc)->parameters = pe_rsc_params(*rsc, NULL, data_set); // \deprecated data_set 581 lib/pengine/complex.c pe_get_versioned_attributes((*rsc)->versioned_parameters, *rsc, NULL, data_set); data_set 587 lib/pengine/complex.c if (!pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 657 lib/pengine/complex.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 723 lib/pengine/complex.c pe__set_working_set_flags(data_set, pe_flag_have_stonith_resource); data_set 744 lib/pengine/complex.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 759 lib/pengine/complex.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 778 lib/pengine/complex.c } else if (pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 781 lib/pengine/complex.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 784 lib/pengine/complex.c } else if (data_set->no_quorum_policy == no_quorum_ignore) { data_set 808 lib/pengine/complex.c GHashTable *params = pe_rsc_params(*rsc, NULL, data_set); data_set 831 lib/pengine/complex.c if ((*rsc)->fns->unpack(*rsc, data_set) == FALSE) { data_set 835 lib/pengine/complex.c if (pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 837 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "symmetric_default", data_set); data_set 842 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "remote_connection_default", data_set); data_set 851 lib/pengine/complex.c (*rsc)->utilization, NULL, FALSE, data_set); data_set 856 lib/pengine/complex.c if (add_template_rsc(xml_obj, data_set) == FALSE) { data_set 81 lib/pengine/failcounts.c pe_working_set_t *data_set) data_set 133 lib/pengine/failcounts.c lrm_op_xpathObj = xpath_search(data_set->input, lrm_op_xpath); data_set 234 lib/pengine/failcounts.c generate_fail_regexes(pe_resource_t *rsc, pe_working_set_t *data_set, data_set 238 lib/pengine/failcounts.c const char *version = crm_element_value(data_set->input, XML_ATTR_CRM_VERSION); data_set 252 lib/pengine/failcounts.c uint32_t flags, xmlNode *xml_op, pe_working_set_t *data_set) data_set 261 lib/pengine/failcounts.c generate_fail_regexes(rsc, data_set, &failcount_re, &lastfailure_re); data_set 286 lib/pengine/failcounts.c && block_failure(node, rsc, xml_op, data_set)) { data_set 297 lib/pengine/failcounts.c time_t now = get_effective_time(data_set); data_set 326 lib/pengine/failcounts.c flags, xml_op, data_set); data_set 365 lib/pengine/failcounts.c const char *reason, pe_working_set_t *data_set) data_set 370 lib/pengine/failcounts.c CRM_CHECK(rsc && node && reason && data_set, return NULL); data_set 374 lib/pengine/failcounts.c data_set); data_set 97 lib/pengine/group.c group_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 134 lib/pengine/group.c if (common_unpack(xml_native_rsc, &new_rsc, rsc, data_set) == FALSE) { data_set 90 lib/pengine/native.c native_add_running(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set, gboolean failed) data_set 122 lib/pengine/native.c resource_location(rsc, node, INFINITY, "not_managed_default", data_set); data_set 143 lib/pengine/native.c rsc->allowed_nodes = pe__node_list2table(data_set->nodes); data_set 182 lib/pengine/native.c native_add_running(rsc->parent, node, data_set, FALSE); data_set 195 lib/pengine/native.c native_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 216 lib/pengine/native.c pe__force_anon(standard, parent, rsc->id, data_set); data_set 322 lib/pengine/native.c pe_working_set_t * data_set) data_set 332 lib/pengine/native.c params = pe_rsc_params(rsc, node, data_set); data_set 102 lib/pengine/pe_digest.c pe_working_set_t *data_set) data_set 109 lib/pengine/pe_digest.c pe_get_versioned_attributes(local_versioned_params, rsc, node, data_set); data_set 142 lib/pengine/pe_digest.c GHashTable *overrides, pe_working_set_t *data_set) data_set 151 lib/pengine/pe_digest.c if (pe__add_bundle_remote_name(rsc, data_set, data->params_all, data_set 173 lib/pengine/pe_digest.c task, node, TRUE, FALSE, data_set); data_set 182 lib/pengine/pe_digest.c append_all_versioned_params(rsc, node, action, xml_op, data_set); data_set 323 lib/pengine/pe_digest.c bool calc_secure, pe_working_set_t *data_set) data_set 336 lib/pengine/pe_digest.c params = pe_rsc_params(rsc, node, data_set); data_set 338 lib/pengine/pe_digest.c op_version, overrides, data_set); data_set 364 lib/pengine/pe_digest.c pe_working_set_t *data_set) data_set 372 lib/pengine/pe_digest.c NULL, calc_secure, data_set); data_set 393 lib/pengine/pe_digest.c pe_working_set_t * data_set) data_set 411 lib/pengine/pe_digest.c pcmk_is_set(data_set->flags, pe_flag_sanitized), data_set 412 lib/pengine/pe_digest.c data_set); data_set 521 lib/pengine/pe_digest.c pe_node_t *node, pe_working_set_t *data_set) data_set 527 lib/pengine/pe_digest.c node, NULL, TRUE, data_set); data_set 548 lib/pengine/pe_digest.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 549 lib/pengine/pe_digest.c pcmk__output_t *out = data_set->priv; data_set 559 lib/pengine/pe_digest.c if (pcmk_is_set(data_set->flags, pe_flag_sanitized) && data->digest_secure_calc) { data_set 560 lib/pengine/pe_digest.c if (data_set->priv != NULL) { data_set 561 lib/pengine/pe_digest.c pcmk__output_t *out = data_set->priv; data_set 47 lib/pengine/pe_output.c add_extra_info(pe_node_t *node, GList *rsc_list, pe_working_set_t *data_set, data_set 59 lib/pengine/pe_output.c if (add_extra_info(node, rsc->children, data_set, attrname, data_set 69 lib/pengine/pe_output.c params = pe_rsc_params(rsc, node, data_set); data_set 178 lib/pengine/pe_output.c get_cluster_stack(pe_working_set_t *data_set) data_set 181 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 315 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 320 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 329 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 333 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 334 lib/pengine/pe_output.c char *dc_name = data_set->dc_node ? pe__node_display_name(data_set->dc_node, pcmk_is_set(show_opts, pcmk_show_node_id)) : NULL; data_set 337 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, dc_version_s, dc_name); data_set 342 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 343 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 344 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 345 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 353 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 354 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 355 lib/pengine/pe_output.c data_set->blocked_resources); data_set 360 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 366 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 377 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 382 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 390 lib/pengine/pe_output.c if (data_set->dc_node == NULL || pcmk_is_set(section_opts, pcmk_section_dc)) { data_set 392 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 396 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 397 lib/pengine/pe_output.c char *dc_name = data_set->dc_node ? pe__node_display_name(data_set->dc_node, pcmk_is_set(show_opts, pcmk_show_node_id)) : NULL; data_set 400 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, dc_version_s, dc_name); data_set 405 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 406 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 407 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 408 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 416 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 417 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 418 lib/pengine/pe_output.c data_set->blocked_resources); data_set 429 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 435 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 609 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 619 lib/pengine/pe_output.c for (gIter = data_set->placement_constraints; gIter != NULL; gIter = gIter->next) { data_set 870 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 873 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 876 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 878 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 901 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 908 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 925 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 927 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 929 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 939 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 942 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 945 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 947 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 976 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 979 lib/pengine/pe_output.c char *stonith_timeout_str = pcmk__itoa(data_set->stonith_timeout); data_set 980 lib/pengine/pe_output.c char *priority_fencing_delay_str = pcmk__itoa(data_set->priority_fencing_delay * 1000); data_set 982 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 1005 lib/pengine/pe_output.c "stonith-enabled", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)), data_set 1006 lib/pengine/pe_output.c "symmetric-cluster", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)), data_set 1008 lib/pengine/pe_output.c "maintenance-mode", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)), data_set 1009 lib/pengine/pe_output.c "stop-all-resources", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything)), data_set 1348 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1359 lib/pengine/pe_output.c if (xmlChildElementCount(data_set->failed) == 0) { data_set 1363 lib/pengine/pe_output.c for (xml_op = pcmk__xml_first_child(data_set->failed); xml_op != NULL; data_set 1695 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1710 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 1751 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1771 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 1825 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1834 lib/pengine/pe_output.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1872 lib/pengine/pe_output.c data_set, name, &expected_score); data_set 1924 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1943 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1967 lib/pengine/pe_output.c NULL, data_set); data_set 1982 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, data_set 1994 lib/pengine/pe_output.c out->message(out, "resource-operation-list", data_set, rsc, node, data_set 2197 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2205 lib/pengine/pe_output.c xmlNode *cib_status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 2214 lib/pengine/pe_output.c pe_node_t *node = pe_find_node_id(data_set->nodes, ID(node_state)); data_set 2228 lib/pengine/pe_output.c out->message(out, "node-history-list", data_set, node, node_state, data_set 2487 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2509 lib/pengine/pe_output.c GList *rscs = pe__filter_rsc_list(data_set->resources, only_rsc); data_set 2520 lib/pengine/pe_output.c for (rsc_iter = data_set->resources; rsc_iter != NULL; rsc_iter = rsc_iter->next) { data_set 2594 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2624 lib/pengine/pe_output.c NULL, data_set); data_set 2748 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2754 lib/pengine/pe_output.c if (g_hash_table_size(data_set->tickets) == 0) { data_set 2764 lib/pengine/pe_output.c g_hash_table_iter_init(&iter, data_set->tickets); data_set 34 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 38 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 41 lib/pengine/pe_status_private.h gboolean unpack_remote_nodes(xmlNode *xml_resources, pe_working_set_t *data_set); data_set 44 lib/pengine/pe_status_private.h gboolean unpack_resources(xmlNode *xml_resources, pe_working_set_t *data_set); data_set 47 lib/pengine/pe_status_private.h gboolean unpack_config(xmlNode *config, pe_working_set_t *data_set); data_set 50 lib/pengine/pe_status_private.h gboolean unpack_nodes(xmlNode *xml_nodes, pe_working_set_t *data_set); data_set 53 lib/pengine/pe_status_private.h gboolean unpack_tags(xmlNode *xml_tags, pe_working_set_t *data_set); data_set 56 lib/pengine/pe_status_private.h gboolean unpack_status(xmlNode *status, pe_working_set_t *data_set); data_set 62 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 18 lib/pengine/remote.c const pe_working_set_t *data_set) data_set 21 lib/pengine/remote.c && pe__is_remote_node(pe_find_node(data_set->nodes, rsc->id)); data_set 66 lib/pengine/remote.c pe__resource_contains_guest_node(const pe_working_set_t *data_set, data_set 69 lib/pengine/remote.c if ((rsc != NULL) && (data_set != NULL) data_set 70 lib/pengine/remote.c && pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 120 lib/pengine/remote.c pe_foreach_guest_node(const pe_working_set_t *data_set, const pe_node_t *host, data_set 125 lib/pengine/remote.c CRM_CHECK(data_set && host && host->details && helper, return); data_set 126 lib/pengine/remote.c if (!pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 133 lib/pengine/remote.c pe_node_t *guest_node = pe_find_node(data_set->nodes, rsc->id); data_set 221 lib/pengine/remote.c enum pe_check_parameters flag, pe_working_set_t *data_set) data_set 225 lib/pengine/remote.c CRM_CHECK(data_set && rsc_op && rsc && node, return); data_set 235 lib/pengine/remote.c data_set->param_check = g_list_prepend(data_set->param_check, check_op); data_set 246 lib/pengine/remote.c pe__foreach_param_check(pe_working_set_t *data_set, data_set 250 lib/pengine/remote.c CRM_CHECK(data_set && cb, return); data_set 252 lib/pengine/remote.c for (GList *item = data_set->param_check; item != NULL; item = item->next) { data_set 256 lib/pengine/remote.c check_op->check_type, data_set); data_set 261 lib/pengine/remote.c pe__free_param_checks(pe_working_set_t *data_set) data_set 263 lib/pengine/remote.c if (data_set && data_set->param_check) { data_set 264 lib/pengine/remote.c g_list_free_full(data_set->param_check, free); data_set 265 lib/pengine/remote.c data_set->param_check = NULL; data_set 36 lib/pengine/status.c pe_working_set_t *data_set = calloc(1, sizeof(pe_working_set_t)); data_set 38 lib/pengine/status.c if (data_set != NULL) { data_set 39 lib/pengine/status.c set_working_set_defaults(data_set); data_set 41 lib/pengine/status.c return data_set; data_set 50 lib/pengine/status.c pe_free_working_set(pe_working_set_t *data_set) data_set 52 lib/pengine/status.c if (data_set != NULL) { data_set 53 lib/pengine/status.c pe_reset_working_set(data_set); data_set 54 lib/pengine/status.c data_set->priv = NULL; data_set 55 lib/pengine/status.c free(data_set); data_set 71 lib/pengine/status.c cluster_status(pe_working_set_t * data_set) data_set 73 lib/pengine/status.c xmlNode *config = get_xpath_object("//"XML_CIB_TAG_CRMCONFIG, data_set->input, LOG_TRACE); data_set 74 lib/pengine/status.c xmlNode *cib_nodes = get_xpath_object("//"XML_CIB_TAG_NODES, data_set->input, LOG_TRACE); data_set 75 lib/pengine/status.c xmlNode *cib_resources = get_xpath_object("//"XML_CIB_TAG_RESOURCES, data_set->input, LOG_TRACE); data_set 76 lib/pengine/status.c xmlNode *cib_status = get_xpath_object("//"XML_CIB_TAG_STATUS, data_set->input, LOG_TRACE); data_set 77 lib/pengine/status.c xmlNode *cib_tags = get_xpath_object("//" XML_CIB_TAG_TAGS, data_set->input, data_set 79 lib/pengine/status.c const char *value = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 84 lib/pengine/status.c data_set->failed = create_xml_node(NULL, "failed-ops"); data_set 86 lib/pengine/status.c if (data_set->input == NULL) { data_set 90 lib/pengine/status.c if (data_set->now == NULL) { data_set 91 lib/pengine/status.c data_set->now = crm_time_new(NULL); data_set 94 lib/pengine/status.c if (data_set->dc_uuid == NULL) { data_set 95 lib/pengine/status.c data_set->dc_uuid = crm_element_value_copy(data_set->input, data_set 100 lib/pengine/status.c pe__set_working_set_flags(data_set, pe_flag_have_quorum); data_set 102 lib/pengine/status.c pe__clear_working_set_flags(data_set, pe_flag_have_quorum); data_set 105 lib/pengine/status.c data_set->op_defaults = get_xpath_object("//" XML_CIB_TAG_OPCONFIG, data_set 106 lib/pengine/status.c data_set->input, LOG_NEVER); data_set 107 lib/pengine/status.c data_set->rsc_defaults = get_xpath_object("//" XML_CIB_TAG_RSCCONFIG, data_set 108 lib/pengine/status.c data_set->input, LOG_NEVER); data_set 110 lib/pengine/status.c unpack_config(config, data_set); data_set 112 lib/pengine/status.c if (!pcmk_any_flags_set(data_set->flags, data_set 114 lib/pengine/status.c && (data_set->no_quorum_policy != no_quorum_ignore)) { data_set 118 lib/pengine/status.c unpack_nodes(cib_nodes, data_set); data_set 120 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 121 lib/pengine/status.c unpack_remote_nodes(cib_resources, data_set); data_set 124 lib/pengine/status.c unpack_resources(cib_resources, data_set); data_set 125 lib/pengine/status.c unpack_tags(cib_tags, data_set); data_set 127 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 128 lib/pengine/status.c unpack_status(cib_status, data_set); data_set 131 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_no_counts)) { data_set 132 lib/pengine/status.c for (GList *item = data_set->resources; item != NULL; data_set 138 lib/pengine/status.c pe__set_working_set_flags(data_set, pe_flag_have_status); data_set 270 lib/pengine/status.c cleanup_calculations(pe_working_set_t * data_set) data_set 272 lib/pengine/status.c if (data_set == NULL) { data_set 276 lib/pengine/status.c pe__clear_working_set_flags(data_set, pe_flag_have_status); data_set 277 lib/pengine/status.c if (data_set->config_hash != NULL) { data_set 278 lib/pengine/status.c g_hash_table_destroy(data_set->config_hash); data_set 281 lib/pengine/status.c if (data_set->singletons != NULL) { data_set 282 lib/pengine/status.c g_hash_table_destroy(data_set->singletons); data_set 285 lib/pengine/status.c if (data_set->tickets) { data_set 286 lib/pengine/status.c g_hash_table_destroy(data_set->tickets); data_set 289 lib/pengine/status.c if (data_set->template_rsc_sets) { data_set 290 lib/pengine/status.c g_hash_table_destroy(data_set->template_rsc_sets); data_set 293 lib/pengine/status.c if (data_set->tags) { data_set 294 lib/pengine/status.c g_hash_table_destroy(data_set->tags); data_set 297 lib/pengine/status.c free(data_set->dc_uuid); data_set 300 lib/pengine/status.c pe_free_resources(data_set->resources); data_set 303 lib/pengine/status.c pe_free_actions(data_set->actions); data_set 306 lib/pengine/status.c pe_free_nodes(data_set->nodes); data_set 308 lib/pengine/status.c pe__free_param_checks(data_set); data_set 309 lib/pengine/status.c g_list_free(data_set->stop_needed); data_set 310 lib/pengine/status.c free_xml(data_set->graph); data_set 311 lib/pengine/status.c crm_time_free(data_set->now); data_set 312 lib/pengine/status.c free_xml(data_set->input); data_set 313 lib/pengine/status.c free_xml(data_set->failed); data_set 315 lib/pengine/status.c set_working_set_defaults(data_set); data_set 317 lib/pengine/status.c CRM_CHECK(data_set->ordering_constraints == NULL,; data_set 319 lib/pengine/status.c CRM_CHECK(data_set->placement_constraints == NULL,; data_set 329 lib/pengine/status.c pe_reset_working_set(pe_working_set_t *data_set) data_set 331 lib/pengine/status.c if (data_set == NULL) { data_set 336 lib/pengine/status.c g_list_length(data_set->ordering_constraints)); data_set 337 lib/pengine/status.c pe__free_ordering(data_set->ordering_constraints); data_set 338 lib/pengine/status.c data_set->ordering_constraints = NULL; data_set 341 lib/pengine/status.c g_list_length(data_set->placement_constraints)); data_set 342 lib/pengine/status.c pe__free_location(data_set->placement_constraints); data_set 343 lib/pengine/status.c data_set->placement_constraints = NULL; data_set 346 lib/pengine/status.c g_list_length(data_set->colocation_constraints)); data_set 347 lib/pengine/status.c g_list_free_full(data_set->colocation_constraints, free); data_set 348 lib/pengine/status.c data_set->colocation_constraints = NULL; data_set 351 lib/pengine/status.c g_list_length(data_set->ticket_constraints)); data_set 352 lib/pengine/status.c g_list_free_full(data_set->ticket_constraints, free); data_set 353 lib/pengine/status.c data_set->ticket_constraints = NULL; data_set 355 lib/pengine/status.c cleanup_calculations(data_set); data_set 359 lib/pengine/status.c set_working_set_defaults(pe_working_set_t * data_set) data_set 361 lib/pengine/status.c void *priv = data_set->priv; data_set 363 lib/pengine/status.c memset(data_set, 0, sizeof(pe_working_set_t)); data_set 365 lib/pengine/status.c data_set->priv = priv; data_set 366 lib/pengine/status.c data_set->order_id = 1; data_set 367 lib/pengine/status.c data_set->action_id = 1; data_set 368 lib/pengine/status.c data_set->no_quorum_policy = no_quorum_stop; data_set 370 lib/pengine/status.c data_set->flags = 0x0ULL; data_set 372 lib/pengine/status.c pe__set_working_set_flags(data_set, data_set 377 lib/pengine/status.c pe__set_working_set_flags(data_set, pe_flag_concurrent_fencing); data_set 20 lib/pengine/tags.c pe__rscs_with_tag(pe_working_set_t *data_set, const char *tag_name) data_set 25 lib/pengine/tags.c if (data_set->tags == NULL) { data_set 29 lib/pengine/tags.c value = g_hash_table_lookup(data_set->tags, tag_name); data_set 37 lib/pengine/tags.c pe_resource_t *rsc = pe_find_resource_with_flags(data_set->resources, id, data_set 51 lib/pengine/tags.c pe__unames_with_tag(pe_working_set_t *data_set, const char *tag_name) data_set 56 lib/pengine/tags.c if (data_set->tags == NULL) { data_set 60 lib/pengine/tags.c value = g_hash_table_lookup(data_set->tags, tag_name); data_set 70 lib/pengine/tags.c pe_node_t *node = pe_find_node_id(data_set->nodes, id); data_set 84 lib/pengine/tags.c pe__rsc_has_tag(pe_working_set_t *data_set, const char *rsc_name, const char *tag_name) data_set 86 lib/pengine/tags.c GList *rscs = pe__rscs_with_tag(data_set, tag_name); data_set 99 lib/pengine/tags.c pe__uname_has_tag(pe_working_set_t *data_set, const char *node_name, const char *tag_name) data_set 101 lib/pengine/tags.c GList *unames = pe__unames_with_tag(data_set, tag_name); data_set 34 lib/pengine/unpack.c #define set_config_flag(data_set, option, flag) do { \ data_set 35 lib/pengine/unpack.c const char *scf_value = pe_pref((data_set)->config_hash, (option)); \ data_set 38 lib/pengine/unpack.c (data_set)->flags = pcmk__set_flags_as(__func__, __LINE__, \ data_set 40 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 43 lib/pengine/unpack.c (data_set)->flags = pcmk__clear_flags_as(__func__, __LINE__,\ data_set 45 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 54 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 55 lib/pengine/unpack.c static void determine_remote_online_status(pe_working_set_t *data_set, data_set 58 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 60 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 63 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 96 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, data_set 144 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 149 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, FALSE, data_set); data_set 154 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", data_set 160 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 163 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, priority_delay, data_set); data_set 183 lib/pengine/unpack.c set_if_xpath(uint64_t flag, const char *xpath, pe_working_set_t *data_set) data_set 187 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, flag)) { data_set 188 lib/pengine/unpack.c result = xpath_search(data_set->input, xpath); data_set 190 lib/pengine/unpack.c pe__set_working_set_flags(data_set, flag); data_set 197 lib/pengine/unpack.c unpack_config(xmlNode * config, pe_working_set_t * data_set) data_set 205 lib/pengine/unpack.c .now = data_set->now, data_set 211 lib/pengine/unpack.c data_set->config_hash = config_hash; data_set 214 lib/pengine/unpack.c CIB_OPTIONS_FIRST, FALSE, data_set); data_set 216 lib/pengine/unpack.c verify_pe_options(data_set->config_hash); data_set 218 lib/pengine/unpack.c set_config_flag(data_set, "enable-startup-probes", pe_flag_startup_probes); data_set 219 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 223 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, XML_ATTR_HAVE_WATCHDOG); data_set 227 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_stonith_resource); data_set 233 lib/pengine/unpack.c set_if_xpath(pe_flag_enable_unfencing, XPATH_ENABLE_UNFENCING, data_set); data_set 235 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 236 lib/pengine/unpack.c data_set->stonith_timeout = (int) crm_parse_interval_spec(value); data_set 237 lib/pengine/unpack.c crm_debug("STONITH timeout: %d", data_set->stonith_timeout); data_set 239 lib/pengine/unpack.c set_config_flag(data_set, "stonith-enabled", pe_flag_stonith_enabled); data_set 241 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)? "enabled" : "disabled"); data_set 243 lib/pengine/unpack.c data_set->stonith_action = pe_pref(data_set->config_hash, "stonith-action"); data_set 244 lib/pengine/unpack.c if (!strcmp(data_set->stonith_action, "poweroff")) { data_set 248 lib/pengine/unpack.c data_set->stonith_action = "off"; data_set 250 lib/pengine/unpack.c crm_trace("STONITH will %s nodes", data_set->stonith_action); data_set 252 lib/pengine/unpack.c set_config_flag(data_set, "concurrent-fencing", pe_flag_concurrent_fencing); data_set 254 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)? "enabled" : "disabled"); data_set 256 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 259 lib/pengine/unpack.c data_set->priority_fencing_delay = crm_parse_interval_spec(value) / 1000; data_set 260 lib/pengine/unpack.c crm_trace("Priority fencing delay is %ds", data_set->priority_fencing_delay); data_set 263 lib/pengine/unpack.c set_config_flag(data_set, "stop-all-resources", pe_flag_stop_everything); data_set 265 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything))); data_set 267 lib/pengine/unpack.c set_config_flag(data_set, "symmetric-cluster", pe_flag_symmetric_cluster); data_set 268 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 272 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "no-quorum-policy"); data_set 275 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_ignore; data_set 278 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_freeze; data_set 281 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_demote; data_set 284 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 287 lib/pengine/unpack.c crm_element_value_int(data_set->input, XML_ATTR_QUORUM_PANIC, data_set 289 lib/pengine/unpack.c if (do_panic || pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 290 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_suicide; data_set 293 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 298 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 302 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 305 lib/pengine/unpack.c switch (data_set->no_quorum_policy) { data_set 324 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-resources", pe_flag_stop_rsc_orphans); data_set 326 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)? "stopped" : "ignored"); data_set 328 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-actions", pe_flag_stop_action_orphans); data_set 330 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_action_orphans)? "stopped" : "ignored"); data_set 332 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "remove-after-stop"); data_set 335 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 342 lib/pengine/unpack.c pe__clear_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 346 lib/pengine/unpack.c set_config_flag(data_set, "maintenance-mode", pe_flag_maintenance_mode); data_set 348 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode))); data_set 350 lib/pengine/unpack.c set_config_flag(data_set, "start-failure-is-fatal", pe_flag_start_failure_fatal); data_set 352 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)? "always fatal" : "handled by failcount"); data_set 354 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 355 lib/pengine/unpack.c set_config_flag(data_set, "startup-fencing", pe_flag_startup_fencing); data_set 357 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 363 lib/pengine/unpack.c pcmk__score_red = char2score(pe_pref(data_set->config_hash, "node-health-red")); data_set 364 lib/pengine/unpack.c pcmk__score_green = char2score(pe_pref(data_set->config_hash, "node-health-green")); data_set 365 lib/pengine/unpack.c pcmk__score_yellow = char2score(pe_pref(data_set->config_hash, "node-health-yellow")); data_set 368 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-red"), data_set 369 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-yellow"), data_set 370 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-green")); data_set 372 lib/pengine/unpack.c data_set->placement_strategy = pe_pref(data_set->config_hash, "placement-strategy"); data_set 373 lib/pengine/unpack.c crm_trace("Placement strategy: %s", data_set->placement_strategy); data_set 375 lib/pengine/unpack.c set_config_flag(data_set, "shutdown-lock", pe_flag_shutdown_lock); data_set 377 lib/pengine/unpack.c (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)? "" : " not")); data_set 378 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 379 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 381 lib/pengine/unpack.c data_set->shutdown_lock = crm_parse_interval_spec(value) / 1000; data_set 382 lib/pengine/unpack.c crm_trace("Shutdown locks expire after %us", data_set->shutdown_lock); data_set 390 lib/pengine/unpack.c const char *score, pe_working_set_t * data_set) data_set 394 lib/pengine/unpack.c if (pe_find_node(data_set->nodes, uname) != NULL) { data_set 423 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_remote_nodes); data_set 442 lib/pengine/unpack.c data_set->nodes = g_list_insert_sorted(data_set->nodes, new_node, sort_node_uname); data_set 504 lib/pengine/unpack.c handle_startup_fencing(pe_working_set_t *data_set, pe_node_t *new_node) data_set 514 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 529 lib/pengine/unpack.c unpack_nodes(xmlNode * xml_nodes, pe_working_set_t * data_set) data_set 541 lib/pengine/unpack.c .now = data_set->now, data_set 564 lib/pengine/unpack.c new_node = pe_create_node(id, uname, type, score, data_set); data_set 576 lib/pengine/unpack.c handle_startup_fencing(data_set, new_node); data_set 578 lib/pengine/unpack.c add_node_attrs(xml_obj, new_node, FALSE, data_set); data_set 581 lib/pengine/unpack.c FALSE, data_set); data_set 587 lib/pengine/unpack.c if (data_set->localhost && pe_find_node(data_set->nodes, data_set->localhost) == NULL) { data_set 589 lib/pengine/unpack.c pe_create_node(data_set->localhost, data_set->localhost, NULL, 0, data_set 590 lib/pengine/unpack.c data_set); data_set 597 lib/pengine/unpack.c setup_container(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 602 lib/pengine/unpack.c g_list_foreach(rsc->children, (GFunc) setup_container, data_set); data_set 608 lib/pengine/unpack.c pe_resource_t *container = pe_find_resource(data_set->resources, container_id); data_set 622 lib/pengine/unpack.c unpack_remote_nodes(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 641 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 645 lib/pengine/unpack.c data_set); data_set 658 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj, xml_resources, data_set); data_set 659 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 663 lib/pengine/unpack.c data_set); data_set 676 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj2, xml_resources, data_set); data_set 678 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 682 lib/pengine/unpack.c data_set); data_set 699 lib/pengine/unpack.c link_rsc2remotenode(pe_working_set_t *data_set, pe_resource_t *new_rsc) data_set 707 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 712 lib/pengine/unpack.c remote_node = pe_find_node(data_set->nodes, new_rsc->id); data_set 723 lib/pengine/unpack.c handle_startup_fencing(data_set, remote_node); data_set 759 lib/pengine/unpack.c unpack_resources(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 764 lib/pengine/unpack.c data_set->template_rsc_sets = pcmk__strkey_table(free, destroy_tag); data_set 774 lib/pengine/unpack.c if (template_id && g_hash_table_lookup_extended(data_set->template_rsc_sets, data_set 777 lib/pengine/unpack.c g_hash_table_insert(data_set->template_rsc_sets, strdup(template_id), NULL); data_set 783 lib/pengine/unpack.c if (common_unpack(xml_obj, &new_rsc, NULL, data_set) && (new_rsc != NULL)) { data_set 784 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, new_rsc); data_set 797 lib/pengine/unpack.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 800 lib/pengine/unpack.c setup_container(rsc, data_set); data_set 801 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 804 lib/pengine/unpack.c data_set->resources = g_list_sort(data_set->resources, sort_rsc_priority); data_set 805 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 808 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 809 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 820 lib/pengine/unpack.c unpack_tags(xmlNode * xml_tags, pe_working_set_t * data_set) data_set 824 lib/pengine/unpack.c data_set->tags = pcmk__strkey_table(free, destroy_tag); data_set 857 lib/pengine/unpack.c if (add_tag_ref(data_set->tags, tag_id, obj_ref) == FALSE) { data_set 869 lib/pengine/unpack.c unpack_ticket_state(xmlNode * xml_ticket, pe_working_set_t * data_set) data_set 886 lib/pengine/unpack.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 888 lib/pengine/unpack.c ticket = ticket_new(ticket_id, data_set); data_set 937 lib/pengine/unpack.c unpack_tickets_state(xmlNode * xml_tickets, pe_working_set_t * data_set) data_set 947 lib/pengine/unpack.c unpack_ticket_state(xml_obj, data_set); data_set 954 lib/pengine/unpack.c unpack_handle_remote_attrs(pe_node_t *this_node, xmlNode *state, pe_working_set_t * data_set) data_set 978 lib/pengine/unpack.c add_node_attrs(attrs, this_node, TRUE, data_set); data_set 999 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1024 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 1029 lib/pengine/unpack.c add_node_attrs(attrs, node, TRUE, data_set); data_set 1062 lib/pengine/unpack.c unpack_node_state(xmlNode *state, pe_working_set_t *data_set) data_set 1082 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1100 lib/pengine/unpack.c unpack_transient_attributes(state, this_node, data_set); data_set 1110 lib/pengine/unpack.c determine_online_status(state, this_node, data_set); data_set 1112 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 1114 lib/pengine/unpack.c && (data_set->no_quorum_policy == no_quorum_suicide)) { data_set 1119 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "cluster does not have quorum", data_set 1142 lib/pengine/unpack.c unpack_node_history(xmlNode *status, bool fence, pe_working_set_t *data_set) data_set 1161 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1202 lib/pengine/unpack.c || (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock) data_set 1214 lib/pengine/unpack.c } else if (!pcmk_any_flags_set(data_set->flags, pe_flag_stonith_enabled data_set 1223 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1224 lib/pengine/unpack.c unpack_handle_remote_attrs(this_node, state, data_set); data_set 1231 lib/pengine/unpack.c unpack_node_lrm(this_node, state, data_set); data_set 1242 lib/pengine/unpack.c unpack_status(xmlNode * status, pe_working_set_t * data_set) data_set 1248 lib/pengine/unpack.c if (data_set->tickets == NULL) { data_set 1249 lib/pengine/unpack.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 1256 lib/pengine/unpack.c unpack_tickets_state((xmlNode *) state, data_set); data_set 1259 lib/pengine/unpack.c unpack_node_state(state, data_set); data_set 1263 lib/pengine/unpack.c while (unpack_node_history(status, FALSE, data_set) == EAGAIN) { data_set 1269 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled), data_set 1270 lib/pengine/unpack.c data_set); data_set 1275 lib/pengine/unpack.c if (data_set->stop_needed != NULL) { data_set 1276 lib/pengine/unpack.c for (GList *item = data_set->stop_needed; item; item = item->next) { data_set 1284 lib/pengine/unpack.c g_list_free(data_set->stop_needed); data_set 1285 lib/pengine/unpack.c data_set->stop_needed = NULL; data_set 1292 lib/pengine/unpack.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1304 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1312 lib/pengine/unpack.c determine_online_status_no_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1338 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is unexpectedly down", FALSE); data_set 1346 lib/pengine/unpack.c determine_online_status_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1394 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer has not been seen by the cluster", FALSE); data_set 1397 lib/pengine/unpack.c pe_fence_node(data_set, this_node, data_set 1418 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is no longer part of the cluster", TRUE); data_set 1421 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer process is no longer available", FALSE); data_set 1425 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "termination was requested", FALSE); data_set 1436 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer was in an unknown state", FALSE); data_set 1446 lib/pengine/unpack.c determine_remote_online_status(pe_working_set_t * data_set, pe_node_t * this_node) data_set 1515 lib/pengine/unpack.c determine_online_status(xmlNode * node_state, pe_node_t * this_node, pe_working_set_t * data_set) data_set 1539 lib/pengine/unpack.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1540 lib/pengine/unpack.c online = determine_online_status_no_fencing(data_set, node_state, this_node); data_set 1543 lib/pengine/unpack.c online = determine_online_status_fencing(data_set, node_state, this_node); data_set 1666 lib/pengine/unpack.c create_fake_resource(const char *rsc_id, xmlNode * rsc_entry, pe_working_set_t * data_set) data_set 1675 lib/pengine/unpack.c if (!common_unpack(xml_rsc, &rsc, NULL, data_set)) { data_set 1683 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); data_set 1685 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); data_set 1687 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 1701 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, rsc); data_set 1711 lib/pengine/unpack.c pe_node_t *node, pe_working_set_t *data_set) data_set 1713 lib/pengine/unpack.c pe_resource_t *top = pe__create_clone_child(parent, data_set); data_set 1738 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, pe_node_t * node, pe_resource_t * parent, data_set 1848 lib/pengine/unpack.c && !pe__is_universal_clone(parent, data_set)) { data_set 1854 lib/pengine/unpack.c rsc = create_anonymous_orphan(parent, rsc_id, node, data_set); data_set 1861 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, pe_node_t * node, const char *rsc_id, data_set 1868 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1876 lib/pengine/unpack.c pe_resource_t *clone0 = pe_find_resource(data_set->resources, clone0_id); data_set 1904 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); data_set 1923 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, pe_node_t * node, pe_working_set_t * data_set) data_set 1929 lib/pengine/unpack.c rsc = create_fake_resource(rsc_id, rsc_entry, data_set); data_set 1934 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 1940 lib/pengine/unpack.c resource_location(rsc, NULL, -INFINITY, "__orphan_do_not_run__", data_set); data_set 1948 lib/pengine/unpack.c xmlNode * migrate_op, pe_working_set_t * data_set) data_set 1996 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2019 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2049 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2070 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); data_set 2092 lib/pengine/unpack.c data_set->stop_needed = g_list_prepend(data_set->stop_needed, data_set 2103 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2106 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2115 lib/pengine/unpack.c pe_fence_node(data_set, tmpnode, data_set 2138 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2157 lib/pengine/unpack.c native_add_running(rsc, node, data_set, (save_on_fail != action_fail_ignore)); data_set 2197 lib/pengine/unpack.c GList *sorted_op_list, pe_working_set_t * data_set) data_set 2245 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); data_set 2300 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2307 lib/pengine/unpack.c if ((data_set->shutdown_lock > 0) data_set 2308 lib/pengine/unpack.c && (get_effective_time(data_set) data_set 2309 lib/pengine/unpack.c > (lock_time + data_set->shutdown_lock))) { data_set 2312 lib/pengine/unpack.c pe__clear_resource_history(rsc, node, data_set); data_set 2332 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2368 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2376 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, lrm_resource); data_set 2382 lib/pengine/unpack.c rsc = process_orphan_resource(lrm_resource, node, data_set); data_set 2388 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2389 lib/pengine/unpack.c unpack_shutdown_lock(lrm_resource, rsc, node, data_set); data_set 2405 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); data_set 2410 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); data_set 2415 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); data_set 2436 lib/pengine/unpack.c handle_orphaned_container_fillers(xmlNode * lrm_rsc_list, pe_working_set_t * data_set) data_set 2457 lib/pengine/unpack.c container = pe_find_resource(data_set->resources, container_id); data_set 2462 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 2485 lib/pengine/unpack.c unpack_node_lrm(pe_node_t *node, xmlNode *xml, pe_working_set_t *data_set) data_set 2503 lib/pengine/unpack.c pe_resource_t *rsc = unpack_lrm_resource(node, rsc_entry, data_set); data_set 2515 lib/pengine/unpack.c handle_orphaned_container_fillers(xml, data_set); data_set 2543 lib/pengine/unpack.c bool success_only, pe_working_set_t *data_set) data_set 2572 lib/pengine/unpack.c xml = get_xpath_object(xpath, data_set->input, LOG_DEBUG); data_set 2616 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2619 lib/pengine/unpack.c node->details->uname, NULL, TRUE, data_set); data_set 2626 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2656 lib/pengine/unpack.c if (stop_happened_after(rsc, node, xml_op, data_set)) { data_set 2663 lib/pengine/unpack.c target_node = pe_find_node(data_set->nodes, target); data_set 2664 lib/pengine/unpack.c source_node = pe_find_node(data_set->nodes, source); data_set 2668 lib/pengine/unpack.c source, FALSE, data_set); data_set 2691 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, TRUE); data_set 2699 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2721 lib/pengine/unpack.c int call_id, pe_working_set_t *data_set) data_set 2724 lib/pengine/unpack.c data_set); data_set 2731 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2750 lib/pengine/unpack.c TRUE, data_set); data_set 2755 lib/pengine/unpack.c source, TRUE, data_set); data_set 2763 lib/pengine/unpack.c pe_node_t *target_node = pe_find_node(data_set->nodes, target); data_set 2768 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2785 lib/pengine/unpack.c data_set) data_set 2787 lib/pengine/unpack.c data_set) data_set 2789 lib/pengine/unpack.c data_set)) { data_set 2800 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 2817 lib/pengine/unpack.c TRUE, data_set); data_set 2821 lib/pengine/unpack.c source, target, TRUE, data_set); data_set 2829 lib/pengine/unpack.c pe_node_t *source_node = pe_find_node(data_set->nodes, source); data_set 2832 lib/pengine/unpack.c native_add_running(rsc, source_node, data_set, TRUE); data_set 2839 lib/pengine/unpack.c const pe_resource_t *rsc, pe_working_set_t *data_set) data_set 2848 lib/pengine/unpack.c for (xIter = data_set->failed->children; xIter; xIter = xIter->next) { data_set 2861 lib/pengine/unpack.c add_node_copy(data_set->failed, op); data_set 2985 lib/pengine/unpack.c enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3010 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) data_set 3038 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3041 lib/pengine/unpack.c action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3049 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); data_set 3052 lib/pengine/unpack.c unpack_migrate_to_failure(rsc, node, xml_op, data_set); data_set 3055 lib/pengine/unpack.c unpack_migrate_from_failure(rsc, node, xml_op, data_set); data_set 3120 lib/pengine/unpack.c fail_rsc->allowed_nodes = pe__node_list2table(data_set->nodes); data_set 3148 lib/pengine/unpack.c pe_resource_t *rsc, int rc, int target_rc, pe_node_t * node, xmlNode * xml_op, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3246 lib/pengine/unpack.c if (!pe_can_fence(data_set, node) data_set 3278 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3282 lib/pengine/unpack.c if (pe__bundle_needs_remote_name(rsc, data_set)) { data_set 3288 lib/pengine/unpack.c data_set); data_set 3293 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); data_set 3313 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3315 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, remote_conn->id); data_set 3319 lib/pengine/unpack.c FALSE, data_set); data_set 3328 lib/pengine/unpack.c bool is_last_failure, pe_working_set_t *data_set) data_set 3351 lib/pengine/unpack.c && pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3354 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 3391 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 3409 lib/pengine/unpack.c time_t now = get_effective_time(data_set); data_set 3415 lib/pengine/unpack.c is_last_failure, data_set)) { data_set 3422 lib/pengine/unpack.c data_set); data_set 3432 lib/pengine/unpack.c pe__update_recheck_time(last_failure, data_set); data_set 3437 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, NULL, pe_fc_default, xml_op, data_set)) { data_set 3464 lib/pengine/unpack.c && should_clear_for_param_change(xml_op, task, rsc, node, data_set)) { data_set 3471 lib/pengine/unpack.c data_set); data_set 3473 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3485 lib/pengine/unpack.c order_after_remote_fencing(clear_op, rsc, data_set); data_set 3518 lib/pengine/unpack.c get_action_on_fail(pe_resource_t *rsc, const char *key, const char *task, pe_working_set_t * data_set) data_set 3521 lib/pengine/unpack.c pe_action_t *action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3531 lib/pengine/unpack.c xmlNode * last_failure, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3583 lib/pengine/unpack.c unpack_migrate_to_success(rsc, node, xml_op, data_set); data_set 3648 lib/pengine/unpack.c const pe_resource_t *rsc, pe_working_set_t *data_set) data_set 3655 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3664 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3729 lib/pengine/unpack.c && check_operation_expiry(rsc, node, rc, xml_op, data_set)) { data_set 3734 lib/pengine/unpack.c rc = remap_monitor_rc(rc, xml_op, node, rsc, data_set); data_set 3771 lib/pengine/unpack.c status = determine_op_status(rsc, rc, target_rc, node, xml_op, on_fail, data_set); data_set 3796 lib/pengine/unpack.c pe_node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 3824 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); data_set 3828 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3838 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3839 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 3873 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3886 lib/pengine/unpack.c on_fail, data_set); data_set 3890 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3899 lib/pengine/unpack.c data_set); data_set 3909 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3917 lib/pengine/unpack.c resource_location(parent, NULL, -INFINITY, "fatal-error", data_set); data_set 3929 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3936 lib/pengine/unpack.c .now = data_set->now, data_set 3947 lib/pengine/unpack.c if (pcmk__str_eq(node->details->id, data_set->dc_uuid, pcmk__str_casei)) { data_set 3948 lib/pengine/unpack.c data_set->dc_node = node; data_set 3957 lib/pengine/unpack.c cluster_name = g_hash_table_lookup(data_set->config_hash, "cluster-name"); data_set 3964 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set); data_set 4049 lib/pengine/unpack.c pe_working_set_t * data_set) data_set 4055 lib/pengine/unpack.c xmlNode *status = find_xml_node(data_set->input, XML_CIB_TAG_STATUS, TRUE); data_set 4071 lib/pengine/unpack.c this_node = pe_find_node(data_set->nodes, uname); data_set 4077 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 4080 lib/pengine/unpack.c determine_online_status(node_state, this_node, data_set); data_set 4084 lib/pengine/unpack.c || pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 30 lib/pengine/utils.c pe_working_set_t * data_set, guint interval_ms); data_set 90 lib/pengine/utils.c pe_can_fence(pe_working_set_t *data_set, pe_node_t *node) data_set 102 lib/pengine/utils.c && !pe_can_fence(data_set, container_node)) { data_set 108 lib/pengine/utils.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 111 lib/pengine/utils.c } else if (!pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 114 lib/pengine/utils.c } else if (pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 117 lib/pengine/utils.c } else if (data_set->no_quorum_policy == no_quorum_ignore) { data_set 234 lib/pengine/utils.c GHashTable *nodes, pe_working_set_t *data_set) data_set 236 lib/pengine/utils.c pcmk__output_t *out = data_set->priv; data_set 306 lib/pengine/utils.c GHashTable *nodes, pe_working_set_t *data_set) data_set 320 lib/pengine/utils.c pe__output_node_weights(rsc, comment, nodes, data_set); data_set 329 lib/pengine/utils.c comment, child->allowed_nodes, data_set); data_set 389 lib/pengine/utils.c effective_quorum_policy(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 391 lib/pengine/utils.c enum pe_quorum_policy policy = data_set->no_quorum_policy; data_set 393 lib/pengine/utils.c if (pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 396 lib/pengine/utils.c } else if (data_set->no_quorum_policy == no_quorum_demote) { data_set 415 lib/pengine/utils.c add_singleton(pe_working_set_t *data_set, pe_action_t *action) data_set 417 lib/pengine/utils.c if (data_set->singletons == NULL) { data_set 418 lib/pengine/utils.c data_set->singletons = pcmk__strkey_table(NULL, NULL); data_set 420 lib/pengine/utils.c g_hash_table_insert(data_set->singletons, action->uuid, action); data_set 424 lib/pengine/utils.c lookup_singleton(pe_working_set_t *data_set, const char *action_uuid) data_set 426 lib/pengine/utils.c if (data_set->singletons == NULL) { data_set 429 lib/pengine/utils.c return g_hash_table_lookup(data_set->singletons, action_uuid); data_set 445 lib/pengine/utils.c pe_working_set_t *data_set) data_set 453 lib/pengine/utils.c matches = find_actions(((rsc == NULL)? data_set->actions : rsc->actions), data_set 483 lib/pengine/utils.c bool optional, bool for_graph, pe_working_set_t *data_set) data_set 516 lib/pengine/utils.c unpack_operation(action, action->op_entry, rsc->container, data_set, data_set 523 lib/pengine/utils.c data_set->action_id, key, task, data_set 526 lib/pengine/utils.c action->id = data_set->action_id++; data_set 528 lib/pengine/utils.c data_set->actions = g_list_prepend(data_set->actions, action); data_set 530 lib/pengine/utils.c add_singleton(data_set, action); data_set 546 lib/pengine/utils.c unpack_action_node_attributes(pe_action_t *action, pe_working_set_t *data_set) data_set 554 lib/pengine/utils.c .now = data_set->now, data_set 563 lib/pengine/utils.c FALSE, data_set); data_set 607 lib/pengine/utils.c pe_working_set_t *data_set) data_set 630 lib/pengine/utils.c pe_fence_node(data_set, action->node, "stop is unrunnable", false); data_set 643 lib/pengine/utils.c && !pe_can_fence(data_set, action->node)) { data_set 661 lib/pengine/utils.c switch (effective_quorum_policy(action->rsc, data_set)) { data_set 733 lib/pengine/utils.c pe_working_set_t *data_set) data_set 737 lib/pengine/utils.c CRM_ASSERT((key != NULL) && (task != NULL) && (data_set != NULL)); data_set 740 lib/pengine/utils.c action = find_existing_action(key, rsc, on_node, data_set); data_set 745 lib/pengine/utils.c data_set); data_set 754 lib/pengine/utils.c unpack_action_node_attributes(action, data_set); data_set 757 lib/pengine/utils.c update_resource_action_runnable(action, save_action, data_set); data_set 965 lib/pengine/utils.c pe_get_configured_timeout(pe_resource_t *rsc, const char *action, pe_working_set_t *data_set) data_set 975 lib/pengine/utils.c .now = data_set->now, data_set 990 lib/pengine/utils.c if (timeout_spec == NULL && data_set->op_defaults) { data_set 992 lib/pengine/utils.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, data_set 993 lib/pengine/utils.c &rule_data, action_meta, NULL, FALSE, data_set); data_set 1066 lib/pengine/utils.c pe_working_set_t * data_set, guint interval_ms) data_set 1090 lib/pengine/utils.c .now = data_set->now, data_set 1099 lib/pengine/utils.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, &rule_data, data_set 1100 lib/pengine/utils.c action->meta, NULL, FALSE, data_set); data_set 1122 lib/pengine/utils.c action->meta, NULL, TRUE, data_set); data_set 1127 lib/pengine/utils.c pe_eval_versioned_attributes(data_set->input, xml_obj, data_set 1131 lib/pengine/utils.c pe_eval_versioned_attributes(data_set->input, xml_obj, data_set 1177 lib/pengine/utils.c GHashTable *params = pe_rsc_params(action->rsc, action->node, data_set); data_set 1226 lib/pengine/utils.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1288 lib/pengine/utils.c && pe__resource_is_remote_conn(action->rsc, data_set) data_set 1299 lib/pengine/utils.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1312 lib/pengine/utils.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1358 lib/pengine/utils.c if (unpack_interval_origin(value, xml_obj, interval_ms, data_set->now, data_set 1367 lib/pengine/utils.c data_set->now); data_set 1692 lib/pengine/utils.c pe_working_set_t * data_set) data_set 1697 lib/pengine/utils.c } else if (data_set != NULL) { data_set 1698 lib/pengine/utils.c GList *gIter = data_set->nodes; data_set 1852 lib/pengine/utils.c get_effective_time(pe_working_set_t * data_set) data_set 1854 lib/pengine/utils.c if(data_set) { data_set 1855 lib/pengine/utils.c if (data_set->now == NULL) { data_set 1857 lib/pengine/utils.c data_set->now = crm_time_new(NULL); data_set 1859 lib/pengine/utils.c return crm_time_get_seconds_since_epoch(data_set->now); data_set 1952 lib/pengine/utils.c get_pseudo_op(const char *name, pe_working_set_t * data_set) data_set 1954 lib/pengine/utils.c pe_action_t *op = lookup_singleton(data_set, name); data_set 1957 lib/pengine/utils.c op = custom_action(NULL, strdup(name), name, NULL, TRUE, TRUE, data_set); data_set 1976 lib/pengine/utils.c ticket_new(const char *ticket_id, pe_working_set_t * data_set) data_set 1984 lib/pengine/utils.c if (data_set->tickets == NULL) { data_set 1985 lib/pengine/utils.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 1988 lib/pengine/utils.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 2005 lib/pengine/utils.c g_hash_table_insert(data_set->tickets, strdup(ticket->id), ticket); data_set 2029 lib/pengine/utils.c pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag) data_set 2031 lib/pengine/utils.c for (GList *lpc = data_set->resources; lpc != NULL; lpc = lpc->next) { data_set 2068 lib/pengine/utils.c node_priority_fencing_delay(pe_node_t * node, pe_working_set_t * data_set) data_set 2077 lib/pengine/utils.c if (data_set->priority_fencing_delay <= 0) { data_set 2092 lib/pengine/utils.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 2131 lib/pengine/utils.c return data_set->priority_fencing_delay; data_set 2136 lib/pengine/utils.c bool priority_delay, pe_working_set_t * data_set) data_set 2142 lib/pengine/utils.c op = data_set->stonith_action; data_set 2147 lib/pengine/utils.c stonith_op = lookup_singleton(data_set, op_key); data_set 2149 lib/pengine/utils.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); data_set 2156 lib/pengine/utils.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2168 lib/pengine/utils.c GList *matches = find_unfencing_devices(data_set->resources, NULL); data_set 2176 lib/pengine/utils.c data = pe__compare_fencing_digest(match, agent, node, data_set); data_set 2180 lib/pengine/utils.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 2181 lib/pengine/utils.c pcmk__output_t *out = data_set->priv; data_set 2207 lib/pengine/utils.c if (data_set->priority_fencing_delay > 0 data_set 2223 lib/pengine/utils.c char *delay_s = pcmk__itoa(node_priority_fencing_delay(node, data_set)); data_set 2230 lib/pengine/utils.c if(optional == FALSE && pe_can_fence(data_set, node)) { data_set 2243 lib/pengine/utils.c pe_resource_t * rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t * data_set) data_set 2245 lib/pengine/utils.c if (!pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2258 lib/pengine/utils.c pe_action_t *unfence = pe_fence_op(node, "on", FALSE, reason, FALSE, data_set); data_set 2270 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); data_set 2396 lib/pengine/utils.c pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set) data_set 2398 lib/pengine/utils.c if ((recheck > get_effective_time(data_set)) data_set 2399 lib/pengine/utils.c && ((data_set->recheck_by == 0) data_set 2400 lib/pengine/utils.c || (data_set->recheck_by > recheck))) { data_set 2401 lib/pengine/utils.c data_set->recheck_by = recheck; data_set 2413 lib/pengine/utils.c pe_working_set_t *data_set) data_set 2417 lib/pengine/utils.c pe_eval_nvpairs(data_set->input, xml_obj, set_name, rule_data, hash, data_set 2422 lib/pengine/utils.c pe__update_recheck_time(recheck, data_set); data_set 2457 lib/pengine/utils.c pe_working_set_t *data_set) data_set 2464 lib/pengine/utils.c data_set); data_set 2508 lib/pengine/utils.c pe__build_node_name_list(pe_working_set_t *data_set, const char *s) { data_set 2518 lib/pengine/utils.c pe_node_t *node = pe_find_node(data_set->nodes, s); data_set 2532 lib/pengine/utils.c nodes = pe__unames_with_tag(data_set, s); data_set 2540 lib/pengine/utils.c pe__build_rsc_list(pe_working_set_t *data_set, const char *s) { data_set 2546 lib/pengine/utils.c pe_resource_t *rsc = pe_find_resource_with_flags(data_set->resources, s, data_set 2565 lib/pengine/utils.c resources = pe__rscs_with_tag(data_set, s); data_set 1704 tools/crm_mon.c print_simple_status(pcmk__output_t *out, pe_working_set_t * data_set) data_set 1715 tools/crm_mon.c if (data_set->dc_node == NULL) { data_set 1720 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1765 tools/crm_mon.c data_set->ninstances, pcmk__plural_s(data_set->ninstances)); data_set 181 tools/crm_resource.c static pe_working_set_t *data_set = NULL; data_set 222 tools/crm_resource.c pe_free_working_set(data_set); data_set 223 tools/crm_resource.c data_set = NULL; data_set 1028 tools/crm_resource.c options.interval_spec, TRUE, data_set, options.force); data_set 1051 tools/crm_resource.c before = build_constraint_list(data_set->input); data_set 1055 tools/crm_resource.c rc = cli_resource_clear_all_expired(data_set->input, cib_conn, options.cib_options, data_set 1060 tools/crm_resource.c dest = pe_find_node(data_set->nodes, options.host_uname); data_set 1072 tools/crm_resource.c rc = cli_resource_clear(options.rsc_id, NULL, data_set->nodes, data_set 1089 tools/crm_resource.c data_set->input = *cib_xml_copy; data_set 1090 tools/crm_resource.c cluster_status(data_set); data_set 1092 tools/crm_resource.c after = build_constraint_list(data_set->input); data_set 1258 tools/crm_resource.c data_set = pe_new_working_set(); data_set 1259 tools/crm_resource.c if (data_set == NULL) { data_set 1262 tools/crm_resource.c pe__set_working_set_flags(data_set, data_set 1264 tools/crm_resource.c data_set->priv = out; data_set 1265 tools/crm_resource.c rc = update_working_set_xml(data_set, cib_xml_copy); data_set 1275 tools/crm_resource.c cluster_status(data_set); data_set 1287 tools/crm_resource.c pe_node_t *node = pe_find_node(data_set->nodes, options.host_uname); data_set 1336 tools/crm_resource.c 0, FALSE, data_set, options.force); data_set 1764 tools/crm_resource.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 1775 tools/crm_resource.c if ((options.host_uname != NULL) && (data_set != NULL)) { data_set 1776 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1807 tools/crm_resource.c rc = out->message(out, "resource-list", data_set, data_set 1819 tools/crm_resource.c rc = out->message(out, "resource-names-list", data_set->resources); data_set 1868 tools/crm_resource.c options.timeout_ms, cib_conn, data_set, data_set 1874 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1879 tools/crm_resource.c options.override_params, data_set); data_set 1884 tools/crm_resource.c rc = out->message(out, "stacks-constraints", rsc, data_set, false); data_set 1888 tools/crm_resource.c rc = out->message(out, "stacks-constraints", rsc, data_set, true); data_set 1893 tools/crm_resource.c g_list_foreach(data_set->resources, (GFunc) cli_resource_print_cts, out); data_set 1894 tools/crm_resource.c cli_resource_print_cts_constraints(data_set); data_set 1899 tools/crm_resource.c options.rsc_id, data_set); data_set 1908 tools/crm_resource.c data_set); data_set 1914 tools/crm_resource.c data_set); data_set 1918 tools/crm_resource.c GList *nodes = cli_resource_search(rsc, options.rsc_id, data_set); data_set 1925 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, TRUE); data_set 1929 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, FALSE); data_set 1937 tools/crm_resource.c data_set->resources, rsc, node); data_set 1951 tools/crm_resource.c options.cib_options, data_set, data_set 2009 tools/crm_resource.c params = pe_rsc_params(rsc, current, data_set); data_set 2014 tools/crm_resource.c get_meta_attributes(params, rsc, current, data_set); data_set 2019 tools/crm_resource.c NULL, FALSE, data_set); data_set 2045 tools/crm_resource.c options.cib_options, data_set, data_set 2056 tools/crm_resource.c options.cib_options, data_set, data_set 2064 tools/crm_resource.c data_set); data_set 59 tools/crm_resource.h void cli_resource_print_cts_constraints(pe_working_set_t * data_set); data_set 61 tools/crm_resource.h int cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded); data_set 63 tools/crm_resource.h bool active, pe_working_set_t * data_set); data_set 68 tools/crm_resource.h const char *rsc_id, pe_working_set_t *data_set); data_set 70 tools/crm_resource.h pe_working_set_t *data_set); data_set 74 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 77 tools/crm_resource.h pe_working_set_t *data_set); data_set 83 tools/crm_resource.h pe_working_set_t *data_set, gboolean promoted_role_only, data_set 93 tools/crm_resource.h int timeout_ms, cib_t *cib, pe_working_set_t *data_set, data_set 101 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 106 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 108 tools/crm_resource.h int update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml); data_set 18 tools/crm_resource_print.c cli_resource_print_cts_constraints(pe_working_set_t * data_set) data_set 20 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 23 tools/crm_resource_print.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 35 tools/crm_resource_print.c if (pe_evaluate_rules(lifetime, NULL, data_set->now, NULL) == FALSE) { data_set 86 tools/crm_resource_print.c bool active, pe_working_set_t * data_set) data_set 88 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 90 tools/crm_resource_print.c GList *ops = find_operations(rsc_id, host_uname, active, data_set); data_set 101 tools/crm_resource_print.c out->message(out, "node-and-op", data_set, xml_op); data_set 110 tools/crm_resource_print.c cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded) data_set 112 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 70 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 287 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 289 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 403 tools/crm_resource_runtime.c pcmk__unpack_constraints(data_set); data_set 404 tools/crm_resource_runtime.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 423 tools/crm_resource_runtime.c data_set, force); data_set 438 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 440 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 506 tools/crm_resource_runtime.c const char *host_uname, const char *rsc_id, pe_working_set_t *data_set) data_set 508 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 516 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 536 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, host_uname); data_set 599 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 608 tools/crm_resource_runtime.c rc = send_lrm_rsc_op(controld_api, false, host_uname, rsc_id, data_set); data_set 626 tools/crm_resource_runtime.c const char *interval_spec, pe_working_set_t *data_set) data_set 647 tools/crm_resource_runtime.c for (xmlNode *xml_op = pcmk__xml_first_child(data_set->failed); data_set 659 tools/crm_resource_runtime.c pe_resource_t *fail_rsc = pe_find_resource_with_flags(data_set->resources, data_set 694 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, node_name, failed_id, data_set); data_set 727 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 729 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 743 tools/crm_resource_runtime.c interval_spec, just_failures, data_set, data_set 756 tools/crm_resource_runtime.c nodes = pcmk__copy_node_list(data_set->nodes, false); data_set 779 tools/crm_resource_runtime.c just_failures, data_set, force); data_set 791 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); data_set 820 tools/crm_resource_runtime.c interval_spec, data_set); data_set 822 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, host_uname, rsc->id, data_set); data_set 837 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 839 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 851 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, node_name); data_set 872 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 879 tools/crm_resource_runtime.c for (GList *iter = data_set->nodes; iter; iter = iter->next) { data_set 883 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 926 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 929 tools/crm_resource_runtime.c return send_lrm_rsc_op(controld_api, true, host_uname, rsc_id, data_set); data_set 934 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 945 tools/crm_resource_runtime.c params = pe_rsc_params(rsc, node, data_set); data_set 954 tools/crm_resource_runtime.c get_meta_attributes(meta, rsc, node, data_set); data_set 1074 tools/crm_resource_runtime.c update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml) data_set 1079 tools/crm_resource_runtime.c data_set->input = *xml; data_set 1080 tools/crm_resource_runtime.c data_set->now = crm_time_new(NULL); data_set 1096 tools/crm_resource_runtime.c update_working_set_from_cib(pcmk__output_t *out, pe_working_set_t * data_set, data_set 1109 tools/crm_resource_runtime.c rc = update_working_set_xml(data_set, &cib_xml_copy); data_set 1121 tools/crm_resource_runtime.c update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate) data_set 1128 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1130 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1131 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1149 tools/crm_resource_runtime.c rc = write_xml_file(data_set->input, shadow_file, FALSE); data_set 1164 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set, data_set->input, NULL); data_set 1168 tools/crm_resource_runtime.c run_simulation(data_set, shadow_cib, NULL); data_set 1171 tools/crm_resource_runtime.c rc = update_dataset(shadow_cib, data_set, FALSE); data_set 1174 tools/crm_resource_runtime.c cluster_status(data_set); data_set 1191 tools/crm_resource_runtime.c max_delay_for_resource(pe_working_set_t * data_set, pe_resource_t *rsc) data_set 1202 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, child); data_set 1212 tools/crm_resource_runtime.c pe_action_t *stop = custom_action(rsc, key, RSC_STOP, NULL, TRUE, FALSE, data_set); data_set 1229 tools/crm_resource_runtime.c max_delay_in(pe_working_set_t * data_set, GList *resources) data_set 1236 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, (const char *)item->data); data_set 1238 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, rsc); data_set 1288 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1323 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1324 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1330 tools/crm_resource_runtime.c data_set->priv = out; data_set 1331 tools/crm_resource_runtime.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 1332 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1339 tools/crm_resource_runtime.c restart_target_active = get_active_resources(host, data_set->resources); data_set 1340 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1363 tools/crm_resource_runtime.c data_set, force); data_set 1376 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, TRUE); data_set 1382 tools/crm_resource_runtime.c target_active = get_active_resources(host, data_set->resources); data_set 1393 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1403 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1412 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1437 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1443 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1463 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1475 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1488 tools/crm_resource_runtime.c current_active = get_active_resources(NULL, data_set->resources); data_set 1514 tools/crm_resource_runtime.c FALSE, cib, cib_options, data_set, force); data_set 1519 tools/crm_resource_runtime.c data_set, force); data_set 1536 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1617 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1624 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1625 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1628 tools/crm_resource_runtime.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 1637 tools/crm_resource_runtime.c print_pending_actions(out, data_set->actions); data_set 1638 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1646 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1647 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1649 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1652 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set, data_set->input, NULL); data_set 1663 tools/crm_resource_runtime.c const char *dc_version = g_hash_table_lookup(data_set->config_hash, data_set 1673 tools/crm_resource_runtime.c } while (actions_are_pending(data_set->actions)); data_set 1675 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1832 tools/crm_resource_runtime.c int timeout_ms, cib_t * cib, pe_working_set_t *data_set, data_set 1835 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1846 tools/crm_resource_runtime.c GList *nodes = cli_resource_search(rsc, requested_name, data_set); data_set 1877 tools/crm_resource_runtime.c data_set); data_set 1880 tools/crm_resource_runtime.c timeout_ms = pe_get_configured_timeout(rsc, get_action(rsc_action), data_set); data_set 1895 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean promoted_role_only, data_set 1898 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1902 tools/crm_resource_runtime.c pe_node_t *dest = pe_find_node(data_set->nodes, host_name); data_set 1966 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, NULL, data_set->nodes, cib, cib_options, FALSE, force); data_set 1969 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib, data_set 40 tools/crm_rule.c static int crm_rule_check(pe_working_set_t *data_set, const char *rule_id, crm_time_t *effective_date); data_set 106 tools/crm_rule.c crm_rule_check(pe_working_set_t *data_set, const char *rule_id, crm_time_t *effective_date) data_set 116 tools/crm_rule.c cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 232 tools/crm_rule.c pe_working_set_t *data_set = NULL; data_set 318 tools/crm_rule.c data_set = pe_new_working_set(); data_set 319 tools/crm_rule.c if (data_set == NULL) { data_set 323 tools/crm_rule.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 325 tools/crm_rule.c data_set->input = input; data_set 326 tools/crm_rule.c data_set->now = rule_date; data_set 329 tools/crm_rule.c cluster_status(data_set); data_set 337 tools/crm_rule.c rc = crm_rule_check(data_set, options.rule, rule_date); data_set 353 tools/crm_rule.c pe_free_working_set(data_set); data_set 477 tools/crm_simulate.c pe_working_set_t *data_set = NULL; data_set 540 tools/crm_simulate.c data_set = pe_new_working_set(); data_set 541 tools/crm_simulate.c if (data_set == NULL) { data_set 548 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 551 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 553 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_no_compat); data_set 556 tools/crm_simulate.c data_set->priv = out; data_set 557 tools/crm_simulate.c pcmk__profile_dir(options.test_dir, options.repeat, data_set, options.use_date); data_set 567 tools/crm_simulate.c rc = pcmk__simulate(data_set, out, options.injections, options.flags, section_opts, data_set 587 tools/crm_simulate.c if (data_set) { data_set 588 tools/crm_simulate.c pe_free_working_set(data_set); data_set 49 tools/crm_ticket.c find_ticket(const char *ticket_id, pe_working_set_t * data_set) data_set 53 tools/crm_ticket.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 124 tools/crm_ticket.c print_ticket_list(pe_working_set_t * data_set, gboolean raw, gboolean details) data_set 129 tools/crm_ticket.c g_hash_table_iter_init(&iter, data_set->tickets); data_set 269 tools/crm_ticket.c pe_working_set_t * data_set) data_set 276 tools/crm_ticket.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 371 tools/crm_ticket.c cib_t * cib, pe_working_set_t * data_set) data_set 412 tools/crm_ticket.c ticket = find_ticket(ticket_id, data_set); data_set 713 tools/crm_ticket.c pe_working_set_t *data_set = NULL; data_set 848 tools/crm_ticket.c data_set = pe_new_working_set(); data_set 849 tools/crm_ticket.c if (data_set == NULL) { data_set 854 tools/crm_ticket.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 888 tools/crm_ticket.c data_set->input = cib_xml_copy; data_set 889 tools/crm_ticket.c data_set->now = crm_time_new(NULL); data_set 891 tools/crm_ticket.c cluster_status(data_set); data_set 895 tools/crm_ticket.c pcmk__unpack_constraints(data_set); data_set 908 tools/crm_ticket.c pe_ticket_t *ticket = find_ticket(ticket_id, data_set); data_set 918 tools/crm_ticket.c rc = print_ticket_list(data_set, raw, details); data_set 948 tools/crm_ticket.c rc = get_ticket_state_attr(ticket_id, get_attr_name, &value, data_set); data_set 967 tools/crm_ticket.c ticket = find_ticket(ticket_id, data_set); data_set 1014 tools/crm_ticket.c rc = modify_ticket_state(ticket_id, attr_delete, attr_set, cib_conn, data_set); data_set 1060 tools/crm_ticket.c pe_free_working_set(data_set); data_set 1061 tools/crm_ticket.c data_set = NULL; data_set 48 tools/crm_verify.c extern gboolean stage0(pe_working_set_t * data_set); data_set 110 tools/crm_verify.c pe_working_set_t *data_set = NULL; data_set 220 tools/crm_verify.c data_set = pe_new_working_set(); data_set 221 tools/crm_verify.c if (data_set == NULL) { data_set 226 tools/crm_verify.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 227 tools/crm_verify.c data_set->priv = out; data_set 232 tools/crm_verify.c pcmk__schedule_actions(data_set, cib_object, NULL); data_set 235 tools/crm_verify.c data_set->now = crm_time_new(NULL); data_set 236 tools/crm_verify.c data_set->input = cib_object; data_set 237 tools/crm_verify.c stage0(data_set); data_set 239 tools/crm_verify.c pe_free_working_set(data_set);