data_set 427 daemons/execd/cts-exec-helper.c pe_working_set_t *data_set = NULL; data_set 438 daemons/execd/cts-exec-helper.c data_set = pe_new_working_set(); data_set 439 daemons/execd/cts-exec-helper.c if (data_set == NULL) { data_set 443 daemons/execd/cts-exec-helper.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 470 daemons/execd/cts-exec-helper.c data_set->input = cib_xml_copy; data_set 471 daemons/execd/cts-exec-helper.c data_set->now = crm_time_new(NULL); data_set 473 daemons/execd/cts-exec-helper.c cluster_status(data_set); data_set 475 daemons/execd/cts-exec-helper.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 485 daemons/execd/cts-exec-helper.c params = pe_rsc_params(rsc, NULL, data_set); data_set 488 daemons/execd/cts-exec-helper.c get_meta_attributes(meta, rsc, NULL, data_set); data_set 515 daemons/execd/cts-exec-helper.c pe_free_working_set(data_set); data_set 648 daemons/fenced/pacemaker-fenced.c static void cib_device_update(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 659 daemons/fenced/pacemaker-fenced.c cib_device_update(gIter->data, data_set); data_set 720 daemons/fenced/pacemaker-fenced.c rsc_params = pe_rsc_params(rsc, node, data_set); data_set 721 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 514 include/crm/pengine/internal.h void pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag); data_set 521 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 524 include/crm/pengine/internal.h const char *score, pe_working_set_t * data_set); data_set 531 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 540 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 542 include/crm/pengine/internal.h enum pe_check_parameters, pe_working_set_t *data_set); data_set 543 include/crm/pengine/internal.h void pe__foreach_param_check(pe_working_set_t *data_set, data_set 547 include/crm/pengine/internal.h void pe__free_param_checks(pe_working_set_t *data_set); data_set 550 include/crm/pengine/internal.h void pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set); data_set 561 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 565 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 567 include/crm/pengine/internal.h GList *pe__rscs_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 568 include/crm/pengine/internal.h GList *pe__unames_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 569 include/crm/pengine/internal.h bool pe__rsc_has_tag(pe_working_set_t *data_set, const char *rsc, const char *tag); data_set 570 include/crm/pengine/internal.h bool pe__uname_has_tag(pe_working_set_t *data_set, const char *node, const char *tag); data_set 574 include/crm/pengine/internal.h GList * pe__build_node_name_list(pe_working_set_t *data_set, const char *s); data_set 575 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 74 include/pacemaker.h pe_working_set_t *data_set); data_set 19 include/pcmki/pcmki_resource.h pe_working_set_t *data_set); data_set 40 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 55 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 56 include/pcmki/pcmki_sched_allocate.h extern void native_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 57 include/pcmki/pcmki_sched_allocate.h extern void native_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 60 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 63 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 65 include/pcmki/pcmki_sched_allocate.h pe_working_set_t * data_set); data_set 69 include/pcmki/pcmki_sched_allocate.h extern void native_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 71 include/pcmki/pcmki_sched_allocate.h gboolean force, 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 group_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 77 include/pcmki/pcmki_sched_allocate.h extern void group_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 86 include/pcmki/pcmki_sched_allocate.h extern void group_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 90 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 92 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 95 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 97 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 105 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 109 include/pcmki/pcmki_sched_allocate.h void pcmk__bundle_expand(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 113 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 114 include/pcmki/pcmki_sched_allocate.h extern void clone_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 115 include/pcmki/pcmki_sched_allocate.h extern void clone_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 118 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 121 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 124 include/pcmki/pcmki_sched_allocate.h extern void clone_expand(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 126 include/pcmki/pcmki_sched_allocate.h gboolean force, 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 void create_promotable_actions(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 133 include/pcmki/pcmki_sched_allocate.h void promote_demote_constraints(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 134 include/pcmki/pcmki_sched_allocate.h void promotable_constraints(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 137 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 142 include/pcmki/pcmki_sched_allocate.h extern gboolean unpack_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 144 include/pcmki/pcmki_sched_allocate.h extern gboolean unpack_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 146 include/pcmki/pcmki_sched_allocate.h void LogNodeActions(pe_working_set_t * data_set); data_set 147 include/pcmki/pcmki_sched_allocate.h void LogActions(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 148 include/pcmki/pcmki_sched_allocate.h void pcmk__bundle_log_actions(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 151 include/pcmki/pcmki_sched_allocate.h pe_working_set_t * data_set); data_set 158 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 164 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 171 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 173 include/pcmki/pcmki_sched_allocate.h gboolean update_action(pe_action_t *action, pe_working_set_t *data_set); data_set 177 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 28 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 33 include/pcmki/pcmki_sched_utils.h bool influence, pe_working_set_t *data_set); data_set 37 include/pcmki/pcmki_sched_utils.h pe_working_set_t * data_set); data_set 42 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 56 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 79 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 80 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 83 include/pcmki/pcmki_sched_utils.h pe_working_set_t *data_set); data_set 84 include/pcmki/pcmki_sched_utils.h pe_action_t *sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set); data_set 94 include/pcmki/pcmki_sched_utils.h pe_working_set_t * data_set, cib_t *cib, data_set 99 include/pcmki/pcmki_sched_utils.h int run_simulation(pe_working_set_t * data_set, cib_t *cib, GList *op_fail_list); 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 stage3(pe_working_set_t * data_set); data_set 72 include/pcmki/pcmki_scheduler.h extern gboolean stage4(pe_working_set_t * data_set); data_set 73 include/pcmki/pcmki_scheduler.h extern gboolean stage5(pe_working_set_t * data_set); data_set 74 include/pcmki/pcmki_scheduler.h extern gboolean stage6(pe_working_set_t * data_set); data_set 75 include/pcmki/pcmki_scheduler.h extern gboolean stage7(pe_working_set_t * data_set); data_set 76 include/pcmki/pcmki_scheduler.h extern gboolean stage8(pe_working_set_t * data_set); data_set 80 include/pcmki/pcmki_scheduler.h extern gboolean unpack_constraints(xmlNode * xml_constraints, pe_working_set_t * data_set); data_set 83 include/pcmki/pcmki_scheduler.h pe_working_set_t * data_set); data_set 85 include/pcmki/pcmki_scheduler.h void pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set); data_set 89 include/pcmki/pcmki_scheduler.h enum pe_ordering type, pe_working_set_t * data_set); data_set 93 include/pcmki/pcmki_scheduler.h enum pe_ordering type, pe_working_set_t * data_set); data_set 96 include/pcmki/pcmki_scheduler.h new_rsc_order(rsc1, CRMD_ACTION_START, rsc2, CRMD_ACTION_START, type, data_set) data_set 98 include/pcmki/pcmki_scheduler.h new_rsc_order(rsc1, CRMD_ACTION_STOP, rsc2, CRMD_ACTION_STOP, type, data_set) data_set 100 include/pcmki/pcmki_scheduler.h extern void graph_element_from_action(pe_action_t * action, pe_working_set_t * data_set); data_set 101 include/pcmki/pcmki_scheduler.h extern void add_maintenance_update(pe_working_set_t *data_set); data_set 102 include/pcmki/pcmki_scheduler.h xmlNode *pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input, data_set 540 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 544 lib/pacemaker/pcmk_output.c data_set->input); data_set 546 lib/pacemaker/pcmk_output.c unpack_constraints(cib_constraints, data_set); data_set 553 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 556 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 565 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 569 lib/pacemaker/pcmk_output.c data_set->input); data_set 571 lib/pacemaker/pcmk_output.c unpack_constraints(cib_constraints, data_set); data_set 579 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 582 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 1461 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1474 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "cluster-summary", data_set, data_set 1479 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-list", data_set->nodes, unames, data_set 1485 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "resource-list", data_set, show_opts, data_set 1491 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-attribute-list", data_set, data_set 1499 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-summary", data_set, unames, data_set 1505 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1507 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "failed-action-list", data_set, unames, data_set 1534 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ticket-list", data_set, rc == pcmk_rc_ok)); data_set 1539 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ban-list", data_set, prefix, resources, data_set 1580 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1590 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1594 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, show_opts); data_set 1602 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, full_show_opts, data_set 1608 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, FALSE, data_set 1616 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1622 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1624 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1636 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, FALSE); data_set 1641 lib/pacemaker/pcmk_output.c out->message(out, "ban-list", data_set, prefix, resources, show_opts, data_set 1654 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1665 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1669 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, show_opts); data_set 1674 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, show_opts, TRUE, unames, data_set 1680 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, FALSE, data_set 1688 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1694 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1696 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1746 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, FALSE); data_set 1751 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 29 lib/pacemaker/pcmk_sched_allocate.c void set_alloc_actions(pe_working_set_t * data_set); data_set 30 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 31 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 32 lib/pacemaker/pcmk_sched_allocate.c static void apply_remote_node_ordering(pe_working_set_t *data_set); data_set 123 lib/pacemaker/pcmk_sched_allocate.c gboolean active_here, pe_working_set_t * data_set) data_set 148 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, node, "Device definition changed", NULL, data_set); data_set 170 lib/pacemaker/pcmk_sched_allocate.c const char *reason, pe_working_set_t * data_set) data_set 189 lib/pacemaker/pcmk_sched_allocate.c cancel = pe_cancel_op(rsc, task, interval_ms, active_node, data_set); data_set 191 lib/pacemaker/pcmk_sched_allocate.c custom_action_order(rsc, stop_key(rsc), NULL, rsc, NULL, cancel, pe_order_optional, data_set); data_set 196 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t * data_set) data_set 219 lib/pacemaker/pcmk_sched_allocate.c && pcmk_is_set(data_set->flags, pe_flag_stop_action_orphans)) { data_set 220 lib/pacemaker/pcmk_sched_allocate.c CancelXmlOp(rsc, xml_op, active_node, "orphan", data_set); data_set 247 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, xml_op, active_node, data_set); data_set 249 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_sanitized)) { data_set 257 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 258 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 272 lib/pacemaker/pcmk_sched_allocate.c required = custom_action(rsc, key, task, NULL, TRUE, TRUE, data_set); data_set 276 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed", NULL, data_set); data_set 283 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed (reload)", NULL, data_set); data_set 292 lib/pacemaker/pcmk_sched_allocate.c ReloadRsc(rsc, active_node, data_set); data_set 295 lib/pacemaker/pcmk_sched_allocate.c op = custom_action(rsc, key, task, active_node, TRUE, TRUE, data_set); data_set 303 lib/pacemaker/pcmk_sched_allocate.c ReloadRsc(rsc, active_node, data_set); data_set 314 lib/pacemaker/pcmk_sched_allocate.c required = custom_action(rsc, key, task, NULL, TRUE, TRUE, data_set); data_set 331 lib/pacemaker/pcmk_sched_allocate.c enum pe_check_parameters check, pe_working_set_t *data_set) data_set 338 lib/pacemaker/pcmk_sched_allocate.c if (check_action_definition(rsc, node, rsc_op, data_set) data_set 340 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 347 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, rsc_op, node, data_set); data_set 363 lib/pacemaker/pcmk_sched_allocate.c pe__clear_failcount(rsc, node, reason, data_set); data_set 368 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 389 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 396 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, FALSE, data_set)) { data_set 397 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 406 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, TRUE, data_set)) { data_set 407 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 441 lib/pacemaker/pcmk_sched_allocate.c CancelXmlOp(rsc, rsc_op, node, "maintenance mode", data_set); data_set 449 lib/pacemaker/pcmk_sched_allocate.c if (pe__bundle_needs_remote_name(rsc, data_set)) { data_set 458 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 460 lib/pacemaker/pcmk_sched_allocate.c } else if (check_action_definition(rsc, node, rsc_op, data_set) data_set 462 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 464 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 473 lib/pacemaker/pcmk_sched_allocate.c gboolean partial, pe_working_set_t * data_set) data_set 483 lib/pacemaker/pcmk_sched_allocate.c if (data_set == NULL) { data_set 486 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 529 lib/pacemaker/pcmk_sched_allocate.c check_actions(pe_working_set_t * data_set) data_set 534 lib/pacemaker/pcmk_sched_allocate.c xmlNode *status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 547 lib/pacemaker/pcmk_sched_allocate.c node = pe_find_node_id(data_set->nodes, id); data_set 561 lib/pacemaker/pcmk_sched_allocate.c || pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 577 lib/pacemaker/pcmk_sched_allocate.c result = find_rsc_list(NULL, NULL, rsc_id, TRUE, FALSE, data_set); data_set 584 lib/pacemaker/pcmk_sched_allocate.c check_actions_for(rsc_entry, rsc, node, data_set); data_set 596 lib/pacemaker/pcmk_sched_allocate.c apply_placement_constraints(pe_working_set_t * data_set) data_set 598 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter = data_set->placement_constraints; data_set 629 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t *data_set) data_set 647 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 662 lib/pacemaker/pcmk_sched_allocate.c resource_location(failed, node, -INFINITY, "__fail_limit__", data_set); data_set 673 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 681 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(child_rsc, node, data_set); data_set 694 lib/pacemaker/pcmk_sched_allocate.c || pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 697 lib/pacemaker/pcmk_sched_allocate.c resource_location(sticky_rsc, node, rsc->stickiness, "stickiness", data_set); data_set 726 lib/pacemaker/pcmk_sched_allocate.c check_migration_threshold(rsc, node, data_set); data_set 745 lib/pacemaker/pcmk_sched_allocate.c set_alloc_actions(pe_working_set_t * data_set) data_set 748 lib/pacemaker/pcmk_sched_allocate.c GList *gIter = data_set->resources; data_set 780 lib/pacemaker/pcmk_sched_allocate.c apply_system_health(pe_working_set_t * data_set) data_set 783 lib/pacemaker/pcmk_sched_allocate.c const char *health_strategy = pe_pref(data_set->config_hash, "node-health-strategy"); data_set 816 lib/pacemaker/pcmk_sched_allocate.c base_health = char2score(pe_pref(data_set->config_hash, data_set 834 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 849 lib/pacemaker/pcmk_sched_allocate.c GList *gIter2 = data_set->resources; data_set 854 lib/pacemaker/pcmk_sched_allocate.c rsc2node_new(health_strategy, rsc, system_health, NULL, node, data_set); data_set 863 lib/pacemaker/pcmk_sched_allocate.c stage0(pe_working_set_t * data_set) data_set 865 lib/pacemaker/pcmk_sched_allocate.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 867 lib/pacemaker/pcmk_sched_allocate.c if (data_set->input == NULL) { data_set 871 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_have_status)) { data_set 873 lib/pacemaker/pcmk_sched_allocate.c cluster_status(data_set); data_set 876 lib/pacemaker/pcmk_sched_allocate.c set_alloc_actions(data_set); data_set 877 lib/pacemaker/pcmk_sched_allocate.c apply_system_health(data_set); data_set 878 lib/pacemaker/pcmk_sched_allocate.c unpack_constraints(cib_constraints, data_set); data_set 887 lib/pacemaker/pcmk_sched_allocate.c probe_resources(pe_working_set_t * data_set) data_set 891 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 900 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, node, "the connection is unrecoverable", FALSE); data_set 914 lib/pacemaker/pcmk_sched_allocate.c CRM_OP_REPROBE, node, FALSE, TRUE, data_set); data_set 920 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter2 = data_set->resources; gIter2 != NULL; gIter2 = gIter2->next) { data_set 923 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->create_probe(rsc, node, probe_node_complete, FALSE, data_set); data_set 952 lib/pacemaker/pcmk_sched_allocate.c shutdown_time(pe_node_t *node, pe_working_set_t *data_set) data_set 964 lib/pacemaker/pcmk_sched_allocate.c return result? result : get_effective_time(data_set); data_set 968 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_lock(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 976 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_lock((pe_resource_t *) item->data, data_set); data_set 985 lib/pacemaker/pcmk_sched_allocate.c || pe__resource_is_remote_conn(rsc, data_set)) { data_set 1000 lib/pacemaker/pcmk_sched_allocate.c pe__clear_resource_history(rsc, rsc->lock_node, data_set); data_set 1015 lib/pacemaker/pcmk_sched_allocate.c rsc->lock_time = shutdown_time(node, data_set); data_set 1025 lib/pacemaker/pcmk_sched_allocate.c if (data_set->shutdown_lock > 0) { data_set 1026 lib/pacemaker/pcmk_sched_allocate.c time_t lock_expiration = rsc->lock_time + data_set->shutdown_lock; data_set 1031 lib/pacemaker/pcmk_sched_allocate.c pe__update_recheck_time(++lock_expiration, data_set); data_set 1038 lib/pacemaker/pcmk_sched_allocate.c for (GList *item = data_set->nodes; item != NULL; item = item->next) { data_set 1043 lib/pacemaker/pcmk_sched_allocate.c XML_CONFIG_ATTR_SHUTDOWN_LOCK, data_set); data_set 1056 lib/pacemaker/pcmk_sched_allocate.c stage2(pe_working_set_t * data_set) data_set 1060 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 1061 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1062 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_lock((pe_resource_t *) gIter->data, data_set); data_set 1066 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_no_compat)) { data_set 1068 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1073 lib/pacemaker/pcmk_sched_allocate.c data_set->max_valid_nodes++; data_set 1078 lib/pacemaker/pcmk_sched_allocate.c apply_placement_constraints(data_set); data_set 1080 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 1085 lib/pacemaker/pcmk_sched_allocate.c gIter2 = data_set->resources; data_set 1089 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(rsc, node, data_set); data_set 1101 lib/pacemaker/pcmk_sched_allocate.c stage3(pe_working_set_t * data_set) data_set 1104 lib/pacemaker/pcmk_sched_allocate.c GList *gIter = data_set->resources; data_set 1109 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->internal_constraints(rsc, data_set); data_set 1119 lib/pacemaker/pcmk_sched_allocate.c stage4(pe_working_set_t * data_set) data_set 1121 lib/pacemaker/pcmk_sched_allocate.c check_actions(data_set); data_set 1263 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(pe_working_set_t * data_set) data_set 1267 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 1272 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1279 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->allocate(rsc, rsc->partial_migration_target, data_set); data_set 1284 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1291 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->allocate(rsc, NULL, data_set); data_set 1305 lib/pacemaker/pcmk_sched_allocate.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 1307 lib/pacemaker/pcmk_sched_allocate.c if (lh_rsc && rh_action && data_set) { data_set 1311 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1317 lib/pacemaker/pcmk_sched_allocate.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 1319 lib/pacemaker/pcmk_sched_allocate.c if (lh_action && rh_rsc && data_set) { data_set 1322 lib/pacemaker/pcmk_sched_allocate.c pe_order_preserve | extra, data_set); data_set 1328 lib/pacemaker/pcmk_sched_allocate.c cleanup_orphans(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1332 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1337 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 1342 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1349 lib/pacemaker/pcmk_sched_allocate.c pe_order_optional, data_set); data_set 1355 lib/pacemaker/pcmk_sched_allocate.c stage5(pe_working_set_t * data_set) data_set 1357 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 1360 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk__str_eq(data_set->placement_strategy, "default", pcmk__str_casei)) { data_set 1361 lib/pacemaker/pcmk_sched_allocate.c GList *nodes = g_list_copy(data_set->nodes); data_set 1363 lib/pacemaker/pcmk_sched_allocate.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 1364 lib/pacemaker/pcmk_sched_allocate.c data_set->resources = data_set 1365 lib/pacemaker/pcmk_sched_allocate.c g_list_sort_with_data(data_set->resources, sort_rsc_process_order, nodes); data_set 1370 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 1374 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 1382 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(data_set); data_set 1384 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->nodes; data_set 1388 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 1394 lib/pacemaker/pcmk_sched_allocate.c pe__foreach_param_check(data_set, check_params); data_set 1395 lib/pacemaker/pcmk_sched_allocate.c pe__free_param_checks(data_set); data_set 1397 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 1433 lib/pacemaker/pcmk_sched_allocate.c probe_resources(data_set); data_set 1437 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 1438 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1445 lib/pacemaker/pcmk_sched_allocate.c cleanup_orphans(rsc, data_set); data_set 1452 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1455 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->create_actions(rsc, data_set); data_set 1483 lib/pacemaker/pcmk_sched_allocate.c any_managed_resources(pe_working_set_t * data_set) data_set 1486 lib/pacemaker/pcmk_sched_allocate.c GList *gIter = data_set->resources; data_set 1506 lib/pacemaker/pcmk_sched_allocate.c fence_guest(pe_node_t *node, pe_working_set_t *data_set) data_set 1534 lib/pacemaker/pcmk_sched_allocate.c stonith_op = pe_fence_op(node, fence_action, FALSE, "guest is unclean", FALSE, data_set); data_set 1542 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *parent_stonith_op = pe_fence_op(stop->node, NULL, FALSE, NULL, FALSE, data_set); data_set 1581 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_vs_fence(stonith_op, data_set); data_set 1588 lib/pacemaker/pcmk_sched_allocate.c stage6(pe_working_set_t * data_set) data_set 1605 lib/pacemaker/pcmk_sched_allocate.c apply_remote_node_ordering(data_set); data_set 1608 lib/pacemaker/pcmk_sched_allocate.c if (any_managed_resources(data_set) == FALSE) { data_set 1614 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1622 lib/pacemaker/pcmk_sched_allocate.c && pe_can_fence(data_set, node)) { data_set 1623 lib/pacemaker/pcmk_sched_allocate.c fence_guest(node, data_set); data_set 1631 lib/pacemaker/pcmk_sched_allocate.c && need_stonith && pe_can_fence(data_set, node)) { data_set 1633 lib/pacemaker/pcmk_sched_allocate.c stonith_op = pe_fence_op(node, NULL, FALSE, "node is unclean", FALSE, data_set); data_set 1636 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_vs_fence(stonith_op, data_set); data_set 1644 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing) data_set 1665 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *down_op = sched_shutdown_op(node, data_set); data_set 1683 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1687 lib/pacemaker/pcmk_sched_allocate.c } else if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 1715 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)) { data_set 1832 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t *data_set) data_set 1871 lib/pacemaker/pcmk_sched_allocate.c lh_action = custom_action(lh_rsc, key, op_type, NULL, TRUE, TRUE, data_set); data_set 1897 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t *data_set); data_set 1913 lib/pacemaker/pcmk_sched_allocate.c apply_container_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 1937 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "container failed", FALSE); data_set 1959 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1963 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1985 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 1998 lib/pacemaker/pcmk_sched_allocate.c pe_order_implies_then, data_set); data_set 2002 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 2086 lib/pacemaker/pcmk_sched_allocate.c apply_remote_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 2127 lib/pacemaker/pcmk_sched_allocate.c order_start_then_action(remote_rsc, action, order_opts, data_set); data_set 2133 lib/pacemaker/pcmk_sched_allocate.c pe_order_implies_first, data_set); data_set 2142 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "resources are active and the connection is unrecoverable", FALSE); data_set 2150 lib/pacemaker/pcmk_sched_allocate.c pe_order_implies_first, data_set); data_set 2156 lib/pacemaker/pcmk_sched_allocate.c order_start_then_action(remote_rsc, action, pe_order_none, data_set); data_set 2167 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 2179 lib/pacemaker/pcmk_sched_allocate.c pe_order_implies_then, data_set); data_set 2190 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "resources are in an unknown state and the connection is unrecoverable", FALSE); data_set 2202 lib/pacemaker/pcmk_sched_allocate.c pe_order_runnable_left, data_set); data_set 2206 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 2214 lib/pacemaker/pcmk_sched_allocate.c apply_remote_node_ordering(pe_working_set_t *data_set) data_set 2216 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 2220 lib/pacemaker/pcmk_sched_allocate.c for (GList *gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2243 lib/pacemaker/pcmk_sched_allocate.c data_set); data_set 2287 lib/pacemaker/pcmk_sched_allocate.c pe_order_optional, data_set); data_set 2303 lib/pacemaker/pcmk_sched_allocate.c apply_container_ordering(action, data_set); data_set 2307 lib/pacemaker/pcmk_sched_allocate.c apply_remote_ordering(action, data_set); data_set 2340 lib/pacemaker/pcmk_sched_allocate.c order_first_probes_imply_stops(pe_working_set_t * data_set) data_set 2344 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->ordering_constraints; gIter != NULL; gIter = gIter->next) { data_set 2467 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t * data_set) data_set 2542 lib/pacemaker/pcmk_sched_allocate.c FALSE, data_set); data_set 2592 lib/pacemaker/pcmk_sched_allocate.c order_first_probe_then_restart_repromote(probe, after_wrapper->action, data_set); data_set 2596 lib/pacemaker/pcmk_sched_allocate.c static void clear_actions_tracking_flag(pe_working_set_t * data_set) data_set 2600 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2610 lib/pacemaker/pcmk_sched_allocate.c order_first_rsc_probes(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 2618 lib/pacemaker/pcmk_sched_allocate.c order_first_rsc_probes(child, data_set); data_set 2634 lib/pacemaker/pcmk_sched_allocate.c order_first_probe_then_restart_repromote(probe, after_wrapper->action, data_set); data_set 2635 lib/pacemaker/pcmk_sched_allocate.c clear_actions_tracking_flag(data_set); data_set 2643 lib/pacemaker/pcmk_sched_allocate.c order_first_probes(pe_working_set_t * data_set) data_set 2647 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2650 lib/pacemaker/pcmk_sched_allocate.c order_first_rsc_probes(rsc, data_set); data_set 2653 lib/pacemaker/pcmk_sched_allocate.c order_first_probes_imply_stops(data_set); data_set 2657 lib/pacemaker/pcmk_sched_allocate.c order_then_probes(pe_working_set_t * data_set) data_set 2662 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2774 lib/pacemaker/pcmk_sched_allocate.c order_probes(pe_working_set_t * data_set) data_set 2776 lib/pacemaker/pcmk_sched_allocate.c order_first_probes(data_set); data_set 2777 lib/pacemaker/pcmk_sched_allocate.c order_then_probes(data_set); data_set 2781 lib/pacemaker/pcmk_sched_allocate.c stage7(pe_working_set_t * data_set) data_set 2783 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *prev_out = data_set->priv; data_set 2795 lib/pacemaker/pcmk_sched_allocate.c data_set->ordering_constraints = g_list_reverse(data_set->ordering_constraints); data_set 2797 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->ordering_constraints; gIter != NULL; gIter = gIter->next) { data_set 2805 lib/pacemaker/pcmk_sched_allocate.c rsc_order_first(rsc, order, data_set); data_set 2820 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2823 lib/pacemaker/pcmk_sched_allocate.c update_colo_start_chain(action, data_set); data_set 2827 lib/pacemaker/pcmk_sched_allocate.c order_probes(data_set); data_set 2829 lib/pacemaker/pcmk_sched_allocate.c crm_trace("Updating %d actions", g_list_length(data_set->actions)); data_set 2830 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2833 lib/pacemaker/pcmk_sched_allocate.c update_action(action, data_set); data_set 2837 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2860 lib/pacemaker/pcmk_sched_allocate.c data_set->priv = out; data_set 2863 lib/pacemaker/pcmk_sched_allocate.c LogNodeActions(data_set); data_set 2865 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2868 lib/pacemaker/pcmk_sched_allocate.c LogActions(rsc, data_set); data_set 2875 lib/pacemaker/pcmk_sched_allocate.c data_set->priv = prev_out; data_set 2918 lib/pacemaker/pcmk_sched_allocate.c stage8(pe_working_set_t * data_set) data_set 2927 lib/pacemaker/pcmk_sched_allocate.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 2929 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "cluster-delay"); data_set 2930 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "cluster-delay", value); data_set 2932 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 2933 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "stonith-timeout", value); data_set 2935 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-stop-offset", "INFINITY"); data_set 2937 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)) { data_set 2938 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "INFINITY"); data_set 2940 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "1"); data_set 2943 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "batch-limit"); data_set 2944 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "batch-limit", value); data_set 2946 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add_int(data_set->graph, "transition_id", transition_id); data_set 2948 lib/pacemaker/pcmk_sched_allocate.c value = pe_pref(data_set->config_hash, "migration-limit"); data_set 2950 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "migration-limit", value); data_set 2953 lib/pacemaker/pcmk_sched_allocate.c if (data_set->recheck_by > 0) { data_set 2957 lib/pacemaker/pcmk_sched_allocate.c (long long) data_set->recheck_by); data_set 2958 lib/pacemaker/pcmk_sched_allocate.c crm_xml_add(data_set->graph, "recheck-by", recheck_epoch); data_set 2975 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->resources; data_set 2980 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->expand(rsc, data_set); data_set 2983 lib/pacemaker/pcmk_sched_allocate.c crm_log_xml_trace(data_set->graph, "created resource-driven action list"); data_set 2986 lib/pacemaker/pcmk_sched_allocate.c add_maintenance_update(data_set); data_set 2991 lib/pacemaker/pcmk_sched_allocate.c gIter = data_set->actions; data_set 3007 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 3008 lib/pacemaker/pcmk_sched_allocate.c || data_set->no_quorum_policy == no_quorum_ignore) { data_set 3018 lib/pacemaker/pcmk_sched_allocate.c graph_element_from_action(action, data_set); data_set 3021 lib/pacemaker/pcmk_sched_allocate.c crm_log_xml_trace(data_set->graph, "created generic action list"); data_set 3028 lib/pacemaker/pcmk_sched_allocate.c LogNodeActions(pe_working_set_t * data_set) data_set 3030 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 3033 lib/pacemaker/pcmk_sched_allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 33 lib/pacemaker/pcmk_sched_bundle.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 35 lib/pacemaker/pcmk_sched_bundle.c int max, int per_host_max, pe_working_set_t * data_set); data_set 65 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 82 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 104 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 117 lib/pacemaker/pcmk_sched_bundle.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 118 lib/pacemaker/pcmk_sched_bundle.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 121 lib/pacemaker/pcmk_sched_bundle.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 122 lib/pacemaker/pcmk_sched_bundle.c containers = g_list_sort_with_data(containers, sort_clone_instance, data_set); data_set 124 lib/pacemaker/pcmk_sched_bundle.c bundle_data->nreplicas_per_host, data_set); data_set 137 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->allocate(replica->ip, prefer, data_set); data_set 149 lib/pacemaker/pcmk_sched_bundle.c NULL, true, data_set); data_set 156 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 169 lib/pacemaker/pcmk_sched_bundle.c data_set)) { data_set 178 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 197 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->allocate(bundle_data->child, prefer, data_set); data_set 206 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_create_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 222 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->create_actions(replica->ip, data_set); data_set 226 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 229 lib/pacemaker/pcmk_sched_bundle.c replica->remote->cmds->create_actions(replica->remote, data_set); data_set 233 lib/pacemaker/pcmk_sched_bundle.c clone_create_pseudo_actions(rsc, containers, NULL, NULL, data_set); data_set 236 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->create_actions(bundle_data->child, data_set); data_set 240 lib/pacemaker/pcmk_sched_bundle.c create_pseudo_resource_op(rsc, RSC_PROMOTE, TRUE, TRUE, data_set); data_set 241 lib/pacemaker/pcmk_sched_bundle.c action = create_pseudo_resource_op(rsc, RSC_PROMOTED, TRUE, TRUE, data_set); data_set 245 lib/pacemaker/pcmk_sched_bundle.c create_pseudo_resource_op(rsc, RSC_DEMOTE, TRUE, TRUE, data_set); data_set 246 lib/pacemaker/pcmk_sched_bundle.c action = create_pseudo_resource_op(rsc, RSC_DEMOTED, TRUE, TRUE, data_set); data_set 256 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 266 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 268 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 272 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 274 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 277 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 279 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 291 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 303 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 305 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 308 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->internal_constraints(replica->ip, data_set); data_set 312 lib/pacemaker/pcmk_sched_bundle.c pe_order_runnable_left|pe_order_preserve, data_set); data_set 314 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first|pe_order_preserve, data_set); data_set 318 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 328 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 340 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->internal_constraints(bundle_data->child, data_set); data_set 342 lib/pacemaker/pcmk_sched_bundle.c promote_demote_constraints(rsc, data_set); data_set 346 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 350 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 354 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_then_printed, data_set); data_set 358 lib/pacemaker/pcmk_sched_bundle.c pe_order_implies_first_printed, data_set); data_set 400 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 413 lib/pacemaker/pcmk_sched_bundle.c scratch = sort_nodes_by_weight(scratch, NULL, data_set); data_set 433 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 486 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 503 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 508 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 532 lib/pacemaker/pcmk_sched_bundle.c constraint, data_set); data_set 652 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 671 lib/pacemaker/pcmk_sched_bundle.c current, data_set); data_set 774 lib/pacemaker/pcmk_sched_bundle.c filter, type, data_set); data_set 826 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 834 lib/pacemaker/pcmk_sched_bundle.c filter, type, data_set); data_set 842 lib/pacemaker/pcmk_sched_bundle.c type, data_set); data_set 856 lib/pacemaker/pcmk_sched_bundle.c then_child_action, node, flags, filter, type, data_set); data_set 862 lib/pacemaker/pcmk_sched_bundle.c update_action(next->action, data_set); data_set 906 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_expand(pe_resource_t *rsc, pe_working_set_t * data_set) data_set 915 lib/pacemaker/pcmk_sched_bundle.c bundle_data->child->cmds->expand(bundle_data->child, data_set); data_set 924 lib/pacemaker/pcmk_sched_bundle.c && pe__bundle_needs_remote_name(replica->remote, data_set)) { data_set 938 lib/pacemaker/pcmk_sched_bundle.c data_set, data_set 947 lib/pacemaker/pcmk_sched_bundle.c NULL, data_set); data_set 967 lib/pacemaker/pcmk_sched_bundle.c replica->ip->cmds->expand(replica->ip, data_set); data_set 970 lib/pacemaker/pcmk_sched_bundle.c replica->container->cmds->expand(replica->container, data_set); data_set 973 lib/pacemaker/pcmk_sched_bundle.c replica->remote->cmds->expand(replica->remote, data_set); data_set 981 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t * data_set) data_set 997 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 1002 lib/pacemaker/pcmk_sched_bundle.c force, data_set); data_set 1007 lib/pacemaker/pcmk_sched_bundle.c force, data_set); data_set 1038 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 1046 lib/pacemaker/pcmk_sched_bundle.c data_set)) { data_set 1065 lib/pacemaker/pcmk_sched_bundle.c pe_order_probe, data_set); data_set 1078 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_log_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1091 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->ip, data_set); data_set 1094 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->container, data_set); data_set 1097 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->remote, data_set); data_set 1100 lib/pacemaker/pcmk_sched_bundle.c LogActions(replica->child, data_set); data_set 18 lib/pacemaker/pcmk_sched_clone.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 96 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 208 lib/pacemaker/pcmk_sched_clone.c list1 = sort_nodes_by_weight(list1, current_node1, data_set); data_set 209 lib/pacemaker/pcmk_sched_clone.c list2 = sort_nodes_by_weight(list2, current_node2, data_set); data_set 251 lib/pacemaker/pcmk_sched_clone.c sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 406 lib/pacemaker/pcmk_sched_clone.c rc = order_instance_by_colocation(resource1, resource2, data_set); data_set 472 lib/pacemaker/pcmk_sched_clone.c int limit, pe_working_set_t *data_set) data_set 509 lib/pacemaker/pcmk_sched_clone.c chosen = rsc->cmds->allocate(rsc, prefer, data_set); data_set 570 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set); data_set 574 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set) data_set 638 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 663 lib/pacemaker/pcmk_sched_clone.c resource_location(child, NULL, -INFINITY, "clone:limit_reached", data_set); data_set 666 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 679 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 708 lib/pacemaker/pcmk_sched_clone.c constraint->rsc_rh->cmds->allocate(constraint->rsc_rh, prefer, data_set); data_set 724 lib/pacemaker/pcmk_sched_clone.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 725 lib/pacemaker/pcmk_sched_clone.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 728 lib/pacemaker/pcmk_sched_clone.c nodes = sort_nodes_by_weight(nodes, NULL, data_set); data_set 729 lib/pacemaker/pcmk_sched_clone.c rsc->children = g_list_sort_with_data(rsc->children, sort_clone_instance, data_set); data_set 730 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 734 lib/pacemaker/pcmk_sched_clone.c pcmk__set_instance_roles(rsc, data_set); data_set 856 lib/pacemaker/pcmk_sched_clone.c child_ordering_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 898 lib/pacemaker/pcmk_sched_clone.c clone_create_actions(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 903 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 904 lib/pacemaker/pcmk_sched_clone.c child_ordering_constraints(rsc, data_set); data_set 906 lib/pacemaker/pcmk_sched_clone.c create_promotable_actions(rsc, data_set); data_set 912 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 932 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 943 lib/pacemaker/pcmk_sched_clone.c start = create_pseudo_resource_op(rsc, RSC_START, !child_starting, TRUE, data_set); data_set 944 lib/pacemaker/pcmk_sched_clone.c started = create_pseudo_resource_op(rsc, RSC_STARTED, !child_starting, FALSE, data_set); data_set 952 lib/pacemaker/pcmk_sched_clone.c *start_notify = create_notification_boundaries(rsc, RSC_START, start, started, data_set); data_set 956 lib/pacemaker/pcmk_sched_clone.c stop = create_pseudo_resource_op(rsc, RSC_STOP, !child_stopping, TRUE, data_set); data_set 957 lib/pacemaker/pcmk_sched_clone.c stopped = create_pseudo_resource_op(rsc, RSC_STOPPED, !child_stopping, TRUE, data_set); data_set 964 lib/pacemaker/pcmk_sched_clone.c *stop_notify = create_notification_boundaries(rsc, RSC_STOP, stop, stopped, data_set); data_set 973 lib/pacemaker/pcmk_sched_clone.c clone_internal_constraints(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 982 lib/pacemaker/pcmk_sched_clone.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 983 lib/pacemaker/pcmk_sched_clone.c new_rsc_order(rsc, RSC_START, rsc, RSC_STARTED, pe_order_runnable_left, data_set); data_set 984 lib/pacemaker/pcmk_sched_clone.c new_rsc_order(rsc, RSC_STOP, rsc, RSC_STOPPED, pe_order_runnable_left, data_set); data_set 987 lib/pacemaker/pcmk_sched_clone.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_STOP, pe_order_optional, data_set); data_set 988 lib/pacemaker/pcmk_sched_clone.c new_rsc_order(rsc, RSC_STARTED, rsc, RSC_PROMOTE, pe_order_runnable_left, data_set); data_set 998 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 1002 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1009 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1017 lib/pacemaker/pcmk_sched_clone.c promotable_constraints(rsc, data_set); data_set 1078 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1091 lib/pacemaker/pcmk_sched_clone.c scratch = sort_nodes_by_weight(scratch, NULL, data_set); data_set 1112 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1124 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1145 lib/pacemaker/pcmk_sched_clone.c promotable_colocation_rh(rsc_lh, rsc_rh, constraint, data_set); data_set 1172 lib/pacemaker/pcmk_sched_clone.c FALSE, data_set); data_set 1177 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1213 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1328 lib/pacemaker/pcmk_sched_clone.c clone_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1344 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->start_notify, data_set); data_set 1345 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->start_notify, data_set); data_set 1350 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->stop_notify, data_set); data_set 1351 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->stop_notify, data_set); data_set 1356 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->promote_notify, data_set); data_set 1357 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->promote_notify, data_set); data_set 1362 lib/pacemaker/pcmk_sched_clone.c pcmk__create_notification_keys(rsc, clone_data->demote_notify, data_set); data_set 1363 lib/pacemaker/pcmk_sched_clone.c create_notifications(rsc, clone_data->demote_notify, data_set); data_set 1372 lib/pacemaker/pcmk_sched_clone.c child_rsc->cmds->expand(child_rsc, data_set); data_set 1375 lib/pacemaker/pcmk_sched_clone.c native_expand(rsc, data_set); data_set 1434 lib/pacemaker/pcmk_sched_clone.c gboolean force, pe_working_set_t *data_set) data_set 1444 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 1453 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 1480 lib/pacemaker/pcmk_sched_clone.c return child->cmds->create_probe(child, node, complete, force, data_set); data_set 1485 lib/pacemaker/pcmk_sched_clone.c gboolean force, pe_working_set_t * data_set) data_set 1515 lib/pacemaker/pcmk_sched_clone.c any_created = probe_unique_clone(rsc, node, complete, force, data_set); data_set 1518 lib/pacemaker/pcmk_sched_clone.c data_set); data_set 36 lib/pacemaker/pcmk_sched_constraints.c __rsc = pe_find_constraint_resource(data_set->resources, __name); \ data_set 50 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t *data_set, data_set 52 lib/pacemaker/pcmk_sched_constraints.c static void unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 53 lib/pacemaker/pcmk_sched_constraints.c static void unpack_rsc_colocation(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 56 lib/pacemaker/pcmk_sched_constraints.c evaluate_lifetime(xmlNode *lifetime, pe_working_set_t *data_set) data_set 61 lib/pacemaker/pcmk_sched_constraints.c result = pe_evaluate_rules(lifetime, NULL, data_set->now, next_change); data_set 65 lib/pacemaker/pcmk_sched_constraints.c pe__update_recheck_time(recheck, data_set); data_set 72 lib/pacemaker/pcmk_sched_constraints.c unpack_constraints(xmlNode * xml_constraints, pe_working_set_t * data_set) data_set 98 lib/pacemaker/pcmk_sched_constraints.c if (lifetime && !evaluate_lifetime(lifetime, data_set)) { data_set 102 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_order(xml_obj, data_set); data_set 105 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_colocation(xml_obj, data_set); data_set 108 lib/pacemaker/pcmk_sched_constraints.c unpack_location(xml_obj, data_set); data_set 111 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_ticket(xml_obj, data_set); data_set 216 lib/pacemaker/pcmk_sched_constraints.c pe_find_constraint_tag(pe_working_set_t * data_set, const char * id, pe_tag_t ** tag) data_set 221 lib/pacemaker/pcmk_sched_constraints.c rc = g_hash_table_lookup_extended(data_set->template_rsc_sets, id, data_set 225 lib/pacemaker/pcmk_sched_constraints.c rc = g_hash_table_lookup_extended(data_set->tags, id, data_set 246 lib/pacemaker/pcmk_sched_constraints.c valid_resource_or_tag(pe_working_set_t * data_set, const char * id, data_set 253 lib/pacemaker/pcmk_sched_constraints.c *rsc = pe_find_constraint_resource(data_set->resources, id); data_set 261 lib/pacemaker/pcmk_sched_constraints.c rc = pe_find_constraint_tag(data_set, id, tag); data_set 308 lib/pacemaker/pcmk_sched_constraints.c unpack_simple_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 365 lib/pacemaker/pcmk_sched_constraints.c rsc_then = pe_find_constraint_resource(data_set->resources, id_then); data_set 366 lib/pacemaker/pcmk_sched_constraints.c rsc_first = pe_find_constraint_resource(data_set->resources, id_first); data_set 392 lib/pacemaker/pcmk_sched_constraints.c rsc_then = find_clone_instance(rsc_then, instance_then, data_set); data_set 402 lib/pacemaker/pcmk_sched_constraints.c rsc_first = find_clone_instance(rsc_first, instance_first, data_set); data_set 457 lib/pacemaker/pcmk_sched_constraints.c pe_action_t *unordered_action = get_pseudo_op(task, data_set); data_set 472 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 480 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 482 lib/pacemaker/pcmk_sched_constraints.c order_id = new_rsc_order(rsc_first, action_first, rsc_then, action_then, cons_weight, data_set); data_set 509 lib/pacemaker/pcmk_sched_constraints.c order_id = new_rsc_order(rsc_then, action_then, rsc_first, action_first, cons_weight, data_set); data_set 518 lib/pacemaker/pcmk_sched_constraints.c expand_tags_in_sets(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 554 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id, &rsc, &tag) == FALSE) { data_set 642 lib/pacemaker/pcmk_sched_constraints.c gboolean convert_rsc, pe_working_set_t * data_set) data_set 666 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id, &rsc, &tag) == FALSE) { data_set 716 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t *data_set, data_set 720 lib/pacemaker/pcmk_sched_constraints.c unpack_simple_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 726 lib/pacemaker/pcmk_sched_constraints.c pe_resource_t *rsc_lh = pe_find_constraint_resource(data_set->resources, value); data_set 728 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(xml_obj, rsc_lh, NULL, NULL, data_set, NULL); data_set 751 lib/pacemaker/pcmk_sched_constraints.c for (rIter = data_set->resources; rIter; rIter = rIter->next) { data_set 774 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, &re_match_data); data_set 778 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, NULL); data_set 794 lib/pacemaker/pcmk_sched_constraints.c const char *score, pe_working_set_t *data_set, data_set 815 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *match = pe_find_node(data_set->nodes, node); data_set 820 lib/pacemaker/pcmk_sched_constraints.c location = rsc2node_new(id, rsc_lh, score_i, discovery, match, data_set); data_set 835 lib/pacemaker/pcmk_sched_constraints.c data_set, re_match_data); data_set 849 lib/pacemaker/pcmk_sched_constraints.c pe__update_recheck_time(t, data_set); data_set 882 lib/pacemaker/pcmk_sched_constraints.c unpack_location_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 907 lib/pacemaker/pcmk_sched_constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 920 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 935 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_LOC_ATTR_SOURCE, FALSE, data_set) == FALSE) { data_set 959 lib/pacemaker/pcmk_sched_constraints.c unpack_location_set(xmlNode * location, xmlNode * set, pe_working_set_t * data_set) data_set 985 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(location, resource, role, local_score, data_set, NULL); data_set 993 lib/pacemaker/pcmk_sched_constraints.c unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 1001 lib/pacemaker/pcmk_sched_constraints.c if (unpack_location_tags(xml_obj, &expanded_xml, data_set) == FALSE) { data_set 1015 lib/pacemaker/pcmk_sched_constraints.c set = expand_idref(set, data_set->input); data_set 1016 lib/pacemaker/pcmk_sched_constraints.c if (unpack_location_set(xml_obj, set, data_set) == FALSE) { data_set 1031 lib/pacemaker/pcmk_sched_constraints.c unpack_simple_location(xml_obj, data_set); data_set 1066 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t *data_set, data_set 1084 lib/pacemaker/pcmk_sched_constraints.c rule_xml = expand_idref(rule_xml, data_set->input); data_set 1107 lib/pacemaker/pcmk_sched_constraints.c location_rule = rsc2node_new(rule_id, rsc, 0, discovery, NULL, data_set); data_set 1138 lib/pacemaker/pcmk_sched_constraints.c match_L = pcmk__copy_node_list(data_set->nodes, true); data_set 1146 lib/pacemaker/pcmk_sched_constraints.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1151 lib/pacemaker/pcmk_sched_constraints.c .params = pe_rsc_params(rsc, node, data_set), data_set 1156 lib/pacemaker/pcmk_sched_constraints.c data_set->now, next_change, &match_data); data_set 1307 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t * data_set) data_set 1341 lib/pacemaker/pcmk_sched_constraints.c pe_order_anti_colocation, data_set); data_set 1350 lib/pacemaker/pcmk_sched_constraints.c bool influence, pe_working_set_t *data_set) data_set 1397 lib/pacemaker/pcmk_sched_constraints.c data_set->colocation_constraints = g_list_append(data_set->colocation_constraints, new_con); data_set 1400 lib/pacemaker/pcmk_sched_constraints.c anti_colocation_order(rsc_lh, new_con->role_lh, rsc_rh, new_con->role_rh, data_set); data_set 1401 lib/pacemaker/pcmk_sched_constraints.c anti_colocation_order(rsc_rh, new_con->role_rh, rsc_lh, new_con->role_lh, data_set); data_set 1409 lib/pacemaker/pcmk_sched_constraints.c enum pe_ordering type, pe_working_set_t * data_set) data_set 1431 lib/pacemaker/pcmk_sched_constraints.c return custom_action_order(lh_rsc, lh_key, NULL, rh_rsc, rh_key, NULL, type, data_set); data_set 1452 lib/pacemaker/pcmk_sched_constraints.c handle_migration_ordering(pe__ordering_t *order, pe_working_set_t *data_set) data_set 1500 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1514 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1531 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1540 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1553 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1564 lib/pacemaker/pcmk_sched_constraints.c flags, data_set); data_set 1573 lib/pacemaker/pcmk_sched_constraints.c NULL, flags, data_set); data_set 1587 lib/pacemaker/pcmk_sched_constraints.c enum pe_ordering type, pe_working_set_t * data_set) data_set 1608 lib/pacemaker/pcmk_sched_constraints.c crm_trace("Creating[%d] %s %s %s - %s %s %s", data_set->order_id, data_set 1614 lib/pacemaker/pcmk_sched_constraints.c order->id = data_set->order_id++; data_set 1639 lib/pacemaker/pcmk_sched_constraints.c data_set->ordering_constraints = g_list_prepend(data_set->ordering_constraints, order); data_set 1640 lib/pacemaker/pcmk_sched_constraints.c handle_migration_ordering(order, data_set); data_set 1687 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t * data_set) data_set 1793 lib/pacemaker/pcmk_sched_constraints.c flags, data_set); data_set 1798 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(last, action, resource, action, flags, data_set); data_set 1844 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(resource, action, last, action, flags, data_set); data_set 1857 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t * data_set, gboolean invert, gboolean symmetrical) data_set 1907 lib/pacemaker/pcmk_sched_constraints.c pe_action_t *unordered_action = get_pseudo_op(task, data_set); data_set 1926 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 1941 lib/pacemaker/pcmk_sched_constraints.c NULL, flags|pe_order_runnable_left, data_set); data_set 2002 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 2010 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 2022 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 2041 lib/pacemaker/pcmk_sched_constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 2052 lib/pacemaker/pcmk_sched_constraints.c unpack_order_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 2082 lib/pacemaker/pcmk_sched_constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 2096 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_first, &rsc_first, &tag_first) == FALSE) { data_set 2102 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_then, &rsc_then, &tag_then) == FALSE) { data_set 2119 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_first, XML_ORDER_ATTR_FIRST, TRUE, data_set) == FALSE) { data_set 2135 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_then, XML_ORDER_ATTR_THEN, TRUE, data_set) == FALSE) { data_set 2161 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2197 lib/pacemaker/pcmk_sched_constraints.c rc = unpack_order_tags(xml_obj, &expanded_xml, data_set); data_set 2211 lib/pacemaker/pcmk_sched_constraints.c set = expand_idref(set, data_set->input); data_set 2213 lib/pacemaker/pcmk_sched_constraints.c &set_inv_begin, &set_inv_end, invert, data_set) == FALSE) { data_set 2254 lib/pacemaker/pcmk_sched_constraints.c if (order_rsc_sets(id, last, set, kind, data_set, FALSE, invert_bool) == FALSE) { data_set 2259 lib/pacemaker/pcmk_sched_constraints.c && order_rsc_sets(id, set, last, kind, data_set, TRUE, invert_bool) == FALSE) { data_set 2281 lib/pacemaker/pcmk_sched_constraints.c return unpack_simple_rsc_order(xml_obj, data_set); data_set 2318 lib/pacemaker/pcmk_sched_constraints.c const char *influence_s, pe_working_set_t *data_set) data_set 2360 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 2379 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 2415 lib/pacemaker/pcmk_sched_constraints.c influence, data_set); data_set 2427 lib/pacemaker/pcmk_sched_constraints.c const char *influence_s, pe_working_set_t *data_set) data_set 2473 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 2484 lib/pacemaker/pcmk_sched_constraints.c role_2, influence, data_set); data_set 2497 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 2520 lib/pacemaker/pcmk_sched_constraints.c data_set); data_set 2532 lib/pacemaker/pcmk_sched_constraints.c const char *influence_s, pe_working_set_t *data_set) data_set 2548 lib/pacemaker/pcmk_sched_constraints.c pe_resource_t *rsc_lh = pe_find_constraint_resource(data_set->resources, id_lh); data_set 2549 lib/pacemaker/pcmk_sched_constraints.c pe_resource_t *rsc_rh = pe_find_constraint_resource(data_set->resources, id_rh); data_set 2575 lib/pacemaker/pcmk_sched_constraints.c rsc_lh = find_clone_instance(rsc_lh, instance_lh, data_set); data_set 2585 lib/pacemaker/pcmk_sched_constraints.c rsc_rh = find_clone_instance(rsc_rh, instance_rh, data_set); data_set 2605 lib/pacemaker/pcmk_sched_constraints.c unpack_influence(id, rsc_lh, influence_s), data_set); data_set 2609 lib/pacemaker/pcmk_sched_constraints.c unpack_colocation_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 2640 lib/pacemaker/pcmk_sched_constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 2654 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 2660 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_rh, &rsc_rh, &tag_rh) == FALSE) { data_set 2684 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_COLOC_ATTR_SOURCE, TRUE, data_set) == FALSE) { data_set 2700 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_rh, XML_COLOC_ATTR_TARGET, TRUE, data_set) == FALSE) { data_set 2726 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_colocation(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 2745 lib/pacemaker/pcmk_sched_constraints.c if (!unpack_colocation_tags(xml_obj, &expanded_xml, data_set)) { data_set 2758 lib/pacemaker/pcmk_sched_constraints.c set = expand_idref(set, data_set->input); data_set 2760 lib/pacemaker/pcmk_sched_constraints.c data_set)) { data_set 2764 lib/pacemaker/pcmk_sched_constraints.c influence_s, data_set)) { data_set 2777 lib/pacemaker/pcmk_sched_constraints.c unpack_simple_colocation(xml_obj, id, influence_s, data_set); data_set 2783 lib/pacemaker/pcmk_sched_constraints.c const char *state_lh, const char *loss_policy, pe_working_set_t * data_set) data_set 2808 lib/pacemaker/pcmk_sched_constraints.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2861 lib/pacemaker/pcmk_sched_constraints.c data_set->ticket_constraints = g_list_append(data_set->ticket_constraints, new_rsc_ticket); data_set 2864 lib/pacemaker/pcmk_sched_constraints.c rsc_ticket_constraint(rsc_lh, new_rsc_ticket, data_set); data_set 2872 lib/pacemaker/pcmk_sched_constraints.c pe_working_set_t * data_set) data_set 2897 lib/pacemaker/pcmk_sched_constraints.c rsc_ticket_new(set_id, resource, ticket, role, loss_policy, data_set); data_set 2904 lib/pacemaker/pcmk_sched_constraints.c unpack_simple_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2934 lib/pacemaker/pcmk_sched_constraints.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 2947 lib/pacemaker/pcmk_sched_constraints.c rsc_lh = pe_find_constraint_resource(data_set->resources, id_lh); data_set 2963 lib/pacemaker/pcmk_sched_constraints.c rsc_lh = find_clone_instance(rsc_lh, instance_lh, data_set); data_set 2972 lib/pacemaker/pcmk_sched_constraints.c rsc_ticket_new(id, rsc_lh, ticket, state_lh, loss_policy, data_set); data_set 2977 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_ticket_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 3002 lib/pacemaker/pcmk_sched_constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 3015 lib/pacemaker/pcmk_sched_constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 3030 lib/pacemaker/pcmk_sched_constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_COLOC_ATTR_SOURCE, FALSE, data_set) == FALSE) { data_set 3056 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 3081 lib/pacemaker/pcmk_sched_constraints.c if (data_set->tickets == NULL) { data_set 3082 lib/pacemaker/pcmk_sched_constraints.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 3089 lib/pacemaker/pcmk_sched_constraints.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 3093 lib/pacemaker/pcmk_sched_constraints.c ticket = ticket_new(ticket_str, data_set); data_set 3099 lib/pacemaker/pcmk_sched_constraints.c rc = unpack_rsc_ticket_tags(xml_obj, &expanded_xml, data_set); data_set 3113 lib/pacemaker/pcmk_sched_constraints.c set = expand_idref(set, data_set->input); data_set 3114 lib/pacemaker/pcmk_sched_constraints.c if (unpack_rsc_ticket_set(set, ticket, loss_policy, data_set) == FALSE) { data_set 3126 lib/pacemaker/pcmk_sched_constraints.c return unpack_simple_rsc_ticket(xml_obj, data_set); data_set 22 lib/pacemaker/pcmk_sched_graph.c void update_colo_start_chain(pe_action_t *action, pe_working_set_t *data_set); data_set 178 lib/pacemaker/pcmk_sched_graph.c pe_action_wrapper_t *order, pe_working_set_t *data_set) data_set 212 lib/pacemaker/pcmk_sched_graph.c pe_order_implies_then, data_set); data_set 232 lib/pacemaker/pcmk_sched_graph.c pe_order_restart, data_set); data_set 245 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 271 lib/pacemaker/pcmk_sched_graph.c pe_order_promoted_implies_first, data_set); data_set 289 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 328 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 343 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 363 lib/pacemaker/pcmk_sched_graph.c pe_order_implies_first_migratable, data_set); data_set 377 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 390 lib/pacemaker/pcmk_sched_graph.c first_flags, pe_action_runnable, pe_order_optional, data_set); data_set 404 lib/pacemaker/pcmk_sched_graph.c data_set); data_set 462 lib/pacemaker/pcmk_sched_graph.c pe_working_set_t *data_set) data_set 476 lib/pacemaker/pcmk_sched_graph.c update_colo_start_chain(action, data_set); data_set 477 lib/pacemaker/pcmk_sched_graph.c update_action(action, data_set); data_set 484 lib/pacemaker/pcmk_sched_graph.c update_colo_start_chain(pe_action_t *action, pe_working_set_t *data_set) data_set 521 lib/pacemaker/pcmk_sched_graph.c mark_start_blocked(colocate_with->rsc_lh, action->rsc, data_set); data_set 527 lib/pacemaker/pcmk_sched_graph.c update_action(pe_action_t *then, pe_working_set_t *data_set) data_set 653 lib/pacemaker/pcmk_sched_graph.c then_flags, other, data_set); data_set 685 lib/pacemaker/pcmk_sched_graph.c update_action(other->action, data_set); data_set 687 lib/pacemaker/pcmk_sched_graph.c update_action(first, data_set); data_set 709 lib/pacemaker/pcmk_sched_graph.c update_colo_start_chain(then, data_set); data_set 711 lib/pacemaker/pcmk_sched_graph.c update_action(then, data_set); data_set 715 lib/pacemaker/pcmk_sched_graph.c update_action(other->action, data_set); data_set 723 lib/pacemaker/pcmk_sched_graph.c shutdown_constraints(pe_node_t * node, pe_action_t * shutdown_op, pe_working_set_t * data_set) data_set 730 lib/pacemaker/pcmk_sched_graph.c for (lpc = data_set->actions; lpc != NULL; lpc = lpc->next) { data_set 760 lib/pacemaker/pcmk_sched_graph.c pe_order_optional | pe_order_runnable_left, data_set); data_set 778 lib/pacemaker/pcmk_sched_graph.c pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set) data_set 780 lib/pacemaker/pcmk_sched_graph.c CRM_CHECK(stonith_op && data_set, return); data_set 781 lib/pacemaker/pcmk_sched_graph.c for (GList *r = data_set->resources; r != NULL; r = r->next) { data_set 782 lib/pacemaker/pcmk_sched_graph.c rsc_stonith_ordering((pe_resource_t *) r->data, stonith_op, data_set); data_set 920 lib/pacemaker/pcmk_sched_graph.c add_maintenance_nodes(xmlNode *xml, const pe_working_set_t *data_set) data_set 927 lib/pacemaker/pcmk_sched_graph.c for (gIter = data_set->nodes; gIter != NULL; data_set 957 lib/pacemaker/pcmk_sched_graph.c add_maintenance_update(pe_working_set_t *data_set) data_set 961 lib/pacemaker/pcmk_sched_graph.c if (add_maintenance_nodes(NULL, data_set)) { data_set 963 lib/pacemaker/pcmk_sched_graph.c action = get_pseudo_op(CRM_OP_MAINTENANCE_NODES, data_set); data_set 982 lib/pacemaker/pcmk_sched_graph.c const pe_working_set_t *data_set) data_set 984 lib/pacemaker/pcmk_sched_graph.c CRM_CHECK(xml && action && action->node && data_set, return); data_set 1000 lib/pacemaker/pcmk_sched_graph.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); data_set 1049 lib/pacemaker/pcmk_sched_graph.c action2xml(pe_action_t * action, gboolean as_input, pe_working_set_t *data_set) data_set 1242 lib/pacemaker/pcmk_sched_graph.c GHashTable *params = pe_rsc_params(action->rsc, action->node, data_set); data_set 1253 lib/pacemaker/pcmk_sched_graph.c GHashTable *base = pe_rsc_params(action->rsc, NULL, data_set); data_set 1270 lib/pacemaker/pcmk_sched_graph.c action->node, data_set); data_set 1279 lib/pacemaker/pcmk_sched_graph.c GHashTable *params = pe_rsc_params(action->rsc, NULL, data_set); data_set 1369 lib/pacemaker/pcmk_sched_graph.c add_downed_nodes(action_xml, action, data_set); data_set 1373 lib/pacemaker/pcmk_sched_graph.c add_maintenance_nodes(action_xml, data_set); data_set 1853 lib/pacemaker/pcmk_sched_graph.c graph_element_from_action(pe_action_t *action, pe_working_set_t *data_set) data_set 1877 lib/pacemaker/pcmk_sched_graph.c syn = create_xml_node(data_set->graph, "synapse"); data_set 1881 lib/pacemaker/pcmk_sched_graph.c crm_xml_add_int(syn, XML_ATTR_ID, data_set->num_synapse); data_set 1882 lib/pacemaker/pcmk_sched_graph.c data_set->num_synapse++; data_set 1894 lib/pacemaker/pcmk_sched_graph.c xml_action = action2xml(action, FALSE, data_set); data_set 1903 lib/pacemaker/pcmk_sched_graph.c xml_action = action2xml(input->action, TRUE, data_set); data_set 83 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 111 lib/pacemaker/pcmk_sched_group.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 112 lib/pacemaker/pcmk_sched_group.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 120 lib/pacemaker/pcmk_sched_group.c node = child_rsc->cmds->allocate(child_rsc, prefer, data_set); data_set 139 lib/pacemaker/pcmk_sched_group.c group_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 150 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 158 lib/pacemaker/pcmk_sched_group.c RSC_STARTED, NULL, TRUE /* !group_data->child_starting */ , TRUE, data_set); data_set 165 lib/pacemaker/pcmk_sched_group.c RSC_STOPPED, NULL, TRUE /* !group_data->child_stopping */ , TRUE, data_set); data_set 170 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, demote_key(rsc), RSC_DEMOTE, NULL, TRUE, TRUE, data_set); data_set 173 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, demoted_key(rsc), RSC_DEMOTED, NULL, TRUE, TRUE, data_set); data_set 176 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, promote_key(rsc), RSC_PROMOTE, NULL, TRUE, TRUE, data_set); data_set 179 lib/pacemaker/pcmk_sched_group.c op = custom_action(rsc, promoted_key(rsc), RSC_PROMOTED, NULL, TRUE, TRUE, data_set); data_set 222 lib/pacemaker/pcmk_sched_group.c group_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 232 lib/pacemaker/pcmk_sched_group.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 233 lib/pacemaker/pcmk_sched_group.c new_rsc_order(rsc, RSC_START, rsc, RSC_STARTED, pe_order_runnable_left, data_set); data_set 234 lib/pacemaker/pcmk_sched_group.c new_rsc_order(rsc, RSC_STOP, rsc, RSC_STOPPED, pe_order_runnable_left, data_set); data_set 244 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 256 lib/pacemaker/pcmk_sched_group.c data_set); data_set 261 lib/pacemaker/pcmk_sched_group.c stop | pe_order_implies_first_printed, data_set); data_set 263 lib/pacemaker/pcmk_sched_group.c new_rsc_order(child_rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, stopped, data_set); data_set 265 lib/pacemaker/pcmk_sched_group.c new_rsc_order(child_rsc, RSC_PROMOTE, rsc, RSC_PROMOTED, started, data_set); data_set 268 lib/pacemaker/pcmk_sched_group.c pe_order_implies_first_printed, data_set); data_set 275 lib/pacemaker/pcmk_sched_group.c new_rsc_order(child_rsc, RSC_STOP, rsc, RSC_STOPPED, stopped, data_set); data_set 277 lib/pacemaker/pcmk_sched_group.c new_rsc_order(child_rsc, RSC_START, rsc, RSC_STARTED, started, data_set); data_set 283 lib/pacemaker/pcmk_sched_group.c start | pe_order_implies_first_printed, data_set); data_set 291 lib/pacemaker/pcmk_sched_group.c new_rsc_order(last_rsc, RSC_PROMOTE, child_rsc, RSC_PROMOTE, start, data_set); data_set 293 lib/pacemaker/pcmk_sched_group.c data_set); data_set 300 lib/pacemaker/pcmk_sched_group.c pe_order_none, data_set); data_set 324 lib/pacemaker/pcmk_sched_group.c new_rsc_order(last_rsc, RSC_STOP, rsc, RSC_STOPPED, stop_stopped_flags, data_set); data_set 327 lib/pacemaker/pcmk_sched_group.c new_rsc_order(rsc, RSC_DEMOTE, last_rsc, RSC_DEMOTE, stop_stop_flags, data_set); data_set 328 lib/pacemaker/pcmk_sched_group.c new_rsc_order(last_rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, stop_stopped_flags, data_set); data_set 336 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 358 lib/pacemaker/pcmk_sched_group.c data_set); data_set 372 lib/pacemaker/pcmk_sched_group.c data_set); data_set 379 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 399 lib/pacemaker/pcmk_sched_group.c data_set); data_set 405 lib/pacemaker/pcmk_sched_group.c data_set); data_set 420 lib/pacemaker/pcmk_sched_group.c data_set); data_set 472 lib/pacemaker/pcmk_sched_group.c enum pe_ordering type, pe_working_set_t *data_set) data_set 479 lib/pacemaker/pcmk_sched_group.c data_set); data_set 488 lib/pacemaker/pcmk_sched_group.c data_set); data_set 525 lib/pacemaker/pcmk_sched_group.c group_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 530 lib/pacemaker/pcmk_sched_group.c native_expand(rsc, data_set); data_set 535 lib/pacemaker/pcmk_sched_group.c child_rsc->cmds->expand(child_rsc, data_set); data_set 28 lib/pacemaker/pcmk_sched_messages.c log_resource_details(pe_working_set_t *data_set) data_set 30 lib/pacemaker/pcmk_sched_messages.c pcmk__output_t *out = data_set->priv; data_set 40 lib/pacemaker/pcmk_sched_messages.c for (GList *item = data_set->resources; item != NULL; item = item->next) { data_set 62 lib/pacemaker/pcmk_sched_messages.c pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input, data_set 67 lib/pacemaker/pcmk_sched_messages.c CRM_ASSERT(xml_input || pcmk_is_set(data_set->flags, pe_flag_have_status)); data_set 69 lib/pacemaker/pcmk_sched_messages.c if (!pcmk_is_set(data_set->flags, pe_flag_have_status)) { data_set 70 lib/pacemaker/pcmk_sched_messages.c set_working_set_defaults(data_set); data_set 71 lib/pacemaker/pcmk_sched_messages.c data_set->input = xml_input; data_set 72 lib/pacemaker/pcmk_sched_messages.c data_set->now = now; data_set 78 lib/pacemaker/pcmk_sched_messages.c if (data_set->now == NULL) { data_set 79 lib/pacemaker/pcmk_sched_messages.c data_set->now = crm_time_new(NULL); data_set 83 lib/pacemaker/pcmk_sched_messages.c stage0(data_set); data_set 84 lib/pacemaker/pcmk_sched_messages.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location) && data_set 86 lib/pacemaker/pcmk_sched_messages.c log_resource_details(data_set); data_set 90 lib/pacemaker/pcmk_sched_messages.c stage2(data_set); data_set 92 lib/pacemaker/pcmk_sched_messages.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 97 lib/pacemaker/pcmk_sched_messages.c stage3(data_set); data_set 100 lib/pacemaker/pcmk_sched_messages.c stage4(data_set); data_set 103 lib/pacemaker/pcmk_sched_messages.c stage5(data_set); data_set 106 lib/pacemaker/pcmk_sched_messages.c stage6(data_set); data_set 109 lib/pacemaker/pcmk_sched_messages.c stage7(data_set); data_set 112 lib/pacemaker/pcmk_sched_messages.c stage8(data_set); data_set 117 lib/pacemaker/pcmk_sched_messages.c gIter = data_set->actions; data_set 130 lib/pacemaker/pcmk_sched_messages.c return data_set->graph; data_set 31 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 33 lib/pacemaker/pcmk_sched_native.c xmlNode *operation, pe_working_set_t *data_set); data_set 35 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 37 lib/pacemaker/pcmk_sched_native.c xmlNode *operation, pe_working_set_t *data_set); data_set 39 lib/pacemaker/pcmk_sched_native.c void ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set); data_set 40 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 41 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 42 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 43 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 45 lib/pacemaker/pcmk_sched_native.c pe_working_set_t * data_set); data_set 46 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 47 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 67 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set); data_set 87 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 96 lib/pacemaker/pcmk_sched_native.c process_utilization(rsc, &prefer, data_set); data_set 108 lib/pacemaker/pcmk_sched_native.c nodes = sort_nodes_by_weight(nodes, pe__current_node(rsc), data_set); data_set 499 lib/pacemaker/pcmk_sched_native.c is_unfence_device(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 502 lib/pacemaker/pcmk_sched_native.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing); data_set 507 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 515 lib/pacemaker/pcmk_sched_native.c rsc->parent->cmds->allocate(rsc->parent, prefer, data_set); data_set 528 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(true, rsc, "Pre-alloc", rsc->allowed_nodes, data_set); data_set 545 lib/pacemaker/pcmk_sched_native.c rsc_rh->cmds->allocate(rsc_rh, NULL, data_set); data_set 546 lib/pacemaker/pcmk_sched_native.c rsc->cmds->rsc_colocation_lh(rsc, rsc_rh, constraint, data_set); data_set 558 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(true, rsc, "Post-coloc", rsc->allowed_nodes, data_set); data_set 579 lib/pacemaker/pcmk_sched_native.c resource_location(rsc, NULL, -INFINITY, XML_RSC_ATTR_TARGET_ROLE, data_set); data_set 582 lib/pacemaker/pcmk_sched_native.c && !pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 583 lib/pacemaker/pcmk_sched_native.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 589 lib/pacemaker/pcmk_sched_native.c pe__show_node_weights(!pcmk_is_set(data_set->flags, pe_flag_show_scores), data_set 590 lib/pacemaker/pcmk_sched_native.c rsc, __func__, rsc->allowed_nodes, data_set); data_set 591 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 592 lib/pacemaker/pcmk_sched_native.c && !pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 615 lib/pacemaker/pcmk_sched_native.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 620 lib/pacemaker/pcmk_sched_native.c && native_choose_node(rsc, prefer, data_set)) { data_set 639 lib/pacemaker/pcmk_sched_native.c pe_node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 711 lib/pacemaker/pcmk_sched_native.c xmlNode * operation, pe_working_set_t * data_set) data_set 804 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); data_set 826 lib/pacemaker/pcmk_sched_native.c pe_order_runnable_left, data_set); data_set 838 lib/pacemaker/pcmk_sched_native.c mon = custom_action(rsc, key, name, node, is_optional, TRUE, data_set); data_set 869 lib/pacemaker/pcmk_sched_native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 873 lib/pacemaker/pcmk_sched_native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 878 lib/pacemaker/pcmk_sched_native.c pe_order_optional | pe_order_runnable_left, data_set); data_set 883 lib/pacemaker/pcmk_sched_native.c pe_order_optional | pe_order_runnable_left, data_set); data_set 889 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 900 lib/pacemaker/pcmk_sched_native.c RecurringOp(rsc, start, node, operation, data_set); data_set 908 lib/pacemaker/pcmk_sched_native.c xmlNode * operation, pe_working_set_t * data_set) data_set 973 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); data_set 980 lib/pacemaker/pcmk_sched_native.c pe_order_runnable_left, data_set); data_set 988 lib/pacemaker/pcmk_sched_native.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1020 lib/pacemaker/pcmk_sched_native.c stopped_mon = custom_action(rsc, strdup(key), name, stop_node, is_optional, TRUE, data_set); data_set 1063 lib/pacemaker/pcmk_sched_native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 1100 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 1111 lib/pacemaker/pcmk_sched_native.c RecurringOp_Stopped(rsc, start, node, operation, data_set); data_set 1118 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 1133 lib/pacemaker/pcmk_sched_native.c RSC_MIGRATE, current, TRUE, TRUE, data_set); data_set 1137 lib/pacemaker/pcmk_sched_native.c RSC_MIGRATED, chosen, TRUE, TRUE, data_set); data_set 1154 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 1163 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 1168 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1174 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1178 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1207 lib/pacemaker/pcmk_sched_native.c native_create_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1245 lib/pacemaker/pcmk_sched_native.c pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)? "and cleanup " : "", data_set 1249 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 1250 lib/pacemaker/pcmk_sched_native.c DeleteRsc(rsc, dangling_source, FALSE, data_set); data_set 1359 lib/pacemaker/pcmk_sched_native.c if (rsc_action_matrix[role][next_role] (rsc, current, !need_stop, data_set) == FALSE) { data_set 1378 lib/pacemaker/pcmk_sched_native.c data_set) == FALSE) { data_set 1391 lib/pacemaker/pcmk_sched_native.c if (rsc_action_matrix[role][next_role] (rsc, chosen, FALSE, data_set) == FALSE) { data_set 1407 lib/pacemaker/pcmk_sched_native.c Recurring(rsc, start, chosen, data_set); data_set 1408 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(rsc, start, chosen, data_set); data_set 1413 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(rsc, NULL, NULL, data_set); data_set 1434 lib/pacemaker/pcmk_sched_native.c handle_migration_actions(rsc, current, chosen, data_set); data_set 1466 lib/pacemaker/pcmk_sched_native.c allowed_nodes_as_list(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1482 lib/pacemaker/pcmk_sched_native.c native_internal_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1502 lib/pacemaker/pcmk_sched_native.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing) data_set 1507 lib/pacemaker/pcmk_sched_native.c && !pcmk__str_eq(data_set->placement_strategy, data_set 1514 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1522 lib/pacemaker/pcmk_sched_native.c pe_order_promoted_implies_first, data_set); data_set 1526 lib/pacemaker/pcmk_sched_native.c pe_order_runnable_left, data_set); data_set 1533 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1537 lib/pacemaker/pcmk_sched_native.c allowed_nodes = allowed_nodes_as_list(rsc, data_set); data_set 1545 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); data_set 1567 lib/pacemaker/pcmk_sched_native.c pe_order_optional|pe_order_same_node, data_set); data_set 1572 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1580 lib/pacemaker/pcmk_sched_native.c rsc->id, data_set->placement_strategy); data_set 1587 lib/pacemaker/pcmk_sched_native.c pe_action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1595 lib/pacemaker/pcmk_sched_native.c NULL, load_stopped_task, load_stopped, pe_order_load, data_set); data_set 1602 lib/pacemaker/pcmk_sched_native.c pe_action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1610 lib/pacemaker/pcmk_sched_native.c rsc, start_key(rsc), NULL, pe_order_load, data_set); data_set 1614 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_load, data_set); data_set 1641 lib/pacemaker/pcmk_sched_native.c pe_order_optional, data_set); data_set 1653 lib/pacemaker/pcmk_sched_native.c remote_rsc = pe__resource_contains_guest_node(data_set, data_set 1684 lib/pacemaker/pcmk_sched_native.c data_set); data_set 1689 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_implies_first, data_set); data_set 1697 lib/pacemaker/pcmk_sched_native.c rsc->container, NULL, NULL, true, data_set); data_set 1712 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 1726 lib/pacemaker/pcmk_sched_native.c rsc_rh->cmds->rsc_colocation_rh(rsc_lh, rsc_rh, constraint, data_set); data_set 1918 lib/pacemaker/pcmk_sched_native.c pe_working_set_t *data_set) data_set 1955 lib/pacemaker/pcmk_sched_native.c rsc_ticket_constraint(pe_resource_t * rsc_lh, rsc_ticket_t * rsc_ticket, pe_working_set_t * data_set) data_set 1979 lib/pacemaker/pcmk_sched_native.c rsc_ticket_constraint(child_rsc, rsc_ticket, data_set); data_set 1995 lib/pacemaker/pcmk_sched_native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 2001 lib/pacemaker/pcmk_sched_native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 2010 lib/pacemaker/pcmk_sched_native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 2015 lib/pacemaker/pcmk_sched_native.c pe_fence_node(data_set, node, "deadman ticket was lost", FALSE); data_set 2034 lib/pacemaker/pcmk_sched_native.c resource_location(rsc_lh, NULL, -INFINITY, "__no_ticket__", data_set); data_set 2041 lib/pacemaker/pcmk_sched_native.c resource_location(rsc_lh, NULL, -INFINITY, "__ticket_standby__", data_set); data_set 2128 lib/pacemaker/pcmk_sched_native.c enum pe_ordering type, pe_working_set_t *data_set) data_set 2272 lib/pacemaker/pcmk_sched_native.c update_action(then, data_set); data_set 2345 lib/pacemaker/pcmk_sched_native.c native_expand(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 2356 lib/pacemaker/pcmk_sched_native.c graph_element_from_action(action, data_set); data_set 2362 lib/pacemaker/pcmk_sched_native.c child_rsc->cmds->expand(child_rsc, data_set); data_set 2381 lib/pacemaker/pcmk_sched_native.c LogActions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 2383 lib/pacemaker/pcmk_sched_native.c pcmk__output_t *out = data_set->priv; data_set 2391 lib/pacemaker/pcmk_sched_native.c pcmk__bundle_log_actions(rsc, data_set); data_set 2401 lib/pacemaker/pcmk_sched_native.c LogActions(child_rsc, data_set); data_set 2427 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 2460 lib/pacemaker/pcmk_sched_native.c if (pcmk_is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 2461 lib/pacemaker/pcmk_sched_native.c DeleteRsc(rsc, current, optional, data_set); data_set 2465 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(current, "on", TRUE, NULL, FALSE, data_set); data_set 2479 lib/pacemaker/pcmk_sched_native.c enum pe_ordering order, pe_working_set_t *data_set) data_set 2488 lib/pacemaker/pcmk_sched_native.c if (is_unfence_device(rsc, data_set) data_set 2495 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); data_set 2504 lib/pacemaker/pcmk_sched_native.c trigger_unfencing(NULL, node, reason, NULL, data_set); data_set 2511 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 2519 lib/pacemaker/pcmk_sched_native.c order_after_unfencing(rsc, next, start, pe_order_implies_then, data_set); data_set 2530 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 2571 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 2589 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 2598 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 2606 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 2627 lib/pacemaker/pcmk_sched_native.c optional ? pe_order_implies_then : pe_order_optional, data_set); data_set 2630 lib/pacemaker/pcmk_sched_native.c optional ? pe_order_implies_then : pe_order_optional, data_set); data_set 2637 lib/pacemaker/pcmk_sched_native.c gboolean force, pe_working_set_t * data_set) data_set 2655 lib/pacemaker/pcmk_sched_native.c if (!force && !pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 2669 lib/pacemaker/pcmk_sched_native.c && pe__resource_contains_guest_node(data_set, rsc)) { data_set 2689 lib/pacemaker/pcmk_sched_native.c any_created = child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set) data_set 2773 lib/pacemaker/pcmk_sched_native.c pe_order_optional, data_set); data_set 2795 lib/pacemaker/pcmk_sched_native.c NULL, pe_order_optional, data_set); data_set 2806 lib/pacemaker/pcmk_sched_native.c probe = custom_action(rsc, key, RSC_STATUS, node, FALSE, TRUE, data_set); data_set 2809 lib/pacemaker/pcmk_sched_native.c order_after_unfencing(rsc, node, probe, pe_order_optional, data_set); data_set 2826 lib/pacemaker/pcmk_sched_native.c if (is_unfence_device(rsc, data_set) || !pe_rsc_is_clone(top)) { data_set 2842 lib/pacemaker/pcmk_sched_native.c flags, data_set); data_set 2847 lib/pacemaker/pcmk_sched_native.c pe_order_optional, data_set); data_set 2851 lib/pacemaker/pcmk_sched_native.c if (!is_unfence_device(rsc, data_set)) { data_set 2900 lib/pacemaker/pcmk_sched_native.c native_start_constraints(pe_resource_t * rsc, pe_action_t * stonith_op, pe_working_set_t * data_set) data_set 2945 lib/pacemaker/pcmk_sched_native.c native_stop_constraints(pe_resource_t * rsc, pe_action_t * stonith_op, pe_working_set_t * data_set) data_set 3035 lib/pacemaker/pcmk_sched_native.c create_secondary_notification(action, rsc, stonith_op, data_set); data_set 3108 lib/pacemaker/pcmk_sched_native.c rsc_stonith_ordering(pe_resource_t * rsc, pe_action_t * stonith_op, pe_working_set_t * data_set) data_set 3116 lib/pacemaker/pcmk_sched_native.c rsc_stonith_ordering(child_rsc, stonith_op, data_set); data_set 3123 lib/pacemaker/pcmk_sched_native.c native_start_constraints(rsc, stonith_op, data_set); data_set 3124 lib/pacemaker/pcmk_sched_native.c native_stop_constraints(rsc, stonith_op, data_set); data_set 3129 lib/pacemaker/pcmk_sched_native.c ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set) data_set 3138 lib/pacemaker/pcmk_sched_native.c ReloadRsc(child_rsc, node, data_set); data_set 3176 lib/pacemaker/pcmk_sched_native.c FALSE, TRUE, data_set); data_set 3181 lib/pacemaker/pcmk_sched_native.c data_set); data_set 3184 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 18 lib/pacemaker/pcmk_sched_promotable.c extern gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 25 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t * data_set) data_set 31 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(last, RSC_PROMOTE, rsc, RSC_PROMOTED, type, data_set); data_set 37 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(child, RSC_PROMOTE, rsc, RSC_PROMOTED, type, data_set); data_set 40 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_PROMOTE, child, RSC_PROMOTE, type, data_set); data_set 51 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(last, RSC_PROMOTE, child, RSC_PROMOTE, type, data_set); data_set 61 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t * data_set) data_set 67 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTE, last, RSC_DEMOTE, pe_order_optional, data_set); data_set 73 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(child, RSC_DEMOTE, rsc, RSC_DEMOTED, pe_order_implies_then_printed, data_set); data_set 76 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTE, child, RSC_DEMOTE, pe_order_implies_first_printed, data_set); data_set 82 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(child, RSC_DEMOTE, last, RSC_DEMOTE, type, data_set); data_set 87 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(child, RSC_DEMOTE, rsc, RSC_DEMOTED, type, data_set); data_set 246 lib/pacemaker/pcmk_sched_promotable.c sort_promotable_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 276 lib/pacemaker/pcmk_sched_promotable.c return sort_clone_instance(a, b, data_set); data_set 280 lib/pacemaker/pcmk_sched_promotable.c promotion_order(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 303 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Before", rsc->allowed_nodes, data_set); data_set 324 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Middle", rsc->allowed_nodes, data_set); data_set 376 lib/pacemaker/pcmk_sched_promotable.c resource_location(rsc, NULL, -INFINITY, "__stateful_without_ticket__", data_set); data_set 380 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "After", rsc->allowed_nodes, data_set); data_set 406 lib/pacemaker/pcmk_sched_promotable.c sort_promotable_instance, data_set); data_set 659 lib/pacemaker/pcmk_sched_promotable.c pcmk__set_instance_roles(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 740 lib/pacemaker/pcmk_sched_promotable.c data_set); data_set 751 lib/pacemaker/pcmk_sched_promotable.c pe__show_node_weights(true, rsc, "Pre merge", rsc->allowed_nodes, data_set); data_set 752 lib/pacemaker/pcmk_sched_promotable.c promotion_order(rsc, data_set); data_set 760 lib/pacemaker/pcmk_sched_promotable.c if (pcmk_is_set(data_set->flags, pe_flag_show_scores) && !pcmk__is_daemon) { data_set 761 lib/pacemaker/pcmk_sched_promotable.c if (data_set->priv != NULL) { data_set 762 lib/pacemaker/pcmk_sched_promotable.c pcmk__output_t *out = data_set->priv; data_set 790 lib/pacemaker/pcmk_sched_promotable.c && !pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 791 lib/pacemaker/pcmk_sched_promotable.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 812 lib/pacemaker/pcmk_sched_promotable.c create_promotable_actions(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 834 lib/pacemaker/pcmk_sched_promotable.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 844 lib/pacemaker/pcmk_sched_promotable.c action = create_pseudo_resource_op(rsc, RSC_PROMOTE, !any_promoting, TRUE, data_set); data_set 845 lib/pacemaker/pcmk_sched_promotable.c action_complete = create_pseudo_resource_op(rsc, RSC_PROMOTED, !any_promoting, TRUE, data_set); data_set 849 lib/pacemaker/pcmk_sched_promotable.c rsc, NULL, last_promote_rsc, data_set); data_set 853 lib/pacemaker/pcmk_sched_promotable.c create_notification_boundaries(rsc, RSC_PROMOTE, action, action_complete, data_set); data_set 857 lib/pacemaker/pcmk_sched_promotable.c action = create_pseudo_resource_op(rsc, RSC_DEMOTE, !any_demoting, TRUE, data_set); data_set 858 lib/pacemaker/pcmk_sched_promotable.c action_complete = create_pseudo_resource_op(rsc, RSC_DEMOTED, !any_demoting, TRUE, data_set); data_set 861 lib/pacemaker/pcmk_sched_promotable.c child_demoting_constraints(clone_data, pe_order_optional, rsc, NULL, last_demote_rsc, data_set); data_set 865 lib/pacemaker/pcmk_sched_promotable.c create_notification_boundaries(rsc, RSC_DEMOTE, action, action_complete, data_set); data_set 895 lib/pacemaker/pcmk_sched_promotable.c promote_demote_constraints(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 898 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 901 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 904 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_START, pe_order_optional, data_set); data_set 907 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_STARTED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 910 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_STOP, pe_order_optional, data_set); data_set 913 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, pe_order_optional, data_set); data_set 916 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 921 lib/pacemaker/pcmk_sched_promotable.c promotable_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 929 lib/pacemaker/pcmk_sched_promotable.c promote_demote_constraints(rsc, data_set); data_set 935 lib/pacemaker/pcmk_sched_promotable.c new_rsc_order(child_rsc, RSC_DEMOTE, child_rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 938 lib/pacemaker/pcmk_sched_promotable.c rsc, child_rsc, last_rsc, data_set); data_set 941 lib/pacemaker/pcmk_sched_promotable.c rsc, child_rsc, last_rsc, data_set); data_set 976 lib/pacemaker/pcmk_sched_promotable.c pe_working_set_t *data_set) data_set 1016 lib/pacemaker/pcmk_sched_promotable.c FALSE, data_set); data_set 392 lib/pacemaker/pcmk_sched_transition.c modify_configuration(pe_working_set_t * data_set, cib_t *cib, data_set 406 lib/pacemaker/pcmk_sched_transition.c out = data_set->priv; data_set 558 lib/pacemaker/pcmk_sched_transition.c rsc = pe_find_resource(data_set->resources, resource); data_set 798 lib/pacemaker/pcmk_sched_transition.c run_simulation(pe_working_set_t * data_set, cib_t *cib, GList *op_fail_list) data_set 810 lib/pacemaker/pcmk_sched_transition.c out = data_set->priv; data_set 820 lib/pacemaker/pcmk_sched_transition.c transition = unpack_graph(data_set->graph, crm_system_name); data_set 823 lib/pacemaker/pcmk_sched_transition.c fake_resource_list = data_set->resources; data_set 844 lib/pacemaker/pcmk_sched_transition.c pe_reset_working_set(data_set); data_set 845 lib/pacemaker/pcmk_sched_transition.c data_set->input = cib_object; data_set 346 lib/pacemaker/pcmk_sched_utilization.c process_utilization(pe_resource_t * rsc, pe_node_t ** prefer, pe_working_set_t * data_set) data_set 348 lib/pacemaker/pcmk_sched_utilization.c CRM_CHECK(rsc && prefer && data_set, return); data_set 349 lib/pacemaker/pcmk_sched_utilization.c if (!pcmk__str_eq(data_set->placement_strategy, "default", pcmk__str_casei)) { data_set 393 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 421 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 425 lib/pacemaker/pcmk_sched_utilization.c pe__show_node_weights(true, rsc, "Post-utilization", rsc->allowed_nodes, data_set); data_set 19 lib/pacemaker/pcmk_sched_utils.c pe_node_t *foo_node, pe_working_set_t *data_set) data_set 57 lib/pacemaker/pcmk_sched_utils.c data_set->placement_constraints = g_list_prepend(data_set->placement_constraints, new_con); data_set 145 lib/pacemaker/pcmk_sched_utils.c pe_working_set_t *data_set; data_set 196 lib/pacemaker/pcmk_sched_utils.c if (pcmk__str_eq(nw->data_set->placement_strategy, "minimal", pcmk__str_casei)) { data_set 200 lib/pacemaker/pcmk_sched_utils.c if (pcmk__str_eq(nw->data_set->placement_strategy, "balanced", pcmk__str_casei)) { data_set 245 lib/pacemaker/pcmk_sched_utils.c pe_working_set_t *data_set) data_set 247 lib/pacemaker/pcmk_sched_utils.c struct node_weight_s nw = { active_node, data_set }; data_set 472 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 475 lib/pacemaker/pcmk_sched_utils.c task, NULL, optional, TRUE, data_set); data_set 498 lib/pacemaker/pcmk_sched_utils.c pe_node_t *node, pe_working_set_t *data_set) data_set 507 lib/pacemaker/pcmk_sched_utils.c data_set); data_set 532 lib/pacemaker/pcmk_sched_utils.c sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set) data_set 538 lib/pacemaker/pcmk_sched_utils.c node, FALSE, TRUE, data_set); data_set 541 lib/pacemaker/pcmk_sched_utils.c shutdown_constraints(node, shutdown_op, data_set); 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 698 lib/pengine/bundle.c pe_working_set_t *data_set) data_set 710 lib/pengine/bundle.c if (pe_find_resource(data_set->resources, id) != NULL) { data_set 716 lib/pengine/bundle.c CRM_ASSERT(pe_find_resource(data_set->resources, id) == NULL); data_set 752 lib/pengine/bundle.c node = pe_find_node(data_set->nodes, uname); data_set 755 lib/pengine/bundle.c data_set); data_set 778 lib/pengine/bundle.c for (rsc_iter = data_set->resources; rsc_iter; rsc_iter = rsc_iter->next) { data_set 801 lib/pengine/bundle.c if (!common_unpack(xml_remote, &replica->remote, parent, data_set)) { data_set 840 lib/pengine/bundle.c pe__bundle_replica_t *replica, pe_working_set_t *data_set) data_set 845 lib/pengine/bundle.c if (!create_docker_resource(parent, data, replica, data_set)) { data_set 851 lib/pengine/bundle.c if (!create_podman_resource(parent, data, replica, data_set)) { data_set 857 lib/pengine/bundle.c if (!create_rkt_resource(parent, data, replica, data_set)) { data_set 865 lib/pengine/bundle.c if (create_ip_resource(parent, data, replica, data_set) == FALSE) { data_set 868 lib/pengine/bundle.c if(create_remote_resource(parent, data, replica, data_set) == FALSE) { data_set 950 lib/pengine/bundle.c pe__bundle_needs_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 960 lib/pengine/bundle.c params = pe_rsc_params(rsc, NULL, data_set); data_set 968 lib/pengine/bundle.c pe__add_bundle_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set, data_set 976 lib/pengine/bundle.c if (!pe__bundle_needs_remote_name(rsc, data_set)) { data_set 1014 lib/pengine/bundle.c pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 1202 lib/pengine/bundle.c if (common_unpack(xml_resource, &new_rsc, rsc, data_set) == FALSE) { data_set 1310 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 1013 lib/pengine/clone.c pe_working_set_t *data_set) data_set 1019 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 198 lib/pengine/native.c native_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 219 lib/pengine/native.c pe__force_anon(standard, parent, rsc->id, data_set); data_set 325 lib/pengine/native.c pe_working_set_t * data_set) data_set 335 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 48 lib/pengine/pe_output.c add_extra_info(pe_node_t *node, GList *rsc_list, pe_working_set_t *data_set, data_set 60 lib/pengine/pe_output.c if (add_extra_info(node, rsc->children, data_set, attrname, data_set 70 lib/pengine/pe_output.c params = pe_rsc_params(rsc, node, data_set); data_set 228 lib/pengine/pe_output.c get_cluster_stack(pe_working_set_t *data_set) data_set 231 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 365 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 370 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 378 lib/pengine/pe_output.c if (data_set->dc_node == NULL || pcmk_is_set(section_opts, pcmk_section_dc)) { data_set 380 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 384 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 385 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 388 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, dc_version_s, dc_name); data_set 393 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 394 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 395 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 396 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 404 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 405 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 406 lib/pengine/pe_output.c data_set->blocked_resources); data_set 411 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 416 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 426 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 431 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 439 lib/pengine/pe_output.c if (data_set->dc_node == NULL || pcmk_is_set(section_opts, pcmk_section_dc)) { data_set 441 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 445 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 446 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 449 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, dc_version_s, dc_name); data_set 454 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 455 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 456 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 457 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 465 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 466 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 467 lib/pengine/pe_output.c data_set->blocked_resources); data_set 478 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 483 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 656 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 666 lib/pengine/pe_output.c for (gIter = data_set->placement_constraints; gIter != NULL; gIter = gIter->next) { data_set 917 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 920 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 923 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 925 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 948 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 955 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 972 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 974 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 976 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 986 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 989 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 992 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 994 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 1023 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1026 lib/pengine/pe_output.c char *stonith_timeout_str = pcmk__itoa(data_set->stonith_timeout); data_set 1027 lib/pengine/pe_output.c char *priority_fencing_delay_str = pcmk__itoa(data_set->priority_fencing_delay * 1000); data_set 1029 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 1052 lib/pengine/pe_output.c "stonith-enabled", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)), data_set 1053 lib/pengine/pe_output.c "symmetric-cluster", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)), data_set 1055 lib/pengine/pe_output.c "maintenance-mode", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)), data_set 1056 lib/pengine/pe_output.c "stop-all-resources", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything)), data_set 1239 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1249 lib/pengine/pe_output.c if (xmlChildElementCount(data_set->failed) == 0) { data_set 1253 lib/pengine/pe_output.c for (xml_op = pcmk__xml_first_child(data_set->failed); xml_op != NULL; data_set 1584 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1599 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 1640 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1660 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 1714 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1723 lib/pengine/pe_output.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1761 lib/pengine/pe_output.c data_set, name, &expected_score); data_set 1813 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1832 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1856 lib/pengine/pe_output.c NULL, data_set); data_set 1871 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, data_set 1883 lib/pengine/pe_output.c out->message(out, "resource-operation-list", data_set, rsc, node, data_set 2080 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2088 lib/pengine/pe_output.c xmlNode *cib_status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 2097 lib/pengine/pe_output.c pe_node_t *node = pe_find_node_id(data_set->nodes, ID(node_state)); data_set 2110 lib/pengine/pe_output.c out->message(out, "node-history-list", data_set, node, node_state, data_set 2369 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2391 lib/pengine/pe_output.c GList *rscs = pe__filter_rsc_list(data_set->resources, only_rsc); data_set 2402 lib/pengine/pe_output.c for (rsc_iter = data_set->resources; rsc_iter != NULL; rsc_iter = rsc_iter->next) { data_set 2476 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2506 lib/pengine/pe_output.c NULL, data_set); data_set 2630 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2636 lib/pengine/pe_output.c if (g_hash_table_size(data_set->tickets) == 0) { data_set 2646 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 35 lib/pengine/unpack.c #define set_config_flag(data_set, option, flag) do { \ data_set 36 lib/pengine/unpack.c const char *scf_value = pe_pref((data_set)->config_hash, (option)); \ data_set 39 lib/pengine/unpack.c (data_set)->flags = pcmk__set_flags_as(__func__, __LINE__, \ data_set 41 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 44 lib/pengine/unpack.c (data_set)->flags = pcmk__clear_flags_as(__func__, __LINE__,\ data_set 46 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 55 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 56 lib/pengine/unpack.c static void determine_remote_online_status(pe_working_set_t *data_set, data_set 59 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 61 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 64 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 97 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, data_set 145 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 150 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, FALSE, data_set); data_set 155 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", data_set 161 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 164 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, priority_delay, data_set); data_set 184 lib/pengine/unpack.c set_if_xpath(uint64_t flag, const char *xpath, pe_working_set_t *data_set) data_set 188 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, flag)) { data_set 189 lib/pengine/unpack.c result = xpath_search(data_set->input, xpath); data_set 191 lib/pengine/unpack.c pe__set_working_set_flags(data_set, flag); data_set 198 lib/pengine/unpack.c unpack_config(xmlNode * config, pe_working_set_t * data_set) data_set 206 lib/pengine/unpack.c .now = data_set->now, data_set 212 lib/pengine/unpack.c data_set->config_hash = config_hash; data_set 215 lib/pengine/unpack.c CIB_OPTIONS_FIRST, FALSE, data_set); data_set 217 lib/pengine/unpack.c verify_pe_options(data_set->config_hash); data_set 219 lib/pengine/unpack.c set_config_flag(data_set, "enable-startup-probes", pe_flag_startup_probes); data_set 220 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 224 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, XML_ATTR_HAVE_WATCHDOG); data_set 228 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_stonith_resource); data_set 234 lib/pengine/unpack.c set_if_xpath(pe_flag_enable_unfencing, XPATH_ENABLE_UNFENCING, data_set); data_set 236 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 237 lib/pengine/unpack.c data_set->stonith_timeout = (int) crm_parse_interval_spec(value); data_set 238 lib/pengine/unpack.c crm_debug("STONITH timeout: %d", data_set->stonith_timeout); data_set 240 lib/pengine/unpack.c set_config_flag(data_set, "stonith-enabled", pe_flag_stonith_enabled); data_set 242 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)? "enabled" : "disabled"); data_set 244 lib/pengine/unpack.c data_set->stonith_action = pe_pref(data_set->config_hash, "stonith-action"); data_set 245 lib/pengine/unpack.c if (!strcmp(data_set->stonith_action, "poweroff")) { data_set 249 lib/pengine/unpack.c data_set->stonith_action = "off"; data_set 251 lib/pengine/unpack.c crm_trace("STONITH will %s nodes", data_set->stonith_action); data_set 253 lib/pengine/unpack.c set_config_flag(data_set, "concurrent-fencing", pe_flag_concurrent_fencing); data_set 255 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)? "enabled" : "disabled"); data_set 257 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 260 lib/pengine/unpack.c data_set->priority_fencing_delay = crm_parse_interval_spec(value) / 1000; data_set 261 lib/pengine/unpack.c crm_trace("Priority fencing delay is %ds", data_set->priority_fencing_delay); data_set 264 lib/pengine/unpack.c set_config_flag(data_set, "stop-all-resources", pe_flag_stop_everything); data_set 266 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything))); data_set 268 lib/pengine/unpack.c set_config_flag(data_set, "symmetric-cluster", pe_flag_symmetric_cluster); data_set 269 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 273 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "no-quorum-policy"); data_set 276 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_ignore; data_set 279 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_freeze; data_set 282 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_demote; data_set 285 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 288 lib/pengine/unpack.c crm_element_value_int(data_set->input, XML_ATTR_QUORUM_PANIC, data_set 290 lib/pengine/unpack.c if (do_panic || pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 291 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_suicide; data_set 294 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 299 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 303 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 306 lib/pengine/unpack.c switch (data_set->no_quorum_policy) { data_set 325 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-resources", pe_flag_stop_rsc_orphans); data_set 327 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)? "stopped" : "ignored"); data_set 329 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-actions", pe_flag_stop_action_orphans); data_set 331 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_action_orphans)? "stopped" : "ignored"); data_set 333 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "remove-after-stop"); data_set 336 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 343 lib/pengine/unpack.c pe__clear_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 347 lib/pengine/unpack.c set_config_flag(data_set, "maintenance-mode", pe_flag_maintenance_mode); data_set 349 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode))); data_set 351 lib/pengine/unpack.c set_config_flag(data_set, "start-failure-is-fatal", pe_flag_start_failure_fatal); data_set 353 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)? "always fatal" : "handled by failcount"); data_set 355 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 356 lib/pengine/unpack.c set_config_flag(data_set, "startup-fencing", pe_flag_startup_fencing); data_set 358 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 364 lib/pengine/unpack.c pcmk__score_red = char2score(pe_pref(data_set->config_hash, "node-health-red")); data_set 365 lib/pengine/unpack.c pcmk__score_green = char2score(pe_pref(data_set->config_hash, "node-health-green")); data_set 366 lib/pengine/unpack.c pcmk__score_yellow = char2score(pe_pref(data_set->config_hash, "node-health-yellow")); data_set 369 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-red"), data_set 370 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-yellow"), data_set 371 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-green")); data_set 373 lib/pengine/unpack.c data_set->placement_strategy = pe_pref(data_set->config_hash, "placement-strategy"); data_set 374 lib/pengine/unpack.c crm_trace("Placement strategy: %s", data_set->placement_strategy); data_set 376 lib/pengine/unpack.c set_config_flag(data_set, "shutdown-lock", pe_flag_shutdown_lock); data_set 378 lib/pengine/unpack.c (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)? "" : " not")); data_set 379 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 380 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 382 lib/pengine/unpack.c data_set->shutdown_lock = crm_parse_interval_spec(value) / 1000; data_set 383 lib/pengine/unpack.c crm_trace("Shutdown locks expire after %us", data_set->shutdown_lock); data_set 391 lib/pengine/unpack.c const char *score, pe_working_set_t * data_set) data_set 395 lib/pengine/unpack.c if (pe_find_node(data_set->nodes, uname) != NULL) { data_set 424 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_remote_nodes); data_set 443 lib/pengine/unpack.c data_set->nodes = g_list_insert_sorted(data_set->nodes, new_node, sort_node_uname); data_set 505 lib/pengine/unpack.c handle_startup_fencing(pe_working_set_t *data_set, pe_node_t *new_node) data_set 515 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 530 lib/pengine/unpack.c unpack_nodes(xmlNode * xml_nodes, pe_working_set_t * data_set) data_set 542 lib/pengine/unpack.c .now = data_set->now, data_set 565 lib/pengine/unpack.c new_node = pe_create_node(id, uname, type, score, data_set); data_set 577 lib/pengine/unpack.c handle_startup_fencing(data_set, new_node); data_set 579 lib/pengine/unpack.c add_node_attrs(xml_obj, new_node, FALSE, data_set); data_set 582 lib/pengine/unpack.c FALSE, data_set); data_set 588 lib/pengine/unpack.c if (data_set->localhost && pe_find_node(data_set->nodes, data_set->localhost) == NULL) { data_set 590 lib/pengine/unpack.c pe_create_node(data_set->localhost, data_set->localhost, NULL, 0, data_set 591 lib/pengine/unpack.c data_set); data_set 598 lib/pengine/unpack.c setup_container(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 608 lib/pengine/unpack.c setup_container(child_rsc, data_set); data_set 615 lib/pengine/unpack.c pe_resource_t *container = pe_find_resource(data_set->resources, container_id); data_set 629 lib/pengine/unpack.c unpack_remote_nodes(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 648 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 652 lib/pengine/unpack.c data_set); data_set 665 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj, xml_resources, data_set); data_set 666 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 670 lib/pengine/unpack.c data_set); data_set 683 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj2, xml_resources, data_set); data_set 685 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 689 lib/pengine/unpack.c data_set); data_set 706 lib/pengine/unpack.c link_rsc2remotenode(pe_working_set_t *data_set, pe_resource_t *new_rsc) data_set 714 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 719 lib/pengine/unpack.c remote_node = pe_find_node(data_set->nodes, new_rsc->id); data_set 730 lib/pengine/unpack.c handle_startup_fencing(data_set, remote_node); data_set 766 lib/pengine/unpack.c unpack_resources(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 771 lib/pengine/unpack.c data_set->template_rsc_sets = pcmk__strkey_table(free, destroy_tag); data_set 781 lib/pengine/unpack.c if (template_id && g_hash_table_lookup_extended(data_set->template_rsc_sets, data_set 784 lib/pengine/unpack.c g_hash_table_insert(data_set->template_rsc_sets, strdup(template_id), NULL); data_set 790 lib/pengine/unpack.c if (common_unpack(xml_obj, &new_rsc, NULL, data_set) && (new_rsc != NULL)) { data_set 791 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, new_rsc); data_set 804 lib/pengine/unpack.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 807 lib/pengine/unpack.c setup_container(rsc, data_set); data_set 808 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 811 lib/pengine/unpack.c data_set->resources = g_list_sort(data_set->resources, sort_rsc_priority); data_set 812 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 815 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 816 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 827 lib/pengine/unpack.c unpack_tags(xmlNode * xml_tags, pe_working_set_t * data_set) data_set 831 lib/pengine/unpack.c data_set->tags = pcmk__strkey_table(free, destroy_tag); data_set 864 lib/pengine/unpack.c if (add_tag_ref(data_set->tags, tag_id, obj_ref) == FALSE) { data_set 876 lib/pengine/unpack.c unpack_ticket_state(xmlNode * xml_ticket, pe_working_set_t * data_set) data_set 893 lib/pengine/unpack.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 895 lib/pengine/unpack.c ticket = ticket_new(ticket_id, data_set); data_set 944 lib/pengine/unpack.c unpack_tickets_state(xmlNode * xml_tickets, pe_working_set_t * data_set) data_set 954 lib/pengine/unpack.c unpack_ticket_state(xml_obj, data_set); data_set 961 lib/pengine/unpack.c unpack_handle_remote_attrs(pe_node_t *this_node, xmlNode *state, pe_working_set_t * data_set) data_set 985 lib/pengine/unpack.c add_node_attrs(attrs, this_node, TRUE, data_set); data_set 1006 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1031 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 1036 lib/pengine/unpack.c add_node_attrs(attrs, node, TRUE, data_set); data_set 1069 lib/pengine/unpack.c unpack_node_state(xmlNode *state, pe_working_set_t *data_set) data_set 1089 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1107 lib/pengine/unpack.c unpack_transient_attributes(state, this_node, data_set); data_set 1117 lib/pengine/unpack.c determine_online_status(state, this_node, data_set); data_set 1119 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 1121 lib/pengine/unpack.c && (data_set->no_quorum_policy == no_quorum_suicide)) { data_set 1126 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "cluster does not have quorum", data_set 1149 lib/pengine/unpack.c unpack_node_history(xmlNode *status, bool fence, pe_working_set_t *data_set) data_set 1168 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1209 lib/pengine/unpack.c || (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock) data_set 1221 lib/pengine/unpack.c } else if (!pcmk_any_flags_set(data_set->flags, pe_flag_stonith_enabled data_set 1230 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1231 lib/pengine/unpack.c unpack_handle_remote_attrs(this_node, state, data_set); data_set 1238 lib/pengine/unpack.c unpack_node_lrm(this_node, state, data_set); data_set 1249 lib/pengine/unpack.c unpack_status(xmlNode * status, pe_working_set_t * data_set) data_set 1255 lib/pengine/unpack.c if (data_set->tickets == NULL) { data_set 1256 lib/pengine/unpack.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 1263 lib/pengine/unpack.c unpack_tickets_state((xmlNode *) state, data_set); data_set 1266 lib/pengine/unpack.c unpack_node_state(state, data_set); data_set 1270 lib/pengine/unpack.c while (unpack_node_history(status, FALSE, data_set) == EAGAIN) { data_set 1276 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled), data_set 1277 lib/pengine/unpack.c data_set); data_set 1282 lib/pengine/unpack.c if (data_set->stop_needed != NULL) { data_set 1283 lib/pengine/unpack.c for (GList *item = data_set->stop_needed; item; item = item->next) { data_set 1291 lib/pengine/unpack.c g_list_free(data_set->stop_needed); data_set 1292 lib/pengine/unpack.c data_set->stop_needed = NULL; data_set 1299 lib/pengine/unpack.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1311 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1319 lib/pengine/unpack.c determine_online_status_no_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1345 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is unexpectedly down", FALSE); data_set 1353 lib/pengine/unpack.c determine_online_status_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1401 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer has not been seen by the cluster", FALSE); data_set 1404 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer failed the pacemaker membership criteria", FALSE); data_set 1424 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is no longer part of the cluster", TRUE); data_set 1427 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer process is no longer available", FALSE); data_set 1431 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "termination was requested", FALSE); data_set 1442 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer was in an unknown state", FALSE); data_set 1452 lib/pengine/unpack.c determine_remote_online_status(pe_working_set_t * data_set, pe_node_t * this_node) data_set 1521 lib/pengine/unpack.c determine_online_status(xmlNode * node_state, pe_node_t * this_node, pe_working_set_t * data_set) data_set 1545 lib/pengine/unpack.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1546 lib/pengine/unpack.c online = determine_online_status_no_fencing(data_set, node_state, this_node); data_set 1549 lib/pengine/unpack.c online = determine_online_status_fencing(data_set, node_state, this_node); data_set 1672 lib/pengine/unpack.c create_fake_resource(const char *rsc_id, xmlNode * rsc_entry, pe_working_set_t * data_set) data_set 1681 lib/pengine/unpack.c if (!common_unpack(xml_rsc, &rsc, NULL, data_set)) { data_set 1689 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); data_set 1691 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); data_set 1693 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 1707 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, rsc); data_set 1717 lib/pengine/unpack.c pe_node_t *node, pe_working_set_t *data_set) data_set 1719 lib/pengine/unpack.c pe_resource_t *top = pe__create_clone_child(parent, data_set); data_set 1744 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, pe_node_t * node, pe_resource_t * parent, data_set 1854 lib/pengine/unpack.c && !pe__is_universal_clone(parent, data_set)) { data_set 1860 lib/pengine/unpack.c rsc = create_anonymous_orphan(parent, rsc_id, node, data_set); data_set 1867 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, pe_node_t * node, const char *rsc_id, data_set 1874 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1882 lib/pengine/unpack.c pe_resource_t *clone0 = pe_find_resource(data_set->resources, clone0_id); data_set 1910 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); data_set 1929 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, pe_node_t * node, pe_working_set_t * data_set) data_set 1935 lib/pengine/unpack.c rsc = create_fake_resource(rsc_id, rsc_entry, data_set); data_set 1937 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 1943 lib/pengine/unpack.c resource_location(rsc, NULL, -INFINITY, "__orphan_do_not_run__", data_set); data_set 1951 lib/pengine/unpack.c xmlNode * migrate_op, pe_working_set_t * data_set) data_set 1999 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2022 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2052 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2073 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); data_set 2095 lib/pengine/unpack.c data_set->stop_needed = g_list_prepend(data_set->stop_needed, data_set 2106 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2109 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2118 lib/pengine/unpack.c pe_fence_node(data_set, tmpnode, data_set 2141 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2160 lib/pengine/unpack.c native_add_running(rsc, node, data_set, (save_on_fail != action_fail_ignore)); data_set 2200 lib/pengine/unpack.c GList *sorted_op_list, pe_working_set_t * data_set) data_set 2248 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); data_set 2303 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2310 lib/pengine/unpack.c if ((data_set->shutdown_lock > 0) data_set 2311 lib/pengine/unpack.c && (get_effective_time(data_set) data_set 2312 lib/pengine/unpack.c > (lock_time + data_set->shutdown_lock))) { data_set 2315 lib/pengine/unpack.c pe__clear_resource_history(rsc, node, data_set); data_set 2335 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2371 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2379 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, lrm_resource); data_set 2385 lib/pengine/unpack.c rsc = process_orphan_resource(lrm_resource, node, data_set); data_set 2391 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2392 lib/pengine/unpack.c unpack_shutdown_lock(lrm_resource, rsc, node, data_set); data_set 2408 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); data_set 2413 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); data_set 2418 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); data_set 2439 lib/pengine/unpack.c handle_orphaned_container_fillers(xmlNode * lrm_rsc_list, pe_working_set_t * data_set) data_set 2460 lib/pengine/unpack.c container = pe_find_resource(data_set->resources, container_id); data_set 2465 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 2488 lib/pengine/unpack.c unpack_node_lrm(pe_node_t *node, xmlNode *xml, pe_working_set_t *data_set) data_set 2506 lib/pengine/unpack.c pe_resource_t *rsc = unpack_lrm_resource(node, rsc_entry, data_set); data_set 2518 lib/pengine/unpack.c handle_orphaned_container_fillers(xml, data_set); data_set 2546 lib/pengine/unpack.c bool success_only, pe_working_set_t *data_set) data_set 2575 lib/pengine/unpack.c xml = get_xpath_object(xpath, data_set->input, LOG_DEBUG); data_set 2619 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2622 lib/pengine/unpack.c node->details->uname, NULL, TRUE, data_set); data_set 2629 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2659 lib/pengine/unpack.c if (stop_happened_after(rsc, node, xml_op, data_set)) { data_set 2666 lib/pengine/unpack.c target_node = pe_find_node(data_set->nodes, target); data_set 2667 lib/pengine/unpack.c source_node = pe_find_node(data_set->nodes, source); data_set 2671 lib/pengine/unpack.c source, FALSE, data_set); data_set 2694 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, TRUE); data_set 2702 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2724 lib/pengine/unpack.c int call_id, pe_working_set_t *data_set) data_set 2727 lib/pengine/unpack.c data_set); data_set 2734 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2753 lib/pengine/unpack.c TRUE, data_set); data_set 2758 lib/pengine/unpack.c source, TRUE, data_set); data_set 2766 lib/pengine/unpack.c pe_node_t *target_node = pe_find_node(data_set->nodes, target); data_set 2771 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2788 lib/pengine/unpack.c data_set) data_set 2790 lib/pengine/unpack.c data_set) data_set 2792 lib/pengine/unpack.c data_set)) { data_set 2803 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 2820 lib/pengine/unpack.c TRUE, data_set); data_set 2824 lib/pengine/unpack.c source, target, TRUE, data_set); data_set 2832 lib/pengine/unpack.c pe_node_t *source_node = pe_find_node(data_set->nodes, source); data_set 2835 lib/pengine/unpack.c native_add_running(rsc, source_node, data_set, TRUE); data_set 2842 lib/pengine/unpack.c const pe_resource_t *rsc, pe_working_set_t *data_set) data_set 2851 lib/pengine/unpack.c for (xIter = data_set->failed->children; xIter; xIter = xIter->next) { data_set 2864 lib/pengine/unpack.c add_node_copy(data_set->failed, op); data_set 2988 lib/pengine/unpack.c enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3013 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) data_set 3041 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3044 lib/pengine/unpack.c action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3052 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); data_set 3055 lib/pengine/unpack.c unpack_migrate_to_failure(rsc, node, xml_op, data_set); data_set 3058 lib/pengine/unpack.c unpack_migrate_from_failure(rsc, node, xml_op, data_set); data_set 3123 lib/pengine/unpack.c fail_rsc->allowed_nodes = pe__node_list2table(data_set->nodes); data_set 3151 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 3249 lib/pengine/unpack.c if (!pe_can_fence(data_set, node) data_set 3281 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3285 lib/pengine/unpack.c if (pe__bundle_needs_remote_name(rsc, data_set)) { data_set 3291 lib/pengine/unpack.c data_set); data_set 3296 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); data_set 3316 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3318 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, remote_conn->id); data_set 3322 lib/pengine/unpack.c FALSE, data_set); data_set 3331 lib/pengine/unpack.c bool is_last_failure, pe_working_set_t *data_set) data_set 3354 lib/pengine/unpack.c && pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3357 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 3394 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 3412 lib/pengine/unpack.c time_t now = get_effective_time(data_set); data_set 3418 lib/pengine/unpack.c is_last_failure, data_set)) { data_set 3425 lib/pengine/unpack.c data_set); data_set 3435 lib/pengine/unpack.c pe__update_recheck_time(last_failure, data_set); data_set 3440 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, NULL, pe_fc_default, xml_op, data_set)) { data_set 3467 lib/pengine/unpack.c && should_clear_for_param_change(xml_op, task, rsc, node, data_set)) { data_set 3474 lib/pengine/unpack.c data_set); data_set 3476 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3488 lib/pengine/unpack.c order_after_remote_fencing(clear_op, rsc, data_set); data_set 3521 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 3524 lib/pengine/unpack.c pe_action_t *action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3534 lib/pengine/unpack.c xmlNode * last_failure, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3586 lib/pengine/unpack.c unpack_migrate_to_success(rsc, node, xml_op, data_set); data_set 3651 lib/pengine/unpack.c const pe_resource_t *rsc, pe_working_set_t *data_set) data_set 3658 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3667 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3732 lib/pengine/unpack.c && check_operation_expiry(rsc, node, rc, xml_op, data_set)) { data_set 3737 lib/pengine/unpack.c rc = remap_monitor_rc(rc, xml_op, node, rsc, data_set); data_set 3774 lib/pengine/unpack.c status = determine_op_status(rsc, rc, target_rc, node, xml_op, on_fail, data_set); data_set 3799 lib/pengine/unpack.c pe_node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 3827 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); data_set 3831 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3841 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3842 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 3867 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3879 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, target_rc, *last_failure, on_fail, data_set); data_set 3883 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3891 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 3901 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3909 lib/pengine/unpack.c resource_location(parent, NULL, -INFINITY, "fatal-error", data_set); data_set 3923 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3930 lib/pengine/unpack.c .now = data_set->now, data_set 3941 lib/pengine/unpack.c if (pcmk__str_eq(node->details->id, data_set->dc_uuid, pcmk__str_casei)) { data_set 3942 lib/pengine/unpack.c data_set->dc_node = node; data_set 3951 lib/pengine/unpack.c cluster_name = g_hash_table_lookup(data_set->config_hash, "cluster-name"); data_set 3958 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set); data_set 4043 lib/pengine/unpack.c pe_working_set_t * data_set) data_set 4049 lib/pengine/unpack.c xmlNode *status = find_xml_node(data_set->input, XML_CIB_TAG_STATUS, TRUE); data_set 4065 lib/pengine/unpack.c this_node = pe_find_node(data_set->nodes, uname); data_set 4071 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 4074 lib/pengine/unpack.c determine_online_status(node_state, this_node, data_set); data_set 4078 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 417 lib/pengine/utils.c pe_working_set_t * data_set) data_set 429 lib/pengine/utils.c action = g_hash_table_lookup(data_set->singletons, key); data_set 432 lib/pengine/utils.c possible_matches = find_actions(data_set->actions, key, on_node); data_set 436 lib/pengine/utils.c if(data_set->singletons == NULL) { data_set 437 lib/pengine/utils.c data_set->singletons = pcmk__strkey_table(NULL, NULL); data_set 458 lib/pengine/utils.c data_set->action_id, data_set 466 lib/pengine/utils.c action->id = data_set->action_id++; data_set 493 lib/pengine/utils.c data_set->actions = g_list_prepend(data_set->actions, action); data_set 495 lib/pengine/utils.c g_hash_table_insert(data_set->singletons, action->uuid, action); data_set 505 lib/pengine/utils.c unpack_operation(action, action->op_entry, rsc->container, data_set, data_set 520 lib/pengine/utils.c enum pe_quorum_policy quorum_policy = effective_quorum_policy(rsc, data_set); data_set 532 lib/pengine/utils.c .now = data_set->now, data_set 541 lib/pengine/utils.c FALSE, data_set); data_set 577 lib/pengine/utils.c pe_fence_node(data_set, action->node, "resource actions are unrunnable", FALSE); data_set 590 lib/pengine/utils.c && !pe_can_fence(data_set, action->node)) { data_set 853 lib/pengine/utils.c pe_get_configured_timeout(pe_resource_t *rsc, const char *action, pe_working_set_t *data_set) data_set 863 lib/pengine/utils.c .now = data_set->now, data_set 878 lib/pengine/utils.c if (timeout_spec == NULL && data_set->op_defaults) { data_set 880 lib/pengine/utils.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, data_set 881 lib/pengine/utils.c &rule_data, action_meta, NULL, FALSE, data_set); data_set 954 lib/pengine/utils.c pe_working_set_t * data_set, guint interval_ms) data_set 978 lib/pengine/utils.c .now = data_set->now, data_set 987 lib/pengine/utils.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, &rule_data, data_set 988 lib/pengine/utils.c action->meta, NULL, FALSE, data_set); data_set 1010 lib/pengine/utils.c action->meta, NULL, TRUE, data_set); data_set 1015 lib/pengine/utils.c pe_eval_versioned_attributes(data_set->input, xml_obj, data_set 1019 lib/pengine/utils.c pe_eval_versioned_attributes(data_set->input, xml_obj, data_set 1065 lib/pengine/utils.c GHashTable *params = pe_rsc_params(action->rsc, action->node, data_set); data_set 1114 lib/pengine/utils.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1176 lib/pengine/utils.c && pe__resource_is_remote_conn(action->rsc, data_set) data_set 1187 lib/pengine/utils.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1200 lib/pengine/utils.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1246 lib/pengine/utils.c if (unpack_interval_origin(value, xml_obj, interval_ms, data_set->now, data_set 1255 lib/pengine/utils.c data_set->now); data_set 1595 lib/pengine/utils.c pe_working_set_t * data_set) data_set 1600 lib/pengine/utils.c } else if (data_set != NULL) { data_set 1601 lib/pengine/utils.c GList *gIter = data_set->nodes; data_set 1755 lib/pengine/utils.c get_effective_time(pe_working_set_t * data_set) data_set 1757 lib/pengine/utils.c if(data_set) { data_set 1758 lib/pengine/utils.c if (data_set->now == NULL) { data_set 1760 lib/pengine/utils.c data_set->now = crm_time_new(NULL); data_set 1762 lib/pengine/utils.c return crm_time_get_seconds_since_epoch(data_set->now); data_set 1854 lib/pengine/utils.c get_pseudo_op(const char *name, pe_working_set_t * data_set) data_set 1858 lib/pengine/utils.c if(data_set->singletons) { data_set 1859 lib/pengine/utils.c op = g_hash_table_lookup(data_set->singletons, name); data_set 1862 lib/pengine/utils.c op = custom_action(NULL, strdup(name), name, NULL, TRUE, TRUE, data_set); data_set 1882 lib/pengine/utils.c ticket_new(const char *ticket_id, pe_working_set_t * data_set) data_set 1890 lib/pengine/utils.c if (data_set->tickets == NULL) { data_set 1891 lib/pengine/utils.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 1894 lib/pengine/utils.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 1911 lib/pengine/utils.c g_hash_table_insert(data_set->tickets, strdup(ticket->id), ticket); data_set 1935 lib/pengine/utils.c pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag) data_set 1937 lib/pengine/utils.c for (GList *lpc = data_set->resources; lpc != NULL; lpc = lpc->next) { data_set 1974 lib/pengine/utils.c node_priority_fencing_delay(pe_node_t * node, pe_working_set_t * data_set) data_set 1983 lib/pengine/utils.c if (data_set->priority_fencing_delay <= 0) { data_set 1998 lib/pengine/utils.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 2037 lib/pengine/utils.c return data_set->priority_fencing_delay; data_set 2042 lib/pengine/utils.c bool priority_delay, pe_working_set_t * data_set) data_set 2048 lib/pengine/utils.c op = data_set->stonith_action; data_set 2053 lib/pengine/utils.c if(data_set->singletons) { data_set 2054 lib/pengine/utils.c stonith_op = g_hash_table_lookup(data_set->singletons, op_key); data_set 2058 lib/pengine/utils.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); data_set 2065 lib/pengine/utils.c && pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2077 lib/pengine/utils.c GList *matches = find_unfencing_devices(data_set->resources, NULL); data_set 2085 lib/pengine/utils.c data = pe__compare_fencing_digest(match, agent, node, data_set); data_set 2089 lib/pengine/utils.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 2090 lib/pengine/utils.c pcmk__output_t *out = data_set->priv; data_set 2116 lib/pengine/utils.c if (data_set->priority_fencing_delay > 0 data_set 2132 lib/pengine/utils.c char *delay_s = pcmk__itoa(node_priority_fencing_delay(node, data_set)); data_set 2139 lib/pengine/utils.c if(optional == FALSE && pe_can_fence(data_set, node)) { data_set 2150 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 2152 lib/pengine/utils.c if (!pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2165 lib/pengine/utils.c pe_action_t *unfence = pe_fence_op(node, "on", FALSE, reason, FALSE, data_set); data_set 2177 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); data_set 2327 lib/pengine/utils.c pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set) data_set 2329 lib/pengine/utils.c if ((recheck > get_effective_time(data_set)) data_set 2330 lib/pengine/utils.c && ((data_set->recheck_by == 0) data_set 2331 lib/pengine/utils.c || (data_set->recheck_by > recheck))) { data_set 2332 lib/pengine/utils.c data_set->recheck_by = recheck; data_set 2344 lib/pengine/utils.c pe_working_set_t *data_set) data_set 2348 lib/pengine/utils.c pe_eval_nvpairs(data_set->input, xml_obj, set_name, rule_data, hash, data_set 2353 lib/pengine/utils.c pe__update_recheck_time(recheck, data_set); data_set 2388 lib/pengine/utils.c pe_working_set_t *data_set) data_set 2395 lib/pengine/utils.c data_set); data_set 2438 lib/pengine/utils.c pe__build_node_name_list(pe_working_set_t *data_set, const char *s) { data_set 2448 lib/pengine/utils.c pe_node_t *node = pe_find_node(data_set->nodes, s); data_set 2462 lib/pengine/utils.c nodes = pe__unames_with_tag(data_set, s); data_set 2470 lib/pengine/utils.c pe__build_rsc_list(pe_working_set_t *data_set, const char *s) { data_set 2476 lib/pengine/utils.c pe_resource_t *rsc = pe_find_resource_with_flags(data_set->resources, s, data_set 2495 lib/pengine/utils.c resources = pe__rscs_with_tag(data_set, s); data_set 1696 tools/crm_mon.c print_simple_status(pcmk__output_t *out, pe_working_set_t * data_set) data_set 1707 tools/crm_mon.c if (data_set->dc_node == NULL) { data_set 1712 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1757 tools/crm_mon.c data_set->ninstances, pcmk__plural_s(data_set->ninstances)); data_set 29 tools/crm_mon.h void print_status(pe_working_set_t *data_set, crm_exit_t history_rc, data_set 33 tools/crm_mon.h void print_xml_status(pe_working_set_t *data_set, crm_exit_t history_rc, data_set 37 tools/crm_mon.h int print_html_status(pe_working_set_t *data_set, crm_exit_t history_rc, 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 1246 tools/crm_resource.c data_set = pe_new_working_set(); data_set 1247 tools/crm_resource.c if (data_set == NULL) { data_set 1250 tools/crm_resource.c pe__set_working_set_flags(data_set, data_set 1252 tools/crm_resource.c data_set->priv = out; data_set 1253 tools/crm_resource.c rc = update_working_set_xml(data_set, cib_xml_copy); data_set 1263 tools/crm_resource.c cluster_status(data_set); data_set 1275 tools/crm_resource.c pe_node_t *node = pe_find_node(data_set->nodes, options.host_uname); data_set 1324 tools/crm_resource.c 0, FALSE, data_set, options.force); data_set 1744 tools/crm_resource.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 1755 tools/crm_resource.c if ((options.host_uname != NULL) && (data_set != NULL)) { data_set 1756 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1787 tools/crm_resource.c rc = out->message(out, "resource-list", data_set, data_set 1799 tools/crm_resource.c rc = out->message(out, "resource-names-list", data_set->resources); data_set 1848 tools/crm_resource.c options.timeout_ms, cib_conn, data_set, data_set 1854 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1859 tools/crm_resource.c options.override_params, data_set); data_set 1864 tools/crm_resource.c rc = out->message(out, "stacks-constraints", rsc, data_set, false); data_set 1868 tools/crm_resource.c rc = out->message(out, "stacks-constraints", rsc, data_set, true); data_set 1874 tools/crm_resource.c for (GList *lpc = data_set->resources; lpc != NULL; data_set 1881 tools/crm_resource.c cli_resource_print_cts_constraints(data_set); data_set 1886 tools/crm_resource.c options.rsc_id, data_set); data_set 1895 tools/crm_resource.c data_set); data_set 1901 tools/crm_resource.c data_set); data_set 1905 tools/crm_resource.c GList *nodes = cli_resource_search(rsc, options.rsc_id, data_set); data_set 1912 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, TRUE); data_set 1916 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, FALSE); data_set 1924 tools/crm_resource.c data_set->resources, rsc, node); data_set 1938 tools/crm_resource.c options.cib_options, data_set, data_set 1996 tools/crm_resource.c params = pe_rsc_params(rsc, current, data_set); data_set 2001 tools/crm_resource.c get_meta_attributes(params, rsc, current, data_set); data_set 2006 tools/crm_resource.c NULL, FALSE, data_set); data_set 2032 tools/crm_resource.c options.cib_options, data_set, data_set 2043 tools/crm_resource.c options.cib_options, data_set, data_set 2051 tools/crm_resource.c data_set); data_set 60 tools/crm_resource.h void cli_resource_print_cts_constraints(pe_working_set_t * data_set); data_set 62 tools/crm_resource.h int cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded); data_set 64 tools/crm_resource.h bool active, pe_working_set_t * data_set); data_set 69 tools/crm_resource.h const char *rsc_id, pe_working_set_t *data_set); data_set 71 tools/crm_resource.h pe_working_set_t *data_set); data_set 75 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 78 tools/crm_resource.h pe_working_set_t *data_set); data_set 84 tools/crm_resource.h pe_working_set_t *data_set, gboolean promoted_role_only, data_set 94 tools/crm_resource.h int timeout_ms, cib_t *cib, pe_working_set_t *data_set, data_set 102 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 107 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 109 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 91 tools/crm_resource_print.c bool active, pe_working_set_t * data_set) data_set 93 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 95 tools/crm_resource_print.c GList *ops = find_operations(rsc_id, host_uname, active, data_set); data_set 106 tools/crm_resource_print.c out->message(out, "node-and-op", data_set, xml_op); data_set 115 tools/crm_resource_print.c cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded) data_set 117 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 69 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 286 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 288 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 401 tools/crm_resource_runtime.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 404 tools/crm_resource_runtime.c unpack_constraints(cib_constraints, data_set); data_set 406 tools/crm_resource_runtime.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 421 tools/crm_resource_runtime.c cib, cib_options, data_set, force); data_set 436 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 438 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 504 tools/crm_resource_runtime.c const char *host_uname, const char *rsc_id, pe_working_set_t *data_set) data_set 506 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 514 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 534 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, host_uname); data_set 597 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 606 tools/crm_resource_runtime.c rc = send_lrm_rsc_op(controld_api, false, host_uname, rsc_id, data_set); data_set 624 tools/crm_resource_runtime.c const char *interval_spec, pe_working_set_t *data_set) data_set 645 tools/crm_resource_runtime.c for (xmlNode *xml_op = pcmk__xml_first_child(data_set->failed); data_set 657 tools/crm_resource_runtime.c pe_resource_t *fail_rsc = pe_find_resource_with_flags(data_set->resources, data_set 692 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, node_name, failed_id, data_set); data_set 725 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 727 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 741 tools/crm_resource_runtime.c interval_spec, just_failures, data_set, data_set 754 tools/crm_resource_runtime.c nodes = pcmk__copy_node_list(data_set->nodes, false); data_set 777 tools/crm_resource_runtime.c just_failures, data_set, force); data_set 789 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); data_set 818 tools/crm_resource_runtime.c interval_spec, data_set); data_set 820 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, host_uname, rsc->id, data_set); data_set 835 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 837 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 849 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, node_name); data_set 870 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 877 tools/crm_resource_runtime.c for (GList *iter = data_set->nodes; iter; iter = iter->next) { data_set 881 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 924 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 927 tools/crm_resource_runtime.c return send_lrm_rsc_op(controld_api, true, host_uname, rsc_id, data_set); data_set 932 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 943 tools/crm_resource_runtime.c params = pe_rsc_params(rsc, node, data_set); data_set 952 tools/crm_resource_runtime.c get_meta_attributes(meta, rsc, node, data_set); data_set 1072 tools/crm_resource_runtime.c update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml) data_set 1077 tools/crm_resource_runtime.c data_set->input = *xml; data_set 1078 tools/crm_resource_runtime.c data_set->now = crm_time_new(NULL); data_set 1094 tools/crm_resource_runtime.c update_working_set_from_cib(pcmk__output_t *out, pe_working_set_t * data_set, data_set 1107 tools/crm_resource_runtime.c rc = update_working_set_xml(data_set, &cib_xml_copy); data_set 1119 tools/crm_resource_runtime.c update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate) data_set 1126 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1128 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1129 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1147 tools/crm_resource_runtime.c rc = write_xml_file(data_set->input, shadow_file, FALSE); data_set 1162 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set, data_set->input, NULL); data_set 1166 tools/crm_resource_runtime.c run_simulation(data_set, shadow_cib, NULL); data_set 1169 tools/crm_resource_runtime.c rc = update_dataset(shadow_cib, data_set, FALSE); data_set 1172 tools/crm_resource_runtime.c cluster_status(data_set); data_set 1189 tools/crm_resource_runtime.c max_delay_for_resource(pe_working_set_t * data_set, pe_resource_t *rsc) data_set 1200 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, child); data_set 1210 tools/crm_resource_runtime.c pe_action_t *stop = custom_action(rsc, key, RSC_STOP, NULL, TRUE, FALSE, data_set); data_set 1227 tools/crm_resource_runtime.c max_delay_in(pe_working_set_t * data_set, GList *resources) data_set 1234 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, (const char *)item->data); data_set 1236 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, rsc); data_set 1286 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1321 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1322 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1328 tools/crm_resource_runtime.c data_set->priv = out; data_set 1329 tools/crm_resource_runtime.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 1330 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1337 tools/crm_resource_runtime.c restart_target_active = get_active_resources(host, data_set->resources); data_set 1338 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1361 tools/crm_resource_runtime.c data_set, force); data_set 1374 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, TRUE); data_set 1380 tools/crm_resource_runtime.c target_active = get_active_resources(host, data_set->resources); data_set 1391 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1401 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1410 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1435 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1441 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1461 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1473 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1486 tools/crm_resource_runtime.c current_active = get_active_resources(NULL, data_set->resources); data_set 1512 tools/crm_resource_runtime.c FALSE, cib, cib_options, data_set, force); data_set 1517 tools/crm_resource_runtime.c data_set, force); data_set 1534 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1615 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1622 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1623 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1626 tools/crm_resource_runtime.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 1635 tools/crm_resource_runtime.c print_pending_actions(out, data_set->actions); data_set 1636 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1644 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1645 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1647 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1650 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set, data_set->input, NULL); data_set 1661 tools/crm_resource_runtime.c const char *dc_version = g_hash_table_lookup(data_set->config_hash, data_set 1671 tools/crm_resource_runtime.c } while (actions_are_pending(data_set->actions)); data_set 1673 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1825 tools/crm_resource_runtime.c int timeout_ms, cib_t * cib, pe_working_set_t *data_set, data_set 1828 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1839 tools/crm_resource_runtime.c GList *nodes = cli_resource_search(rsc, requested_name, data_set); data_set 1870 tools/crm_resource_runtime.c data_set); data_set 1873 tools/crm_resource_runtime.c timeout_ms = pe_get_configured_timeout(rsc, get_action(rsc_action), data_set); data_set 1888 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean promoted_role_only, data_set 1891 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1895 tools/crm_resource_runtime.c pe_node_t *dest = pe_find_node(data_set->nodes, host_name); data_set 1959 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, NULL, data_set->nodes, cib, cib_options, FALSE, force); data_set 1962 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib, data_set 39 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 105 tools/crm_rule.c crm_rule_check(pe_working_set_t *data_set, const char *rule_id, crm_time_t *effective_date) data_set 115 tools/crm_rule.c cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 231 tools/crm_rule.c pe_working_set_t *data_set = NULL; data_set 327 tools/crm_rule.c data_set = pe_new_working_set(); data_set 328 tools/crm_rule.c if (data_set == NULL) { data_set 332 tools/crm_rule.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 334 tools/crm_rule.c data_set->input = input; data_set 335 tools/crm_rule.c data_set->now = rule_date; data_set 338 tools/crm_rule.c cluster_status(data_set); data_set 346 tools/crm_rule.c rc = crm_rule_check(data_set, options.rule, rule_date); data_set 367 tools/crm_rule.c pe_free_working_set(data_set); data_set 368 tools/crm_simulate.c get_date(pe_working_set_t *data_set, bool print_original, char *use_date) data_set 370 tools/crm_simulate.c pcmk__output_t *out = data_set->priv; data_set 373 tools/crm_simulate.c crm_element_value_epoch(data_set->input, "execution-date", &original_date); data_set 376 tools/crm_simulate.c data_set->now = crm_time_new(use_date); data_set 378 tools/crm_simulate.c crm_time_log(LOG_NOTICE, "Pretending 'now' is", data_set->now, data_set 384 tools/crm_simulate.c data_set->now = crm_time_new(NULL); data_set 385 tools/crm_simulate.c crm_time_set_timet(data_set->now, &original_date); data_set 388 tools/crm_simulate.c char *when = crm_time_as_string(data_set->now, data_set 398 tools/crm_simulate.c print_cluster_status(pe_working_set_t * data_set, unsigned int show_opts) data_set 400 tools/crm_simulate.c pcmk__output_t *out = data_set->priv; data_set 406 tools/crm_simulate.c rc = out->message(out, "node-list", data_set->nodes, all, all, show_opts); data_set 408 tools/crm_simulate.c rc = out->message(out, "resource-list", data_set, show_opts | pcmk_show_inactive_rscs, data_set 412 tools/crm_simulate.c rc = out->message(out, "node-attribute-list", data_set, data_set 417 tools/crm_simulate.c rc = out->message(out, "node-summary", data_set, all, all, data_set 420 tools/crm_simulate.c out->message(out, "failed-action-list", data_set, all, all, data_set 505 tools/crm_simulate.c create_dotfile(pe_working_set_t * data_set, const char *dot_file, gboolean all_actions, data_set 519 tools/crm_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 564 tools/crm_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 691 tools/crm_simulate.c profile_one(const char *xml_file, long long repeat, pe_working_set_t *data_set, char *use_date) data_set 693 tools/crm_simulate.c pcmk__output_t *out = data_set->priv; data_set 719 tools/crm_simulate.c data_set->input = input; data_set 720 tools/crm_simulate.c get_date(data_set, false, use_date); data_set 721 tools/crm_simulate.c pcmk__schedule_actions(data_set, input, NULL); data_set 722 tools/crm_simulate.c pe_reset_working_set(data_set); data_set 734 tools/crm_simulate.c profile_all(const char *dir, long long repeat, pe_working_set_t *data_set, char *use_date) data_set 736 tools/crm_simulate.c pcmk__output_t *out = data_set->priv; data_set 759 tools/crm_simulate.c profile_one(buffer, repeat, data_set, use_date); data_set 860 tools/crm_simulate.c pe_working_set_t *data_set = NULL; data_set 917 tools/crm_simulate.c data_set = pe_new_working_set(); data_set 918 tools/crm_simulate.c if (data_set == NULL) { data_set 925 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 928 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 930 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_no_compat); data_set 933 tools/crm_simulate.c data_set->priv = out; data_set 934 tools/crm_simulate.c profile_all(options.test_dir, options.repeat, data_set, options.use_date); data_set 961 tools/crm_simulate.c data_set->input = input; data_set 962 tools/crm_simulate.c data_set->priv = out; data_set 963 tools/crm_simulate.c get_date(data_set, true, options.use_date); data_set 965 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_sanitized); data_set 968 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 971 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 973 tools/crm_simulate.c cluster_status(data_set); data_set 978 tools/crm_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 979 tools/crm_simulate.c printed = out->message(out, "maint-mode", data_set->flags); data_set 982 tools/crm_simulate.c if (data_set->disabled_resources || data_set->blocked_resources) { data_set 986 tools/crm_simulate.c data_set->disabled_resources, data_set->ninstances, data_set 987 tools/crm_simulate.c data_set->blocked_resources); data_set 995 tools/crm_simulate.c print_cluster_status(data_set, show_opts); data_set 1002 tools/crm_simulate.c modify_configuration(data_set, global_cib, options.quorum, options.watchdog, options.node_up, data_set 1016 tools/crm_simulate.c cleanup_calculations(data_set); data_set 1017 tools/crm_simulate.c data_set->input = input; data_set 1018 tools/crm_simulate.c data_set->priv = out; data_set 1019 tools/crm_simulate.c get_date(data_set, true, options.use_date); data_set 1022 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_sanitized); data_set 1025 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 1028 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 1030 tools/crm_simulate.c cluster_status(data_set); data_set 1047 tools/crm_simulate.c if (pcmk_all_flags_set(data_set->flags, pe_flag_show_scores|pe_flag_show_utilization)) { data_set 1051 tools/crm_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_scores)) { data_set 1055 tools/crm_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 1065 tools/crm_simulate.c data_set->priv = logger_out; data_set 1068 tools/crm_simulate.c pcmk__schedule_actions(data_set, input, local_date); data_set 1075 tools/crm_simulate.c data_set->priv = out; data_set 1081 tools/crm_simulate.c write_xml_file(data_set->graph, options.graph_file, FALSE); data_set 1085 tools/crm_simulate.c if (!create_dotfile(data_set, options.dot_file, options.all_actions, &error)) { data_set 1096 tools/crm_simulate.c LogNodeActions(data_set); data_set 1097 tools/crm_simulate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1100 tools/crm_simulate.c LogActions(rsc, data_set); data_set 1112 tools/crm_simulate.c if (run_simulation(data_set, global_cib, options.op_fail) != pcmk_rc_ok) { data_set 1119 tools/crm_simulate.c get_date(data_set, true, options.use_date); data_set 1125 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 1128 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 1131 tools/crm_simulate.c cluster_status(data_set); data_set 1132 tools/crm_simulate.c print_cluster_status(data_set, 0); data_set 1164 tools/crm_simulate.c if (data_set) { data_set 1165 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 849 tools/crm_ticket.c data_set = pe_new_working_set(); data_set 850 tools/crm_ticket.c if (data_set == NULL) { data_set 855 tools/crm_ticket.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 889 tools/crm_ticket.c data_set->input = cib_xml_copy; data_set 890 tools/crm_ticket.c data_set->now = crm_time_new(NULL); data_set 892 tools/crm_ticket.c cluster_status(data_set); data_set 896 tools/crm_ticket.c cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 897 tools/crm_ticket.c unpack_constraints(cib_constraints, data_set); data_set 910 tools/crm_ticket.c pe_ticket_t *ticket = find_ticket(ticket_id, data_set); data_set 920 tools/crm_ticket.c rc = print_ticket_list(data_set, raw, details); data_set 950 tools/crm_ticket.c rc = get_ticket_state_attr(ticket_id, get_attr_name, &value, data_set); data_set 969 tools/crm_ticket.c ticket = find_ticket(ticket_id, data_set); data_set 1016 tools/crm_ticket.c rc = modify_ticket_state(ticket_id, attr_delete, attr_set, cib_conn, data_set); data_set 1062 tools/crm_ticket.c pe_free_working_set(data_set); data_set 1063 tools/crm_ticket.c data_set = NULL; data_set 47 tools/crm_verify.c extern gboolean stage0(pe_working_set_t * data_set); data_set 109 tools/crm_verify.c pe_working_set_t *data_set = NULL; data_set 236 tools/crm_verify.c data_set = pe_new_working_set(); data_set 237 tools/crm_verify.c if (data_set == NULL) { data_set 242 tools/crm_verify.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 243 tools/crm_verify.c data_set->priv = out; data_set 248 tools/crm_verify.c pcmk__schedule_actions(data_set, cib_object, NULL); data_set 251 tools/crm_verify.c data_set->now = crm_time_new(NULL); data_set 252 tools/crm_verify.c data_set->input = cib_object; data_set 253 tools/crm_verify.c stage0(data_set); data_set 255 tools/crm_verify.c pe_free_working_set(data_set);