data_set 446 daemons/execd/cts-exec-helper.c pe_working_set_t *data_set = NULL; data_set 471 daemons/execd/cts-exec-helper.c data_set = pe_new_working_set(); data_set 472 daemons/execd/cts-exec-helper.c if (data_set == NULL) { data_set 476 daemons/execd/cts-exec-helper.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 477 daemons/execd/cts-exec-helper.c data_set->input = cib_xml_copy; data_set 478 daemons/execd/cts-exec-helper.c data_set->now = crm_time_new(NULL); data_set 479 daemons/execd/cts-exec-helper.c cluster_status(data_set); data_set 482 daemons/execd/cts-exec-helper.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 486 daemons/execd/cts-exec-helper.c pe_free_working_set(data_set); data_set 491 daemons/execd/cts-exec-helper.c params = pe_rsc_params(rsc, NULL, data_set); data_set 502 daemons/execd/cts-exec-helper.c get_meta_attributes(meta, rsc, NULL, data_set); data_set 513 daemons/execd/cts-exec-helper.c pe_free_working_set(data_set); data_set 681 daemons/fenced/pacemaker-fenced.c cib_device_update(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 692 daemons/fenced/pacemaker-fenced.c cib_device_update(gIter->data, data_set); data_set 762 daemons/fenced/pacemaker-fenced.c rsc_params = pe_rsc_params(rsc, node, data_set); data_set 763 daemons/fenced/pacemaker-fenced.c get_meta_attributes(rsc->meta, rsc, node, data_set); data_set 28 daemons/schedulerd/schedulerd_messages.c pe_working_set_t *data_set = pe_new_working_set(); data_set 30 daemons/schedulerd/schedulerd_messages.c CRM_ASSERT(data_set != NULL); data_set 38 daemons/schedulerd/schedulerd_messages.c data_set->priv = logger_out; data_set 39 daemons/schedulerd/schedulerd_messages.c return data_set; data_set 75 daemons/schedulerd/schedulerd_messages.c pe_working_set_t *data_set = init_working_set(); data_set 84 daemons/schedulerd/schedulerd_messages.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 85 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(data_set->graph, "transition_id", 0); data_set 86 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(data_set->graph, "cluster-delay", 0); data_set 103 daemons/schedulerd/schedulerd_messages.c |pe_flag_show_utilization, data_set); data_set 115 daemons/schedulerd/schedulerd_messages.c value = pe_pref(data_set->config_hash, series[series_id].param); data_set 129 daemons/schedulerd/schedulerd_messages.c data_set->input = NULL; data_set 130 daemons/schedulerd/schedulerd_messages.c reply = create_reply(msg, data_set->graph); data_set 175 daemons/schedulerd/schedulerd_messages.c pe_free_working_set(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 const pe_node_t *node, pe_working_set_t *data_set); data_set 240 include/crm/pengine/internal.h bool pe_can_fence(pe_working_set_t *data_set, pe_node_t *node); data_set 245 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 252 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 254 include/crm/pengine/internal.h gboolean native_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 255 include/crm/pengine/internal.h gboolean group_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 256 include/crm/pengine/internal.h gboolean clone_unpack(pe_resource_t * rsc, pe_working_set_t * data_set); data_set 257 include/crm/pengine/internal.h gboolean pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set); data_set 338 include/crm/pengine/internal.h extern time_t get_effective_time(pe_working_set_t * data_set); data_set 351 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 355 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 386 include/crm/pengine/internal.h extern pe_action_t *get_pseudo_op(const char *name, pe_working_set_t * data_set); data_set 392 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 394 include/crm/pengine/internal.h #define pe__show_node_weights(level, rsc, text, nodes, data_set) \ data_set 396 include/crm/pengine/internal.h (level), (rsc), (text), (nodes), (data_set)) data_set 402 include/crm/pengine/internal.h gboolean foo, pe_working_set_t *data_set); data_set 451 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 467 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 477 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 480 include/crm/pengine/internal.h extern pe_ticket_t *ticket_new(const char *ticket_id, pe_working_set_t * data_set); data_set 530 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 535 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 537 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 539 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 547 include/crm/pengine/internal.h void pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag); data_set 555 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 558 include/crm/pengine/internal.h const char *score, pe_working_set_t * data_set); data_set 568 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 570 include/crm/pengine/internal.h pe_working_set_t *data_set, data_set 577 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 579 include/crm/pengine/internal.h enum pe_check_parameters, pe_working_set_t *data_set); data_set 580 include/crm/pengine/internal.h void pe__foreach_param_check(pe_working_set_t *data_set, data_set 584 include/crm/pengine/internal.h void pe__free_param_checks(pe_working_set_t *data_set); data_set 587 include/crm/pengine/internal.h void pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set); data_set 600 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 604 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 606 include/crm/pengine/internal.h GList *pe__rscs_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 607 include/crm/pengine/internal.h GList *pe__unames_with_tag(pe_working_set_t *data_set, const char *tag_name); data_set 608 include/crm/pengine/internal.h bool pe__rsc_has_tag(pe_working_set_t *data_set, const char *rsc, const char *tag); data_set 609 include/crm/pengine/internal.h bool pe__uname_has_tag(pe_working_set_t *data_set, const char *node, const char *tag); data_set 613 include/crm/pengine/internal.h GList * pe__build_node_name_list(pe_working_set_t *data_set, const char *s); data_set 614 include/crm/pengine/internal.h GList * pe__build_rsc_list(pe_working_set_t *data_set, const char *s); data_set 631 include/crm/pengine/internal.h pe__health_strategy(pe_working_set_t *data_set) data_set 633 include/crm/pengine/internal.h return pcmk__parse_health_strategy(pe_pref(data_set->config_hash, data_set 638 include/crm/pengine/internal.h pe__health_score(const char *option, pe_working_set_t *data_set) data_set 640 include/crm/pengine/internal.h return char2score(pe_pref(data_set->config_hash, option)); data_set 245 include/crm/pengine/pe_types.h pe_working_set_t *data_set; //!< Cluster that this node is part of 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 140 include/pacemaker.h pe_working_set_t *data_set); data_set 171 include/pacemaker.h int pcmk_simulate(xmlNodePtr *xml, pe_working_set_t *data_set, data_set 53 include/pcmki/pcmki_sched_allocate.h pe_working_set_t *data_set); data_set 35 include/pcmki/pcmki_scheduler.h void pcmk__unpack_constraints(pe_working_set_t *data_set); data_set 38 include/pcmki/pcmki_scheduler.h pe_working_set_t *data_set); data_set 36 include/pcmki/pcmki_simulate.h void pcmk__profile_dir(const char *dir, long long repeat, pe_working_set_t *data_set, data_set 49 include/pcmki/pcmki_simulate.h enum pcmk__graph_status pcmk__simulate_transition(pe_working_set_t *data_set, data_set 84 include/pcmki/pcmki_simulate.h int pcmk__simulate(pe_working_set_t *data_set, pcmk__output_t *out, data_set 39 include/pcmki/pcmki_status.h int pcmk__output_simple_status(pcmk__output_t *out, pe_working_set_t *data_set); data_set 182 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 238 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 244 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 263 lib/pacemaker/libpacemaker_private.h void pcmk__output_actions(pe_working_set_t *data_set); data_set 270 lib/pacemaker/libpacemaker_private.h void pcmk__handle_rsc_config_changes(pe_working_set_t *data_set); data_set 301 lib/pacemaker/libpacemaker_private.h void pcmk__create_graph(pe_working_set_t *data_set); data_set 307 lib/pacemaker/libpacemaker_private.h void pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set); data_set 325 lib/pacemaker/libpacemaker_private.h void pcmk__inject_scheduler_input(pe_working_set_t *data_set, cib_t *cib, data_set 336 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 339 lib/pacemaker/libpacemaker_private.h bool pcmk__valid_resource_or_tag(pe_working_set_t *data_set, const char *id, data_set 344 lib/pacemaker/libpacemaker_private.h bool convert_rsc, pe_working_set_t *data_set); data_set 347 lib/pacemaker/libpacemaker_private.h void pcmk__create_internal_constraints(pe_working_set_t *data_set); data_set 353 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 359 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 362 lib/pacemaker/libpacemaker_private.h void pcmk__apply_locations(pe_working_set_t *data_set); data_set 398 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_colocation(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 410 lib/pacemaker/libpacemaker_private.h bool influence, pe_working_set_t *data_set); data_set 414 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 467 lib/pacemaker/libpacemaker_private.h uint32_t flags, pe_working_set_t *data_set); data_set 470 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_ordering(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 473 lib/pacemaker/libpacemaker_private.h void pcmk__disable_invalid_orderings(pe_working_set_t *data_set); data_set 480 lib/pacemaker/libpacemaker_private.h void pcmk__apply_orderings(pe_working_set_t *data_set); data_set 518 lib/pacemaker/libpacemaker_private.h void pcmk__unpack_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set); data_set 558 lib/pacemaker/libpacemaker_private.h void pcmk__order_remote_connection_actions(pe_working_set_t *data_set); data_set 640 lib/pacemaker/libpacemaker_private.h pe_working_set_t *data_set); data_set 719 lib/pacemaker/libpacemaker_private.h void pcmk__apply_node_health(pe_working_set_t *data_set); data_set 729 lib/pacemaker/libpacemaker_private.h void pcmk__set_allocation_methods(pe_working_set_t *data_set); data_set 736 lib/pacemaker/libpacemaker_private.h GList *pcmk__rscs_matching_id(const char *id, pe_working_set_t *data_set); data_set 763 lib/pacemaker/libpacemaker_private.h void pcmk__sort_resources(pe_working_set_t *data_set); data_set 778 lib/pacemaker/libpacemaker_private.h void pcmk__order_probes(pe_working_set_t *data_set); data_set 784 lib/pacemaker/libpacemaker_private.h void pcmk__schedule_probes(pe_working_set_t *data_set); data_set 821 lib/pacemaker/libpacemaker_private.h void pcmk__show_node_capacities(const char *desc, pe_working_set_t *data_set); data_set 77 lib/pacemaker/pcmk_graph_producer.c add_maintenance_nodes(xmlNode *xml, const pe_working_set_t *data_set) data_set 84 lib/pacemaker/pcmk_graph_producer.c for (gIter = data_set->nodes; gIter != NULL; data_set 114 lib/pacemaker/pcmk_graph_producer.c add_maintenance_update(pe_working_set_t *data_set) data_set 118 lib/pacemaker/pcmk_graph_producer.c if (add_maintenance_nodes(NULL, data_set)) { data_set 120 lib/pacemaker/pcmk_graph_producer.c action = get_pseudo_op(CRM_OP_MAINTENANCE_NODES, data_set); data_set 139 lib/pacemaker/pcmk_graph_producer.c const pe_working_set_t *data_set) data_set 141 lib/pacemaker/pcmk_graph_producer.c CRM_CHECK(xml && action && action->node && data_set, return); data_set 157 lib/pacemaker/pcmk_graph_producer.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); data_set 388 lib/pacemaker/pcmk_graph_producer.c pe_working_set_t *data_set) data_set 394 lib/pacemaker/pcmk_graph_producer.c if ((action == NULL) || (data_set == NULL)) { data_set 472 lib/pacemaker/pcmk_graph_producer.c add_downed_nodes(action_xml, action, data_set); data_set 476 lib/pacemaker/pcmk_graph_producer.c add_maintenance_nodes(action_xml, data_set); data_set 837 lib/pacemaker/pcmk_graph_producer.c create_graph_synapse(pe_action_t *action, pe_working_set_t *data_set) data_set 840 lib/pacemaker/pcmk_graph_producer.c xmlNode *syn = create_xml_node(data_set->graph, "synapse"); data_set 842 lib/pacemaker/pcmk_graph_producer.c crm_xml_add_int(syn, XML_ATTR_ID, data_set->num_synapse); data_set 843 lib/pacemaker/pcmk_graph_producer.c data_set->num_synapse++; data_set 877 lib/pacemaker/pcmk_graph_producer.c pe_working_set_t *data_set = (pe_working_set_t *) user_data; data_set 903 lib/pacemaker/pcmk_graph_producer.c syn = create_graph_synapse(action, data_set); data_set 907 lib/pacemaker/pcmk_graph_producer.c create_graph_action(set, action, false, data_set); data_set 916 lib/pacemaker/pcmk_graph_producer.c create_graph_action(input_xml, input->action, true, data_set); data_set 988 lib/pacemaker/pcmk_graph_producer.c pcmk__create_graph(pe_working_set_t *data_set) data_set 997 lib/pacemaker/pcmk_graph_producer.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 999 lib/pacemaker/pcmk_graph_producer.c value = pe_pref(data_set->config_hash, "cluster-delay"); data_set 1000 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "cluster-delay", value); data_set 1002 lib/pacemaker/pcmk_graph_producer.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 1003 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "stonith-timeout", value); data_set 1005 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "failed-stop-offset", "INFINITY"); data_set 1007 lib/pacemaker/pcmk_graph_producer.c if (pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)) { data_set 1008 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "failed-start-offset", "INFINITY"); data_set 1010 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "failed-start-offset", "1"); data_set 1013 lib/pacemaker/pcmk_graph_producer.c value = pe_pref(data_set->config_hash, "batch-limit"); data_set 1014 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "batch-limit", value); data_set 1016 lib/pacemaker/pcmk_graph_producer.c crm_xml_add_int(data_set->graph, "transition_id", transition_id); data_set 1018 lib/pacemaker/pcmk_graph_producer.c value = pe_pref(data_set->config_hash, "migration-limit"); data_set 1020 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "migration-limit", value); data_set 1023 lib/pacemaker/pcmk_graph_producer.c if (data_set->recheck_by > 0) { data_set 1027 lib/pacemaker/pcmk_graph_producer.c (long long) data_set->recheck_by); data_set 1028 lib/pacemaker/pcmk_graph_producer.c crm_xml_add(data_set->graph, "recheck-by", recheck_epoch); data_set 1038 lib/pacemaker/pcmk_graph_producer.c for (iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 1046 lib/pacemaker/pcmk_graph_producer.c add_maintenance_update(data_set); data_set 1049 lib/pacemaker/pcmk_graph_producer.c for (iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 1063 lib/pacemaker/pcmk_graph_producer.c if (pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 1064 lib/pacemaker/pcmk_graph_producer.c || (data_set->no_quorum_policy == no_quorum_ignore)) { data_set 1074 lib/pacemaker/pcmk_graph_producer.c add_action_to_graph((gpointer) action, (gpointer) data_set); data_set 1077 lib/pacemaker/pcmk_graph_producer.c crm_log_xml_trace(data_set->graph, "graph"); data_set 522 lib/pacemaker/pcmk_injections.c pe_working_set_t *data_set) data_set 556 lib/pacemaker/pcmk_injections.c rsc = pe_find_resource(data_set->resources, resource); data_set 602 lib/pacemaker/pcmk_injections.c pcmk__inject_scheduler_input(pe_working_set_t *data_set, cib_t *cib, data_set 608 lib/pacemaker/pcmk_injections.c pcmk__output_t *out = data_set->priv; data_set 723 lib/pacemaker/pcmk_injections.c inject_action(out, (char *) iter->data, cib, data_set); data_set 556 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 560 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(data_set); data_set 569 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 572 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 583 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 587 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(data_set); data_set 597 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 600 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 1616 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1629 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "cluster-summary", data_set, data_set 1633 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-list", data_set->nodes, unames, data_set 1639 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "resource-list", data_set, show_opts, data_set 1645 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-attribute-list", data_set, data_set 1653 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "node-summary", data_set, unames, data_set 1659 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1661 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "failed-action-list", data_set, unames, data_set 1690 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ticket-list", data_set, rc == pcmk_rc_ok)); data_set 1695 lib/pacemaker/pcmk_output.c CHECK_RC(rc, out->message(out, "ban-list", data_set, prefix, resources, data_set 1739 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1749 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1753 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, data_set 1762 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, full_show_opts, data_set 1768 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, false, data_set 1776 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1782 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1784 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1797 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, false); data_set 1802 lib/pacemaker/pcmk_output.c out->message(out, "ban-list", data_set, prefix, resources, show_opts, data_set 1815 lib/pacemaker/pcmk_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1826 lib/pacemaker/pcmk_output.c out->message(out, "cluster-summary", data_set, section_opts, show_opts); data_set 1830 lib/pacemaker/pcmk_output.c out->message(out, "node-list", data_set->nodes, unames, resources, data_set 1836 lib/pacemaker/pcmk_output.c out->message(out, "resource-list", data_set, show_opts, true, unames, data_set 1842 lib/pacemaker/pcmk_output.c out->message(out, "node-attribute-list", data_set, show_opts, false, data_set 1850 lib/pacemaker/pcmk_output.c out->message(out, "node-summary", data_set, unames, data_set 1856 lib/pacemaker/pcmk_output.c && xml_has_children(data_set->failed)) { data_set 1858 lib/pacemaker/pcmk_output.c out->message(out, "failed-action-list", data_set, unames, resources, data_set 1911 lib/pacemaker/pcmk_output.c out->message(out, "ticket-list", data_set, false); data_set 1916 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 43 lib/pacemaker/pcmk_resource.c history = get_xpath_object(xpath, data_set->input, LOG_NEVER); data_set 159 lib/pacemaker/pcmk_resource.c pe_working_set_t *data_set) data_set 61 lib/pacemaker/pcmk_rule.c pe_working_set_t **data_set) data_set 104 lib/pacemaker/pcmk_rule.c *data_set = new_data_set; data_set 122 lib/pacemaker/pcmk_rule.c eval_rule(pe_working_set_t *data_set, const char *rule_id, const char **error) data_set 134 lib/pacemaker/pcmk_rule.c cib_constraints = pcmk_find_cib_element(data_set->input, data_set 219 lib/pacemaker/pcmk_rule.c rc = eval_date_expression(match, data_set->now); data_set 248 lib/pacemaker/pcmk_rule.c pe_working_set_t *data_set = NULL; data_set 258 lib/pacemaker/pcmk_rule.c rc = init_rule_check(out, input, date, &data_set); data_set 265 lib/pacemaker/pcmk_rule.c int last_rc = eval_rule(data_set, *rule_id, &error); data_set 274 lib/pacemaker/pcmk_rule.c pe_free_working_set(data_set); data_set 222 lib/pacemaker/pcmk_sched_actions.c pe_working_set_t *data_set) data_set 255 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 272 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 285 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 303 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 318 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 353 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 367 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 387 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 402 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 416 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 430 lib/pacemaker/pcmk_sched_actions.c data_set); data_set 500 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(pe_action_t *then, pe_working_set_t *data_set) data_set 615 lib/pacemaker/pcmk_sched_actions.c other, data_set); data_set 640 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(other->action, data_set); data_set 642 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(first, data_set); data_set 659 lib/pacemaker/pcmk_sched_actions.c pcmk__block_colocation_dependents(then, data_set); data_set 661 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(then, data_set); data_set 665 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(other->action, data_set); data_set 838 lib/pacemaker/pcmk_sched_actions.c pe_working_set_t *data_set) data_set 931 lib/pacemaker/pcmk_sched_actions.c pcmk__update_action_for_orderings(then, data_set); data_set 1062 lib/pacemaker/pcmk_sched_actions.c TRUE, node->details->data_set); data_set 1389 lib/pacemaker/pcmk_sched_actions.c pcmk__output_actions(pe_working_set_t *data_set) data_set 1391 lib/pacemaker/pcmk_sched_actions.c pcmk__output_t *out = data_set->priv; data_set 1394 lib/pacemaker/pcmk_sched_actions.c for (GList *iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 1433 lib/pacemaker/pcmk_sched_actions.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 1501 lib/pacemaker/pcmk_sched_actions.c pe_working_set_t *data_set) data_set 1505 lib/pacemaker/pcmk_sched_actions.c if (!pcmk_is_set(data_set->flags, pe_flag_sanitized)) { data_set 1857 lib/pacemaker/pcmk_sched_actions.c process_node_history(pe_node_t *node, xmlNode *lrm_rscs, pe_working_set_t *data_set) data_set 1864 lib/pacemaker/pcmk_sched_actions.c GList *result = pcmk__rscs_matching_id(ID(rsc_entry), data_set); data_set 1896 lib/pacemaker/pcmk_sched_actions.c pcmk__handle_rsc_config_changes(pe_working_set_t *data_set) data_set 1904 lib/pacemaker/pcmk_sched_actions.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 1918 lib/pacemaker/pcmk_sched_actions.c history = get_xpath_object(xpath, data_set->input, LOG_NEVER); data_set 1921 lib/pacemaker/pcmk_sched_actions.c process_node_history(node, history, data_set); data_set 44 lib/pacemaker/pcmk_sched_allocate.c enum pe_check_parameters check, pe_working_set_t *data_set) data_set 53 lib/pacemaker/pcmk_sched_allocate.c data_set)) { data_set 59 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, rsc_op, node, data_set); data_set 75 lib/pacemaker/pcmk_sched_allocate.c pe__clear_failcount(rsc, node, reason, data_set); data_set 177 lib/pacemaker/pcmk_sched_allocate.c apply_stickiness(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 183 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(rsc->children, (GFunc) apply_stickiness, data_set); data_set 225 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_locks(pe_working_set_t *data_set) data_set 227 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 230 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 244 lib/pacemaker/pcmk_sched_allocate.c count_available_nodes(pe_working_set_t *data_set) data_set 246 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_no_compat)) { data_set 251 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 256 lib/pacemaker/pcmk_sched_allocate.c data_set->max_valid_nodes++; data_set 259 lib/pacemaker/pcmk_sched_allocate.c crm_trace("Online node count: %d", data_set->max_valid_nodes); data_set 271 lib/pacemaker/pcmk_sched_allocate.c apply_node_criteria(pe_working_set_t *data_set) data_set 274 lib/pacemaker/pcmk_sched_allocate.c apply_shutdown_locks(data_set); data_set 275 lib/pacemaker/pcmk_sched_allocate.c count_available_nodes(data_set); data_set 276 lib/pacemaker/pcmk_sched_allocate.c pcmk__apply_locations(data_set); data_set 277 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(data_set->resources, (GFunc) apply_stickiness, data_set); data_set 279 lib/pacemaker/pcmk_sched_allocate.c for (GList *node_iter = data_set->nodes; node_iter != NULL; data_set 281 lib/pacemaker/pcmk_sched_allocate.c for (GList *rsc_iter = data_set->resources; rsc_iter != NULL; data_set 299 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(pe_working_set_t *data_set) data_set 305 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk__str_eq(data_set->placement_strategy, "default", pcmk__str_casei)) { data_set 306 lib/pacemaker/pcmk_sched_allocate.c pcmk__sort_resources(data_set); data_set 308 lib/pacemaker/pcmk_sched_allocate.c pcmk__show_node_capacities("Original", data_set); data_set 310 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 315 lib/pacemaker/pcmk_sched_allocate.c for (iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 327 lib/pacemaker/pcmk_sched_allocate.c for (iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 337 lib/pacemaker/pcmk_sched_allocate.c pcmk__show_node_capacities("Remaining", data_set); data_set 348 lib/pacemaker/pcmk_sched_allocate.c clear_failcounts_if_orphaned(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 359 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 367 lib/pacemaker/pcmk_sched_allocate.c data_set) == 0) { data_set 371 lib/pacemaker/pcmk_sched_allocate.c clear_op = pe__clear_failcount(rsc, node, "it is orphaned", data_set); data_set 377 lib/pacemaker/pcmk_sched_allocate.c NULL, pe_order_optional, data_set); data_set 388 lib/pacemaker/pcmk_sched_allocate.c schedule_resource_actions(pe_working_set_t *data_set) data_set 391 lib/pacemaker/pcmk_sched_allocate.c pe__foreach_param_check(data_set, check_params); data_set 392 lib/pacemaker/pcmk_sched_allocate.c pe__free_param_checks(data_set); data_set 394 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 396 lib/pacemaker/pcmk_sched_allocate.c pcmk__schedule_probes(data_set); data_set 399 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 400 lib/pacemaker/pcmk_sched_allocate.c g_list_foreach(data_set->resources, data_set 401 lib/pacemaker/pcmk_sched_allocate.c (GFunc) clear_failcounts_if_orphaned, data_set); data_set 405 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 443 lib/pacemaker/pcmk_sched_allocate.c any_managed_resources(pe_working_set_t *data_set) data_set 445 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 464 lib/pacemaker/pcmk_sched_allocate.c needs_fencing(pe_node_t *node, bool have_managed, pe_working_set_t *data_set) data_set 467 lib/pacemaker/pcmk_sched_allocate.c && pe_can_fence(data_set, node); data_set 500 lib/pacemaker/pcmk_sched_allocate.c add_nondc_fencing(GList *list, pe_action_t *action, pe_working_set_t *data_set) data_set 502 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing) data_set 522 lib/pacemaker/pcmk_sched_allocate.c schedule_fencing(pe_node_t *node, pe_working_set_t *data_set) data_set 525 lib/pacemaker/pcmk_sched_allocate.c FALSE, data_set); data_set 528 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_vs_fence(fencing, data_set); data_set 539 lib/pacemaker/pcmk_sched_allocate.c schedule_fencing_and_shutdowns(pe_working_set_t *data_set) data_set 543 lib/pacemaker/pcmk_sched_allocate.c bool have_managed = any_managed_resources(data_set); data_set 553 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 562 lib/pacemaker/pcmk_sched_allocate.c && pe_can_fence(data_set, node)) { data_set 568 lib/pacemaker/pcmk_sched_allocate.c if (needs_fencing(node, have_managed, data_set)) { data_set 569 lib/pacemaker/pcmk_sched_allocate.c fencing = schedule_fencing(node, data_set); data_set 575 lib/pacemaker/pcmk_sched_allocate.c fencing_ops = add_nondc_fencing(fencing_ops, fencing, data_set); data_set 597 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 602 lib/pacemaker/pcmk_sched_allocate.c } else if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 622 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)) { data_set 642 lib/pacemaker/pcmk_sched_allocate.c log_resource_details(pe_working_set_t *data_set) data_set 644 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *out = data_set->priv; data_set 654 lib/pacemaker/pcmk_sched_allocate.c for (GList *item = data_set->resources; item != NULL; item = item->next) { data_set 668 lib/pacemaker/pcmk_sched_allocate.c log_all_actions(pe_working_set_t *data_set) data_set 673 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_t *prev_out = data_set->priv; data_set 683 lib/pacemaker/pcmk_sched_allocate.c data_set->priv = out; data_set 686 lib/pacemaker/pcmk_sched_allocate.c pcmk__output_actions(data_set); data_set 691 lib/pacemaker/pcmk_sched_allocate.c data_set->priv = prev_out; data_set 701 lib/pacemaker/pcmk_sched_allocate.c log_unrunnable_actions(pe_working_set_t *data_set) data_set 706 lib/pacemaker/pcmk_sched_allocate.c for (GList *iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 724 lib/pacemaker/pcmk_sched_allocate.c unpack_cib(xmlNode *cib, unsigned long long flags, pe_working_set_t *data_set) data_set 728 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_have_status)) { data_set 730 lib/pacemaker/pcmk_sched_allocate.c pe__set_working_set_flags(data_set, flags); data_set 734 lib/pacemaker/pcmk_sched_allocate.c if (data_set->localhost) { data_set 735 lib/pacemaker/pcmk_sched_allocate.c localhost_save = data_set->localhost; data_set 746 lib/pacemaker/pcmk_sched_allocate.c set_working_set_defaults(data_set); data_set 749 lib/pacemaker/pcmk_sched_allocate.c data_set->localhost = localhost_save; data_set 752 lib/pacemaker/pcmk_sched_allocate.c pe__set_working_set_flags(data_set, flags); data_set 753 lib/pacemaker/pcmk_sched_allocate.c data_set->input = cib; data_set 754 lib/pacemaker/pcmk_sched_allocate.c cluster_status(data_set); // Sets pe_flag_have_status data_set 767 lib/pacemaker/pcmk_sched_allocate.c pe_working_set_t *data_set) data_set 769 lib/pacemaker/pcmk_sched_allocate.c unpack_cib(cib, flags, data_set); data_set 770 lib/pacemaker/pcmk_sched_allocate.c pcmk__set_allocation_methods(data_set); data_set 771 lib/pacemaker/pcmk_sched_allocate.c pcmk__apply_node_health(data_set); data_set 772 lib/pacemaker/pcmk_sched_allocate.c pcmk__unpack_constraints(data_set); data_set 773 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_check_config)) { data_set 777 lib/pacemaker/pcmk_sched_allocate.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location) && data_set 779 lib/pacemaker/pcmk_sched_allocate.c log_resource_details(data_set); data_set 782 lib/pacemaker/pcmk_sched_allocate.c apply_node_criteria(data_set); data_set 784 lib/pacemaker/pcmk_sched_allocate.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 788 lib/pacemaker/pcmk_sched_allocate.c pcmk__create_internal_constraints(data_set); data_set 789 lib/pacemaker/pcmk_sched_allocate.c pcmk__handle_rsc_config_changes(data_set); data_set 790 lib/pacemaker/pcmk_sched_allocate.c allocate_resources(data_set); data_set 791 lib/pacemaker/pcmk_sched_allocate.c schedule_resource_actions(data_set); data_set 796 lib/pacemaker/pcmk_sched_allocate.c pcmk__order_remote_connection_actions(data_set); data_set 798 lib/pacemaker/pcmk_sched_allocate.c schedule_fencing_and_shutdowns(data_set); data_set 799 lib/pacemaker/pcmk_sched_allocate.c pcmk__apply_orderings(data_set); data_set 800 lib/pacemaker/pcmk_sched_allocate.c log_all_actions(data_set); data_set 801 lib/pacemaker/pcmk_sched_allocate.c pcmk__create_graph(data_set); data_set 804 lib/pacemaker/pcmk_sched_allocate.c log_unrunnable_actions(data_set); data_set 36 lib/pacemaker/pcmk_sched_bundle.c int max, int per_host_max, pe_working_set_t * data_set); data_set 370 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 634 lib/pacemaker/pcmk_sched_bundle.c uint32_t type, pe_working_set_t *data_set) data_set 759 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 833 lib/pacemaker/pcmk_sched_bundle.c pe_working_set_t *data_set) data_set 841 lib/pacemaker/pcmk_sched_bundle.c type, data_set); data_set 849 lib/pacemaker/pcmk_sched_bundle.c filter, type, data_set); data_set 869 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 877 lib/pacemaker/pcmk_sched_bundle.c data_set); data_set 78 lib/pacemaker/pcmk_sched_clone.c int limit, pe_working_set_t *data_set) data_set 176 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set); data_set 180 lib/pacemaker/pcmk_sched_clone.c int max, int per_host_max, pe_working_set_t * data_set) data_set 244 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 269 lib/pacemaker/pcmk_sched_clone.c resource_location(child, NULL, -INFINITY, "clone:limit_reached", data_set); data_set 272 lib/pacemaker/pcmk_sched_clone.c data_set)) { data_set 446 lib/pacemaker/pcmk_sched_clone.c child_ordering_constraints(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 1022 lib/pacemaker/pcmk_sched_clone.c pe_working_set_t *data_set) data_set 25 lib/pacemaker/pcmk_sched_colocation.c __rsc = pcmk__find_constraint_resource(data_set->resources, __name); \ data_set 168 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 228 lib/pacemaker/pcmk_sched_colocation.c bool influence, pe_working_set_t *data_set) data_set 276 lib/pacemaker/pcmk_sched_colocation.c data_set->colocation_constraints = g_list_append(data_set->colocation_constraints, data_set 281 lib/pacemaker/pcmk_sched_colocation.c new_con->primary_role, data_set); data_set 283 lib/pacemaker/pcmk_sched_colocation.c new_con->dependent_role, data_set); data_set 318 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 358 lib/pacemaker/pcmk_sched_colocation.c influence_s), data_set); data_set 376 lib/pacemaker/pcmk_sched_colocation.c influence_s), data_set); data_set 410 lib/pacemaker/pcmk_sched_colocation.c influence, data_set); data_set 418 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 461 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 471 lib/pacemaker/pcmk_sched_colocation.c role_2, influence, data_set); data_set 482 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 502 lib/pacemaker/pcmk_sched_colocation.c data_set); data_set 510 lib/pacemaker/pcmk_sched_colocation.c const char *influence_s, pe_working_set_t *data_set) data_set 531 lib/pacemaker/pcmk_sched_colocation.c pe_resource_t *dependent = pcmk__find_constraint_resource(data_set->resources, data_set 533 lib/pacemaker/pcmk_sched_colocation.c pe_resource_t *primary = pcmk__find_constraint_resource(data_set->resources, data_set 572 lib/pacemaker/pcmk_sched_colocation.c dependent = find_clone_instance(dependent, dependent_instance, data_set); data_set 582 lib/pacemaker/pcmk_sched_colocation.c primary = find_clone_instance(primary, primary_instance, data_set); data_set 603 lib/pacemaker/pcmk_sched_colocation.c unpack_influence(id, dependent, influence_s), data_set); data_set 609 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 639 lib/pacemaker/pcmk_sched_colocation.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 651 lib/pacemaker/pcmk_sched_colocation.c if (!pcmk__valid_resource_or_tag(data_set, dependent_id, &dependent, data_set 658 lib/pacemaker/pcmk_sched_colocation.c if (!pcmk__valid_resource_or_tag(data_set, primary_id, &primary, data_set 684 lib/pacemaker/pcmk_sched_colocation.c true, data_set)) { data_set 701 lib/pacemaker/pcmk_sched_colocation.c true, data_set)) { data_set 734 lib/pacemaker/pcmk_sched_colocation.c pcmk__unpack_colocation(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 753 lib/pacemaker/pcmk_sched_colocation.c data_set) != pcmk_rc_ok) { data_set 764 lib/pacemaker/pcmk_sched_colocation.c set = expand_idref(set, data_set->input); data_set 772 lib/pacemaker/pcmk_sched_colocation.c unpack_colocation_set(set, score_i, id, influence_s, data_set); data_set 775 lib/pacemaker/pcmk_sched_colocation.c colocate_rsc_sets(id, last, set, score_i, influence_s, data_set); data_set 786 lib/pacemaker/pcmk_sched_colocation.c unpack_simple_colocation(xml_obj, id, influence_s, data_set); data_set 837 lib/pacemaker/pcmk_sched_colocation.c pe_working_set_t *data_set) data_set 31 lib/pacemaker/pcmk_sched_constraints.c evaluate_lifetime(xmlNode *lifetime, pe_working_set_t *data_set) data_set 36 lib/pacemaker/pcmk_sched_constraints.c result = pe_evaluate_rules(lifetime, NULL, data_set->now, next_change); data_set 40 lib/pacemaker/pcmk_sched_constraints.c pe__update_recheck_time(recheck, data_set); data_set 56 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_constraints(pe_working_set_t *data_set) data_set 58 lib/pacemaker/pcmk_sched_constraints.c xmlNode *xml_constraints = pcmk_find_cib_element(data_set->input, data_set 84 lib/pacemaker/pcmk_sched_constraints.c if ((lifetime != NULL) && !evaluate_lifetime(lifetime, data_set)) { data_set 88 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_ordering(xml_obj, data_set); data_set 91 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_colocation(xml_obj, data_set); data_set 94 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_location(xml_obj, data_set); data_set 97 lib/pacemaker/pcmk_sched_constraints.c pcmk__unpack_rsc_ticket(xml_obj, data_set); data_set 140 lib/pacemaker/pcmk_sched_constraints.c find_constraint_tag(pe_working_set_t *data_set, const char *id, pe_tag_t **tag) data_set 145 lib/pacemaker/pcmk_sched_constraints.c if (g_hash_table_lookup_extended(data_set->template_rsc_sets, id, data_set 155 lib/pacemaker/pcmk_sched_constraints.c if (g_hash_table_lookup_extended(data_set->tags, id, data_set 182 lib/pacemaker/pcmk_sched_constraints.c pcmk__valid_resource_or_tag(pe_working_set_t *data_set, const char *id, data_set 186 lib/pacemaker/pcmk_sched_constraints.c *rsc = pcmk__find_constraint_resource(data_set->resources, id); data_set 192 lib/pacemaker/pcmk_sched_constraints.c if ((tag != NULL) && find_constraint_tag(data_set, id, tag)) { data_set 214 lib/pacemaker/pcmk_sched_constraints.c pcmk__expand_tags_in_sets(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 238 lib/pacemaker/pcmk_sched_constraints.c if (!pcmk__valid_resource_or_tag(data_set, ID(xml_rsc), &rsc, data_set 333 lib/pacemaker/pcmk_sched_constraints.c bool convert_rsc, pe_working_set_t *data_set) data_set 357 lib/pacemaker/pcmk_sched_constraints.c if (!pcmk__valid_resource_or_tag(data_set, id, &rsc, &tag)) { data_set 412 lib/pacemaker/pcmk_sched_constraints.c pcmk__create_internal_constraints(pe_working_set_t *data_set) data_set 415 lib/pacemaker/pcmk_sched_constraints.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 56 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 110 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 206 lib/pacemaker/pcmk_sched_fencing.c pe_order_optional, data_set); data_set 257 lib/pacemaker/pcmk_sched_fencing.c pe_working_set_t *data_set) data_set 265 lib/pacemaker/pcmk_sched_fencing.c rsc_stonith_ordering(child_rsc, stonith_op, data_set); data_set 274 lib/pacemaker/pcmk_sched_fencing.c order_start_vs_fencing(rsc, stonith_op, data_set); data_set 275 lib/pacemaker/pcmk_sched_fencing.c order_stop_vs_fencing(rsc, stonith_op, data_set); data_set 291 lib/pacemaker/pcmk_sched_fencing.c pcmk__order_vs_fence(pe_action_t *stonith_op, pe_working_set_t *data_set) data_set 293 lib/pacemaker/pcmk_sched_fencing.c CRM_CHECK(stonith_op && data_set, return); data_set 294 lib/pacemaker/pcmk_sched_fencing.c for (GList *r = data_set->resources; r != NULL; r = r->next) { data_set 295 lib/pacemaker/pcmk_sched_fencing.c rsc_stonith_ordering((pe_resource_t *) r->data, stonith_op, data_set); data_set 384 lib/pacemaker/pcmk_sched_fencing.c FALSE, node->details->data_set); data_set 394 lib/pacemaker/pcmk_sched_fencing.c node->details->data_set); data_set 435 lib/pacemaker/pcmk_sched_fencing.c pcmk__order_vs_fence(stonith_op, node->details->data_set); data_set 598 lib/pacemaker/pcmk_sched_group.c pe_working_set_t *data_set) data_set 602 lib/pacemaker/pcmk_sched_group.c CRM_ASSERT((first != NULL) && (then != NULL) && (data_set != NULL)); data_set 609 lib/pacemaker/pcmk_sched_group.c type, data_set); data_set 622 lib/pacemaker/pcmk_sched_group.c data_set); data_set 53 lib/pacemaker/pcmk_sched_location.c pe_working_set_t *data_set, data_set 71 lib/pacemaker/pcmk_sched_location.c rule_xml = expand_idref(rule_xml, data_set->input); data_set 99 lib/pacemaker/pcmk_sched_location.c data_set); data_set 130 lib/pacemaker/pcmk_sched_location.c match_L = pcmk__copy_node_list(data_set->nodes, true); data_set 138 lib/pacemaker/pcmk_sched_location.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 143 lib/pacemaker/pcmk_sched_location.c .params = pe_rsc_params(rsc, node, data_set), data_set 148 lib/pacemaker/pcmk_sched_location.c data_set->now, next_change, &match_data); data_set 201 lib/pacemaker/pcmk_sched_location.c const char *score, pe_working_set_t *data_set, data_set 222 lib/pacemaker/pcmk_sched_location.c pe_node_t *match = pe_find_node(data_set->nodes, node); data_set 228 lib/pacemaker/pcmk_sched_location.c data_set); data_set 243 lib/pacemaker/pcmk_sched_location.c data_set, re_match_data); data_set 257 lib/pacemaker/pcmk_sched_location.c pe__update_recheck_time(t, data_set); data_set 290 lib/pacemaker/pcmk_sched_location.c unpack_simple_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 298 lib/pacemaker/pcmk_sched_location.c rsc = pcmk__find_constraint_resource(data_set->resources, value); data_set 299 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, rsc, NULL, NULL, data_set, NULL); data_set 322 lib/pacemaker/pcmk_sched_location.c for (rIter = data_set->resources; rIter; rIter = rIter->next) { data_set 345 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, data_set 351 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, NULL); data_set 368 lib/pacemaker/pcmk_sched_location.c pe_working_set_t *data_set) data_set 389 lib/pacemaker/pcmk_sched_location.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 400 lib/pacemaker/pcmk_sched_location.c if (!pcmk__valid_resource_or_tag(data_set, rsc_id, &rsc, &tag)) { data_set 416 lib/pacemaker/pcmk_sched_location.c false, data_set)) { data_set 441 lib/pacemaker/pcmk_sched_location.c unpack_location_set(xmlNode *location, xmlNode *set, pe_working_set_t *data_set) data_set 465 lib/pacemaker/pcmk_sched_location.c resource = pcmk__find_constraint_resource(data_set->resources, data_set 473 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(location, resource, role, local_score, data_set, data_set 481 lib/pacemaker/pcmk_sched_location.c pcmk__unpack_location(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 489 lib/pacemaker/pcmk_sched_location.c if (unpack_location_tags(xml_obj, &expanded_xml, data_set) != pcmk_rc_ok) { data_set 502 lib/pacemaker/pcmk_sched_location.c set = expand_idref(set, data_set->input); data_set 504 lib/pacemaker/pcmk_sched_location.c || (unpack_location_set(xml_obj, set, data_set) != pcmk_rc_ok)) { data_set 519 lib/pacemaker/pcmk_sched_location.c unpack_simple_location(xml_obj, data_set); data_set 541 lib/pacemaker/pcmk_sched_location.c pe_node_t *node, pe_working_set_t *data_set) data_set 587 lib/pacemaker/pcmk_sched_location.c data_set->placement_constraints = g_list_prepend(data_set->placement_constraints, data_set 602 lib/pacemaker/pcmk_sched_location.c pcmk__apply_locations(pe_working_set_t *data_set) data_set 604 lib/pacemaker/pcmk_sched_location.c for (GList *iter = data_set->placement_constraints; data_set 170 lib/pacemaker/pcmk_sched_nodes.c if (pcmk__str_eq(node1->details->data_set->placement_strategy, "minimal", data_set 175 lib/pacemaker/pcmk_sched_nodes.c if (pcmk__str_eq(node1->details->data_set->placement_strategy, "balanced", data_set 276 lib/pacemaker/pcmk_sched_nodes.c pcmk__apply_node_health(pe_working_set_t *data_set) data_set 280 lib/pacemaker/pcmk_sched_nodes.c const char *strategy_str = pe_pref(data_set->config_hash, data_set 291 lib/pacemaker/pcmk_sched_nodes.c base_health = pe__health_score(PCMK__OPT_NODE_HEALTH_BASE, data_set); data_set 294 lib/pacemaker/pcmk_sched_nodes.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 306 lib/pacemaker/pcmk_sched_nodes.c for (GList *r = data_set->resources; r != NULL; r = r->next) { data_set 320 lib/pacemaker/pcmk_sched_nodes.c data_set); data_set 33 lib/pacemaker/pcmk_sched_ordering.c __rsc = pcmk__find_constraint_resource(data_set->resources, __name); \ data_set 230 lib/pacemaker/pcmk_sched_ordering.c const char *instance_attr, pe_working_set_t *data_set) data_set 243 lib/pacemaker/pcmk_sched_ordering.c rsc = pcmk__find_constraint_resource(data_set->resources, rsc_id); data_set 262 lib/pacemaker/pcmk_sched_ordering.c rsc = find_clone_instance(rsc, instance_id, data_set); data_set 334 lib/pacemaker/pcmk_sched_ordering.c uint32_t flags, int clone_min, pe_working_set_t *data_set) data_set 338 lib/pacemaker/pcmk_sched_ordering.c pe_action_t *clone_min_met = get_pseudo_op(task, data_set); data_set 357 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 363 lib/pacemaker/pcmk_sched_ordering.c NULL, flags|pe_order_runnable_left, data_set); data_set 402 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 420 lib/pacemaker/pcmk_sched_ordering.c unpack_simple_rsc_order(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 444 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 451 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 481 lib/pacemaker/pcmk_sched_ordering.c cons_weight, min_required_before, data_set); data_set 489 lib/pacemaker/pcmk_sched_ordering.c rsc_then, action_then, data_set); data_set 525 lib/pacemaker/pcmk_sched_ordering.c uint32_t flags, pe_working_set_t *data_set) data_set 544 lib/pacemaker/pcmk_sched_ordering.c order->id = data_set->order_id++; data_set 570 lib/pacemaker/pcmk_sched_ordering.c (data_set->order_id - 1), data_set 574 lib/pacemaker/pcmk_sched_ordering.c data_set->ordering_constraints = g_list_prepend(data_set->ordering_constraints, data_set 591 lib/pacemaker/pcmk_sched_ordering.c const char *parent_symmetrical_s, pe_working_set_t *data_set) data_set 654 lib/pacemaker/pcmk_sched_ordering.c then_key, NULL, flags, data_set); data_set 710 lib/pacemaker/pcmk_sched_ordering.c enum pe_order_kind kind, pe_working_set_t *data_set, data_set 760 lib/pacemaker/pcmk_sched_ordering.c pe_action_t *unordered_action = get_pseudo_op(task, data_set); data_set 777 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 790 lib/pacemaker/pcmk_sched_ordering.c NULL, flags|pe_order_runnable_left, data_set); data_set 891 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 908 lib/pacemaker/pcmk_sched_ordering.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 920 lib/pacemaker/pcmk_sched_ordering.c if (!pcmk__valid_resource_or_tag(data_set, id_first, &rsc_first, data_set 927 lib/pacemaker/pcmk_sched_ordering.c if (!pcmk__valid_resource_or_tag(data_set, id_then, &rsc_then, &tag_then)) { data_set 945 lib/pacemaker/pcmk_sched_ordering.c true, data_set)) { data_set 962 lib/pacemaker/pcmk_sched_ordering.c true, data_set)) { data_set 995 lib/pacemaker/pcmk_sched_ordering.c pcmk__unpack_ordering(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 1011 lib/pacemaker/pcmk_sched_ordering.c if (unpack_order_tags(xml_obj, &expanded_xml, data_set) != pcmk_rc_ok) { data_set 1023 lib/pacemaker/pcmk_sched_ordering.c set = expand_idref(set, data_set->input); data_set 1025 lib/pacemaker/pcmk_sched_ordering.c || (unpack_order_set(set, kind, invert, data_set) != pcmk_rc_ok)) { data_set 1035 lib/pacemaker/pcmk_sched_ordering.c if (order_rsc_sets(id, last, set, kind, data_set, data_set 1044 lib/pacemaker/pcmk_sched_ordering.c && (order_rsc_sets(id, set, last, kind, data_set, data_set 1063 lib/pacemaker/pcmk_sched_ordering.c return unpack_simple_rsc_order(xml_obj, data_set); data_set 1099 lib/pacemaker/pcmk_sched_ordering.c pcmk__disable_invalid_orderings(pe_working_set_t *data_set) data_set 1101 lib/pacemaker/pcmk_sched_ordering.c for (GList *iter = data_set->actions; iter != NULL; iter = iter->next) { data_set 1126 lib/pacemaker/pcmk_sched_ordering.c for (GList *iter = node->details->data_set->actions; data_set 1174 lib/pacemaker/pcmk_sched_ordering.c node->details->data_set); data_set 1281 lib/pacemaker/pcmk_sched_ordering.c pe_working_set_t *data_set) data_set 1330 lib/pacemaker/pcmk_sched_ordering.c TRUE, data_set); data_set 1360 lib/pacemaker/pcmk_sched_ordering.c pcmk__apply_orderings(pe_working_set_t *data_set) data_set 1376 lib/pacemaker/pcmk_sched_ordering.c data_set->ordering_constraints = g_list_reverse(data_set->ordering_constraints); data_set 1378 lib/pacemaker/pcmk_sched_ordering.c for (GList *gIter = data_set->ordering_constraints; data_set 1385 lib/pacemaker/pcmk_sched_ordering.c rsc_order_first(rsc, order, data_set); data_set 1400 lib/pacemaker/pcmk_sched_ordering.c g_list_foreach(data_set->actions, (GFunc) pcmk__block_colocation_dependents, data_set 1401 lib/pacemaker/pcmk_sched_ordering.c data_set); data_set 1404 lib/pacemaker/pcmk_sched_ordering.c pcmk__order_probes(data_set); data_set 1406 lib/pacemaker/pcmk_sched_ordering.c crm_trace("Updating %d actions", g_list_length(data_set->actions)); data_set 1407 lib/pacemaker/pcmk_sched_ordering.c g_list_foreach(data_set->actions, data_set 1408 lib/pacemaker/pcmk_sched_ordering.c (GFunc) pcmk__update_action_for_orderings, data_set); data_set 1410 lib/pacemaker/pcmk_sched_ordering.c pcmk__disable_invalid_orderings(data_set); data_set 1437 lib/pacemaker/pcmk_sched_primitive.c return (result == 0)? get_effective_time(node->details->data_set) : result; data_set 335 lib/pacemaker/pcmk_sched_probes.c add_probe_orderings_for_stops(pe_working_set_t *data_set) data_set 337 lib/pacemaker/pcmk_sched_probes.c for (GList *iter = data_set->ordering_constraints; iter != NULL; data_set 464 lib/pacemaker/pcmk_sched_probes.c pe_working_set_t *data_set) data_set 581 lib/pacemaker/pcmk_sched_probes.c add_restart_orderings_for_probe(probe, after_wrapper->action, data_set); data_set 592 lib/pacemaker/pcmk_sched_probes.c clear_actions_tracking_flag(pe_working_set_t *data_set) data_set 596 lib/pacemaker/pcmk_sched_probes.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 611 lib/pacemaker/pcmk_sched_probes.c add_restart_orderings_for_rsc(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 618 lib/pacemaker/pcmk_sched_probes.c data_set); data_set 634 lib/pacemaker/pcmk_sched_probes.c add_restart_orderings_for_probe(probe, then->action, data_set); data_set 635 lib/pacemaker/pcmk_sched_probes.c clear_actions_tracking_flag(data_set); data_set 651 lib/pacemaker/pcmk_sched_probes.c order_then_probes(pe_working_set_t *data_set) data_set 683 lib/pacemaker/pcmk_sched_probes.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 760 lib/pacemaker/pcmk_sched_probes.c pcmk__order_probes(pe_working_set_t *data_set) data_set 763 lib/pacemaker/pcmk_sched_probes.c g_list_foreach(data_set->resources, (GFunc) add_restart_orderings_for_rsc, data_set 764 lib/pacemaker/pcmk_sched_probes.c data_set); data_set 765 lib/pacemaker/pcmk_sched_probes.c add_probe_orderings_for_stops(data_set); data_set 767 lib/pacemaker/pcmk_sched_probes.c order_then_probes(data_set); data_set 779 lib/pacemaker/pcmk_sched_probes.c pcmk__schedule_probes(pe_working_set_t *data_set) data_set 782 lib/pacemaker/pcmk_sched_probes.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 788 lib/pacemaker/pcmk_sched_probes.c pe_fence_node(data_set, node, data_set 814 lib/pacemaker/pcmk_sched_probes.c data_set); data_set 821 lib/pacemaker/pcmk_sched_probes.c pcmk__probe_resource_list(data_set->resources, node); data_set 63 lib/pacemaker/pcmk_sched_remote.c uint32_t extra, pe_working_set_t *data_set) data_set 65 lib/pacemaker/pcmk_sched_remote.c if ((first_rsc != NULL) && (then_action != NULL) && (data_set != NULL)) { data_set 69 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 75 lib/pacemaker/pcmk_sched_remote.c uint32_t extra, pe_working_set_t *data_set) data_set 77 lib/pacemaker/pcmk_sched_remote.c if ((first_action != NULL) && (then_rsc != NULL) && (data_set != NULL)) { data_set 80 lib/pacemaker/pcmk_sched_remote.c pe_order_preserve|extra, data_set); data_set 165 lib/pacemaker/pcmk_sched_remote.c apply_remote_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 206 lib/pacemaker/pcmk_sched_remote.c order_start_then_action(remote_rsc, action, order_opts, data_set); data_set 212 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_first, data_set); data_set 221 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, data_set 231 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_first, data_set); data_set 238 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 251 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 263 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_then, data_set); data_set 273 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, data_set 284 lib/pacemaker/pcmk_sched_remote.c pe_order_runnable_left, data_set); data_set 288 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 296 lib/pacemaker/pcmk_sched_remote.c apply_container_ordering(pe_action_t *action, pe_working_set_t *data_set) data_set 320 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(data_set, action->node, "container failed", FALSE); data_set 343 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 347 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 369 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 382 lib/pacemaker/pcmk_sched_remote.c pe_order_implies_then, data_set); data_set 386 lib/pacemaker/pcmk_sched_remote.c data_set); data_set 399 lib/pacemaker/pcmk_sched_remote.c pcmk__order_remote_connection_actions(pe_working_set_t *data_set) data_set 401 lib/pacemaker/pcmk_sched_remote.c if (!pcmk_is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 407 lib/pacemaker/pcmk_sched_remote.c for (GList *gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 425 lib/pacemaker/pcmk_sched_remote.c NULL, pe_order_optional, data_set); data_set 469 lib/pacemaker/pcmk_sched_remote.c pe_order_optional, data_set); data_set 485 lib/pacemaker/pcmk_sched_remote.c apply_container_ordering(action, data_set); data_set 489 lib/pacemaker/pcmk_sched_remote.c apply_remote_ordering(action, data_set); data_set 171 lib/pacemaker/pcmk_sched_resource.c pcmk__rscs_matching_id(const char *id, pe_working_set_t *data_set) data_set 175 lib/pacemaker/pcmk_sched_resource.c CRM_CHECK((id != NULL) && (data_set != NULL), return NULL); data_set 176 lib/pacemaker/pcmk_sched_resource.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 203 lib/pacemaker/pcmk_sched_resource.c pcmk__set_allocation_methods(pe_working_set_t *data_set) data_set 205 lib/pacemaker/pcmk_sched_resource.c g_list_foreach(data_set->resources, (GFunc) set_allocation_methods_for_rsc, data_set 698 lib/pacemaker/pcmk_sched_resource.c pcmk__sort_resources(pe_working_set_t *data_set) data_set 700 lib/pacemaker/pcmk_sched_resource.c GList *nodes = g_list_copy(data_set->nodes); data_set 703 lib/pacemaker/pcmk_sched_resource.c data_set->resources = g_list_sort_with_data(data_set->resources, data_set 66 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 80 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 94 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 101 lib/pacemaker/pcmk_sched_tickets.c "__loss_of_ticket__", data_set); data_set 111 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 115 lib/pacemaker/pcmk_sched_tickets.c pe_fence_node(data_set, (pe_node_t *) gIter->data, data_set 136 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 144 lib/pacemaker/pcmk_sched_tickets.c data_set); data_set 152 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 178 lib/pacemaker/pcmk_sched_tickets.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 231 lib/pacemaker/pcmk_sched_tickets.c data_set->ticket_constraints = g_list_append(data_set->ticket_constraints, data_set 235 lib/pacemaker/pcmk_sched_tickets.c constraints_for_ticket(rsc, new_rsc_ticket, data_set); data_set 242 lib/pacemaker/pcmk_sched_tickets.c const char *loss_policy, pe_working_set_t *data_set) data_set 264 lib/pacemaker/pcmk_sched_tickets.c resource = pcmk__find_constraint_resource(data_set->resources, data_set 273 lib/pacemaker/pcmk_sched_tickets.c rsc_ticket_new(set_id, resource, ticket, role, loss_policy, data_set); data_set 280 lib/pacemaker/pcmk_sched_tickets.c unpack_simple_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 319 lib/pacemaker/pcmk_sched_tickets.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 332 lib/pacemaker/pcmk_sched_tickets.c rsc = pcmk__find_constraint_resource(data_set->resources, rsc_id); data_set 348 lib/pacemaker/pcmk_sched_tickets.c rsc = find_clone_instance(rsc, instance, data_set); data_set 357 lib/pacemaker/pcmk_sched_tickets.c rsc_ticket_new(id, rsc, ticket, state, loss_policy, data_set); data_set 363 lib/pacemaker/pcmk_sched_tickets.c pe_working_set_t *data_set) data_set 386 lib/pacemaker/pcmk_sched_tickets.c *expanded_xml = pcmk__expand_tags_in_sets(xml_obj, data_set); data_set 397 lib/pacemaker/pcmk_sched_tickets.c if (!pcmk__valid_resource_or_tag(data_set, rsc_id, &rsc, &tag)) { data_set 413 lib/pacemaker/pcmk_sched_tickets.c false, data_set)) { data_set 435 lib/pacemaker/pcmk_sched_tickets.c pcmk__unpack_rsc_ticket(xmlNode *xml_obj, pe_working_set_t *data_set) data_set 458 lib/pacemaker/pcmk_sched_tickets.c if (data_set->tickets == NULL) { data_set 459 lib/pacemaker/pcmk_sched_tickets.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 466 lib/pacemaker/pcmk_sched_tickets.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 470 lib/pacemaker/pcmk_sched_tickets.c ticket = ticket_new(ticket_str, data_set); data_set 477 lib/pacemaker/pcmk_sched_tickets.c data_set) != pcmk_rc_ok) { data_set 489 lib/pacemaker/pcmk_sched_tickets.c set = expand_idref(set, data_set->input); data_set 492 lib/pacemaker/pcmk_sched_tickets.c data_set) != pcmk_rc_ok)) { data_set 506 lib/pacemaker/pcmk_sched_tickets.c unpack_simple_rsc_ticket(xml_obj, data_set); data_set 397 lib/pacemaker/pcmk_sched_utilization.c new_load_stopped_op(const pe_node_t *node, pe_working_set_t *data_set) data_set 401 lib/pacemaker/pcmk_sched_utilization.c pe_action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 456 lib/pacemaker/pcmk_sched_utilization.c pcmk__show_node_capacities(const char *desc, pe_working_set_t *data_set) data_set 458 lib/pacemaker/pcmk_sched_utilization.c if (!pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 461 lib/pacemaker/pcmk_sched_utilization.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 463 lib/pacemaker/pcmk_sched_utilization.c pcmk__output_t *out = data_set->priv; data_set 30 lib/pacemaker/pcmk_simulate.c static void set_effective_date(pe_working_set_t *data_set, bool print_original, data_set 137 lib/pacemaker/pcmk_simulate.c print_cluster_status(pe_working_set_t *data_set, uint32_t show_opts, data_set 140 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 151 lib/pacemaker/pcmk_simulate.c out->message(out, "cluster-status", data_set, stonith_rc, NULL, false, data_set 166 lib/pacemaker/pcmk_simulate.c print_transition_summary(pe_working_set_t *data_set, bool print_spacer) data_set 168 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 172 lib/pacemaker/pcmk_simulate.c pcmk__output_actions(data_set); data_set 187 lib/pacemaker/pcmk_simulate.c reset(pe_working_set_t *data_set, xmlNodePtr input, pcmk__output_t *out, data_set 190 lib/pacemaker/pcmk_simulate.c data_set->input = input; data_set 191 lib/pacemaker/pcmk_simulate.c data_set->priv = out; data_set 192 lib/pacemaker/pcmk_simulate.c set_effective_date(data_set, true, use_date); data_set 194 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_sanitized); data_set 197 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 200 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 218 lib/pacemaker/pcmk_simulate.c write_sim_dotfile(pe_working_set_t *data_set, const char *dot_file, data_set 229 lib/pacemaker/pcmk_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 270 lib/pacemaker/pcmk_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 324 lib/pacemaker/pcmk_simulate.c profile_file(const char *xml_file, long long repeat, pe_working_set_t *data_set, data_set 327 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 352 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_show_scores)) { data_set 355 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 362 lib/pacemaker/pcmk_simulate.c data_set->input = input; data_set 363 lib/pacemaker/pcmk_simulate.c set_effective_date(data_set, false, use_date); data_set 364 lib/pacemaker/pcmk_simulate.c pcmk__schedule_actions(input, data_set_flags, data_set); data_set 365 lib/pacemaker/pcmk_simulate.c pe_reset_working_set(data_set); data_set 373 lib/pacemaker/pcmk_simulate.c pcmk__profile_dir(const char *dir, long long repeat, pe_working_set_t *data_set, char *use_date) data_set 375 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 400 lib/pacemaker/pcmk_simulate.c profile_file(buffer, repeat, data_set, use_date); data_set 424 lib/pacemaker/pcmk_simulate.c set_effective_date(pe_working_set_t *data_set, bool print_original, data_set 427 lib/pacemaker/pcmk_simulate.c pcmk__output_t *out = data_set->priv; data_set 432 lib/pacemaker/pcmk_simulate.c crm_element_value_epoch(data_set->input, "execution-date", &original_date); data_set 435 lib/pacemaker/pcmk_simulate.c data_set->now = crm_time_new(use_date); data_set 437 lib/pacemaker/pcmk_simulate.c crm_time_log(LOG_NOTICE, "Pretending 'now' is", data_set->now, data_set 442 lib/pacemaker/pcmk_simulate.c data_set->now = crm_time_new(NULL); data_set 443 lib/pacemaker/pcmk_simulate.c crm_time_set_timet(data_set->now, &original_date); data_set 446 lib/pacemaker/pcmk_simulate.c char *when = crm_time_as_string(data_set->now, data_set 726 lib/pacemaker/pcmk_simulate.c pcmk__simulate_transition(pe_working_set_t *data_set, cib_t *cib, data_set 739 lib/pacemaker/pcmk_simulate.c out = data_set->priv; data_set 749 lib/pacemaker/pcmk_simulate.c transition = pcmk__unpack_graph(data_set->graph, crm_system_name); data_set 752 lib/pacemaker/pcmk_simulate.c fake_resource_list = data_set->resources; data_set 773 lib/pacemaker/pcmk_simulate.c pe_reset_working_set(data_set); data_set 774 lib/pacemaker/pcmk_simulate.c data_set->input = cib_object; data_set 781 lib/pacemaker/pcmk_simulate.c pcmk__simulate(pe_working_set_t *data_set, pcmk__output_t *out, data_set 796 lib/pacemaker/pcmk_simulate.c reset(data_set, input, out, use_date, flags); data_set 797 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 800 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 801 lib/pacemaker/pcmk_simulate.c printed = out->message(out, "maint-mode", data_set->flags); data_set 804 lib/pacemaker/pcmk_simulate.c if (data_set->disabled_resources || data_set->blocked_resources) { data_set 809 lib/pacemaker/pcmk_simulate.c data_set->disabled_resources, data_set 810 lib/pacemaker/pcmk_simulate.c data_set->ninstances, data_set 811 lib/pacemaker/pcmk_simulate.c data_set->blocked_resources); data_set 817 lib/pacemaker/pcmk_simulate.c print_cluster_status(data_set, data_set 836 lib/pacemaker/pcmk_simulate.c pcmk__inject_scheduler_input(data_set, cib, injections); data_set 845 lib/pacemaker/pcmk_simulate.c cleanup_calculations(data_set); data_set 846 lib/pacemaker/pcmk_simulate.c reset(data_set, input, out, use_date, flags); data_set 847 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 862 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_show_scores)) { data_set 865 lib/pacemaker/pcmk_simulate.c if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 869 lib/pacemaker/pcmk_simulate.c if (pcmk_all_flags_set(data_set->flags, data_set 876 lib/pacemaker/pcmk_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_scores)) { data_set 881 lib/pacemaker/pcmk_simulate.c } else if (pcmk_is_set(data_set->flags, pe_flag_show_utilization)) { data_set 893 lib/pacemaker/pcmk_simulate.c data_set->priv = logger_out; data_set 896 lib/pacemaker/pcmk_simulate.c pcmk__schedule_actions(input, data_set_flags, data_set); data_set 903 lib/pacemaker/pcmk_simulate.c data_set->priv = out; data_set 909 lib/pacemaker/pcmk_simulate.c rc = write_xml_file(data_set->graph, graph_file, FALSE); data_set 917 lib/pacemaker/pcmk_simulate.c rc = write_sim_dotfile(data_set, dot_file, data_set 927 lib/pacemaker/pcmk_simulate.c print_transition_summary(data_set, printed == pcmk_rc_ok); data_set 938 lib/pacemaker/pcmk_simulate.c if (pcmk__simulate_transition(data_set, cib, data_set 947 lib/pacemaker/pcmk_simulate.c set_effective_date(data_set, true, use_date); data_set 950 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 953 lib/pacemaker/pcmk_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 956 lib/pacemaker/pcmk_simulate.c cluster_status(data_set); data_set 957 lib/pacemaker/pcmk_simulate.c print_cluster_status(data_set, 0, section_opts, "Revised Cluster Status", data_set 966 lib/pacemaker/pcmk_simulate.c pcmk_simulate(xmlNodePtr *xml, pe_working_set_t *data_set, data_set 982 lib/pacemaker/pcmk_simulate.c rc = pcmk__simulate(data_set, out, injections, flags, section_opts, data_set 109 lib/pacemaker/pcmk_status.c pe_working_set_t *data_set = NULL; data_set 129 lib/pacemaker/pcmk_status.c data_set = pe_new_working_set(); data_set 130 lib/pacemaker/pcmk_status.c CRM_ASSERT(data_set != NULL); data_set 131 lib/pacemaker/pcmk_status.c pe__set_working_set_flags(data_set, pe_flag_no_compat); data_set 133 lib/pacemaker/pcmk_status.c data_set->input = cib_copy; data_set 134 lib/pacemaker/pcmk_status.c data_set->priv = out; data_set 135 lib/pacemaker/pcmk_status.c cluster_status(data_set); data_set 141 lib/pacemaker/pcmk_status.c pcmk__unpack_constraints(data_set); data_set 144 lib/pacemaker/pcmk_status.c unames = pe__build_node_name_list(data_set, only_node); data_set 145 lib/pacemaker/pcmk_status.c resources = pe__build_rsc_list(data_set, only_rsc); data_set 148 lib/pacemaker/pcmk_status.c if (data_set->dc_node == NULL) { data_set 153 lib/pacemaker/pcmk_status.c rc = pcmk__output_simple_status(out, data_set); data_set 155 lib/pacemaker/pcmk_status.c out->message(out, "cluster-status", data_set, pcmk_rc2exitc(history_rc), data_set 165 lib/pacemaker/pcmk_status.c pe_free_working_set(data_set); data_set 318 lib/pacemaker/pcmk_status.c pcmk__output_simple_status(pcmk__output_t *out, pe_working_set_t *data_set) data_set 328 lib/pacemaker/pcmk_status.c if (data_set->dc_node == NULL) { data_set 333 lib/pacemaker/pcmk_status.c for (GList *iter = data_set->nodes; iter != NULL; iter = iter->next) { data_set 380 lib/pacemaker/pcmk_status.c data_set->ninstances, pcmk__plural_s(data_set->ninstances)); data_set 690 lib/pengine/bundle.c pe__bundle_needs_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 700 lib/pengine/bundle.c params = pe_rsc_params(rsc, NULL, data_set); data_set 708 lib/pengine/bundle.c pe__add_bundle_remote_name(pe_resource_t *rsc, pe_working_set_t *data_set, data_set 716 lib/pengine/bundle.c if (!pe__bundle_needs_remote_name(rsc, data_set)) { data_set 754 lib/pengine/bundle.c pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 940 lib/pengine/bundle.c data_set) != pcmk_rc_ok) { data_set 149 lib/pengine/clone.c pe_working_set_t *data_set) data_set 162 lib/pengine/clone.c g_list_length(data_set->nodes)); data_set 167 lib/pengine/clone.c find_clone_instance(pe_resource_t * rsc, const char *sub_id, pe_working_set_t * data_set) data_set 185 lib/pengine/clone.c pe__create_clone_child(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 212 lib/pengine/clone.c data_set) != pcmk_rc_ok) { data_set 236 lib/pengine/clone.c clone_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 302 lib/pengine/clone.c clone_data->clone_max = QB_MAX(1, g_list_length(data_set->nodes)); data_set 365 lib/pengine/clone.c if (pe__create_clone_child(rsc, data_set) == NULL) { data_set 372 lib/pengine/clone.c if (pe__create_clone_child(rsc, data_set) == NULL) { data_set 1159 lib/pengine/clone.c pe_working_set_t *data_set) data_set 1165 lib/pengine/clone.c if (clone_data->clone_max == g_list_length(data_set->nodes)) { data_set 102 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 116 lib/pengine/complex.c rule_data, parent_orig_meta, NULL, FALSE, data_set); data_set 143 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) data_set 154 lib/pengine/complex.c .now = data_set->now, data_set 172 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set); data_set 177 lib/pengine/complex.c expand_parents_fixed_nvpairs(rsc, &rule_data, meta_hash, data_set); data_set 181 lib/pengine/complex.c pe__unpack_dataset_nvpairs(data_set->rsc_defaults, XML_TAG_META_SETS, data_set 182 lib/pengine/complex.c &rule_data, meta_hash, NULL, FALSE, data_set); data_set 193 lib/pengine/complex.c const pe_node_t *node, pe_working_set_t *data_set) data_set 198 lib/pengine/complex.c .now = data_set->now, data_set 209 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set); data_set 213 lib/pengine/complex.c get_rsc_attributes(meta_hash, rsc->parent, node, data_set); data_set 217 lib/pengine/complex.c pe__unpack_dataset_nvpairs(data_set->rsc_defaults, XML_TAG_ATTR_SETS, data_set 218 lib/pengine/complex.c &rule_data, meta_hash, NULL, FALSE, data_set); data_set 240 lib/pengine/complex.c unpack_template(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 273 lib/pengine/complex.c cib_resources = get_xpath_object("//"XML_CIB_TAG_RESOURCES, data_set->input, LOG_TRACE); data_set 354 lib/pengine/complex.c add_template_rsc(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 380 lib/pengine/complex.c if (add_tag_ref(data_set->template_rsc_sets, template_ref, id) == FALSE) { data_set 430 lib/pengine/complex.c pe_working_set_t *data_set) data_set 441 lib/pengine/complex.c if ((rsc == NULL) || (data_set == NULL)) { data_set 458 lib/pengine/complex.c get_rsc_attributes(params_on_node, rsc, node, data_set); data_set 563 lib/pengine/complex.c pe_resource_t *parent, pe_working_set_t *data_set) data_set 582 lib/pengine/complex.c CRM_CHECK((xml_obj != NULL) && (data_set != NULL), data_set 586 lib/pengine/complex.c rule_data.now = data_set->now; data_set 597 lib/pengine/complex.c if (unpack_template(xml_obj, &expanded_xml, data_set) == FALSE) { data_set 606 lib/pengine/complex.c (*rsc)->cluster = data_set; data_set 623 lib/pengine/complex.c (*rsc)->ops_xml = expand_idref(ops, data_set->input); data_set 649 lib/pengine/complex.c get_meta_attributes((*rsc)->meta, *rsc, NULL, data_set); data_set 650 lib/pengine/complex.c (*rsc)->parameters = pe_rsc_params(*rsc, NULL, data_set); // \deprecated data_set 655 lib/pengine/complex.c if (!pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 720 lib/pengine/complex.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 801 lib/pengine/complex.c pe__set_working_set_flags(data_set, pe_flag_have_stonith_resource); data_set 815 lib/pengine/complex.c GHashTable *params = pe_rsc_params(*rsc, NULL, data_set); data_set 838 lib/pengine/complex.c if ((*rsc)->fns->unpack(*rsc, data_set) == FALSE) { data_set 844 lib/pengine/complex.c if (pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 846 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "symmetric_default", data_set); data_set 851 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "remote_connection_default", data_set); data_set 860 lib/pengine/complex.c (*rsc)->utilization, NULL, FALSE, data_set); data_set 863 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 361 lib/pengine/failcounts.c const char *reason, pe_working_set_t *data_set) data_set 366 lib/pengine/failcounts.c CRM_CHECK(rsc && node && reason && data_set, return NULL); data_set 370 lib/pengine/failcounts.c data_set); data_set 171 lib/pengine/group.c group_unpack(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 200 lib/pengine/group.c data_set) != pcmk_rc_ok) { data_set 89 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 121 lib/pengine/native.c resource_location(rsc, node, INFINITY, "not_managed_default", data_set); data_set 142 lib/pengine/native.c rsc->allowed_nodes = pe__node_list2table(data_set->nodes); data_set 185 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 215 lib/pengine/native.c pe__force_anon(standard, parent, rsc->id, data_set); data_set 319 lib/pengine/native.c pe_working_set_t * data_set) data_set 329 lib/pengine/native.c params = pe_rsc_params(rsc, node, data_set); data_set 22 lib/pengine/pe_actions.c pe_working_set_t *data_set, guint interval_ms); data_set 25 lib/pengine/pe_actions.c add_singleton(pe_working_set_t *data_set, pe_action_t *action) data_set 27 lib/pengine/pe_actions.c if (data_set->singletons == NULL) { data_set 28 lib/pengine/pe_actions.c data_set->singletons = pcmk__strkey_table(NULL, NULL); data_set 30 lib/pengine/pe_actions.c g_hash_table_insert(data_set->singletons, action->uuid, action); data_set 34 lib/pengine/pe_actions.c lookup_singleton(pe_working_set_t *data_set, const char *action_uuid) data_set 36 lib/pengine/pe_actions.c if (data_set->singletons == NULL) { data_set 39 lib/pengine/pe_actions.c return g_hash_table_lookup(data_set->singletons, action_uuid); data_set 55 lib/pengine/pe_actions.c pe_working_set_t *data_set) data_set 63 lib/pengine/pe_actions.c matches = find_actions(((rsc == NULL)? data_set->actions : rsc->actions), data_set 169 lib/pengine/pe_actions.c pe_working_set_t *data_set) data_set 202 lib/pengine/pe_actions.c unpack_operation(action, action->op_entry, rsc->container, data_set, data_set 209 lib/pengine/pe_actions.c data_set->action_id, key, task, data_set 212 lib/pengine/pe_actions.c action->id = data_set->action_id++; data_set 214 lib/pengine/pe_actions.c data_set->actions = g_list_prepend(data_set->actions, action); data_set 216 lib/pengine/pe_actions.c add_singleton(data_set, action); data_set 232 lib/pengine/pe_actions.c unpack_action_node_attributes(pe_action_t *action, pe_working_set_t *data_set) data_set 240 lib/pengine/pe_actions.c .now = data_set->now, data_set 249 lib/pengine/pe_actions.c FALSE, data_set); data_set 282 lib/pengine/pe_actions.c effective_quorum_policy(pe_resource_t *rsc, pe_working_set_t *data_set) data_set 284 lib/pengine/pe_actions.c enum pe_quorum_policy policy = data_set->no_quorum_policy; data_set 286 lib/pengine/pe_actions.c if (pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 289 lib/pengine/pe_actions.c } else if (data_set->no_quorum_policy == no_quorum_demote) { data_set 319 lib/pengine/pe_actions.c pe_working_set_t *data_set) data_set 342 lib/pengine/pe_actions.c pe_fence_node(data_set, action->node, "stop is unrunnable", false); data_set 355 lib/pengine/pe_actions.c && !pe_can_fence(data_set, action->node)) { data_set 373 lib/pengine/pe_actions.c switch (effective_quorum_policy(action->rsc, data_set)) { data_set 636 lib/pengine/pe_actions.c pe_working_set_t * data_set, guint interval_ms) data_set 656 lib/pengine/pe_actions.c .now = data_set->now, data_set 667 lib/pengine/pe_actions.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, &rule_data, data_set 668 lib/pengine/pe_actions.c action->meta, NULL, FALSE, data_set); data_set 690 lib/pengine/pe_actions.c action->meta, NULL, TRUE, data_set); data_set 732 lib/pengine/pe_actions.c GHashTable *params = pe_rsc_params(action->rsc, action->node, data_set); data_set 781 lib/pengine/pe_actions.c if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 844 lib/pengine/pe_actions.c && pe__resource_is_remote_conn(action->rsc, data_set) data_set 855 lib/pengine/pe_actions.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 868 lib/pengine/pe_actions.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 914 lib/pengine/pe_actions.c if (unpack_interval_origin(value, xml_obj, interval_ms, data_set->now, data_set 942 lib/pengine/pe_actions.c pe_working_set_t *data_set) data_set 946 lib/pengine/pe_actions.c CRM_ASSERT((key != NULL) && (task != NULL) && (data_set != NULL)); data_set 949 lib/pengine/pe_actions.c action = find_existing_action(key, rsc, on_node, data_set); data_set 954 lib/pengine/pe_actions.c data_set); data_set 963 lib/pengine/pe_actions.c unpack_action_node_attributes(action, data_set); data_set 966 lib/pengine/pe_actions.c update_resource_action_runnable(action, save_action, data_set); data_set 977 lib/pengine/pe_actions.c get_pseudo_op(const char *name, pe_working_set_t * data_set) data_set 979 lib/pengine/pe_actions.c pe_action_t *op = lookup_singleton(data_set, name); data_set 982 lib/pengine/pe_actions.c op = custom_action(NULL, strdup(name), name, NULL, TRUE, TRUE, data_set); data_set 1014 lib/pengine/pe_actions.c node_priority_fencing_delay(pe_node_t * node, pe_working_set_t * data_set) data_set 1023 lib/pengine/pe_actions.c if (data_set->priority_fencing_delay <= 0) { data_set 1038 lib/pengine/pe_actions.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1077 lib/pengine/pe_actions.c return data_set->priority_fencing_delay; data_set 1082 lib/pengine/pe_actions.c bool priority_delay, pe_working_set_t * data_set) data_set 1088 lib/pengine/pe_actions.c op = data_set->stonith_action; data_set 1093 lib/pengine/pe_actions.c stonith_op = lookup_singleton(data_set, op_key); data_set 1095 lib/pengine/pe_actions.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); data_set 1101 lib/pengine/pe_actions.c if (pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 1107 lib/pengine/pe_actions.c GList *matches = find_unfencing_devices(data_set->resources, NULL); data_set 1118 lib/pengine/pe_actions.c data = pe__compare_fencing_digest(match, agent, node, data_set); data_set 1124 lib/pengine/pe_actions.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 1125 lib/pengine/pe_actions.c pcmk__output_t *out = data_set->priv; data_set 1157 lib/pengine/pe_actions.c if (data_set->priority_fencing_delay > 0 data_set 1174 lib/pengine/pe_actions.c char *delay_s = pcmk__itoa(node_priority_fencing_delay(node, data_set)); data_set 1181 lib/pengine/pe_actions.c if(optional == FALSE && pe_can_fence(data_set, node)) { data_set 1215 lib/pengine/pe_actions.c pe_get_configured_timeout(pe_resource_t *rsc, const char *action, pe_working_set_t *data_set) data_set 1225 lib/pengine/pe_actions.c .now = data_set->now, data_set 1240 lib/pengine/pe_actions.c if (timeout_spec == NULL && data_set->op_defaults) { data_set 1242 lib/pengine/pe_actions.c pe__unpack_dataset_nvpairs(data_set->op_defaults, XML_TAG_META_SETS, data_set 1243 lib/pengine/pe_actions.c &rule_data, action_meta, NULL, FALSE, data_set); data_set 1474 lib/pengine/pe_actions.c pe_working_set_t *data_set) data_set 1481 lib/pengine/pe_actions.c data_set); data_set 103 lib/pengine/pe_digest.c GHashTable *overrides, pe_working_set_t *data_set) data_set 112 lib/pengine/pe_digest.c (void) pe__add_bundle_remote_name(rsc, data_set, data->params_all, data_set 131 lib/pengine/pe_digest.c task, node, TRUE, FALSE, data_set); data_set 300 lib/pengine/pe_digest.c bool calc_secure, pe_working_set_t *data_set) data_set 316 lib/pengine/pe_digest.c if (op_version == NULL && data_set != NULL && data_set->input != NULL) { data_set 317 lib/pengine/pe_digest.c op_version = crm_element_value(data_set->input, XML_ATTR_CRM_VERSION); data_set 324 lib/pengine/pe_digest.c params = pe_rsc_params(rsc, node, data_set); data_set 326 lib/pengine/pe_digest.c op_version, overrides, data_set); data_set 352 lib/pengine/pe_digest.c pe_working_set_t *data_set) data_set 360 lib/pengine/pe_digest.c NULL, calc_secure, data_set); data_set 381 lib/pengine/pe_digest.c pe_working_set_t * data_set) data_set 399 lib/pengine/pe_digest.c pcmk_is_set(data_set->flags, pe_flag_sanitized), data_set 400 lib/pengine/pe_digest.c data_set); data_set 533 lib/pengine/pe_digest.c pe_node_t *node, pe_working_set_t *data_set) data_set 539 lib/pengine/pe_digest.c node, NULL, TRUE, data_set); data_set 560 lib/pengine/pe_digest.c if (!pcmk__is_daemon && data_set->priv != NULL) { data_set 561 lib/pengine/pe_digest.c pcmk__output_t *out = data_set->priv; data_set 571 lib/pengine/pe_digest.c if (pcmk_is_set(data_set->flags, pe_flag_sanitized) && data->digest_secure_calc) { data_set 572 lib/pengine/pe_digest.c if (data_set->priv != NULL) { data_set 573 lib/pengine/pe_digest.c pcmk__output_t *out = data_set->priv; data_set 23 lib/pengine/pe_health.c pe__unpack_node_health_scores(pe_working_set_t *data_set) data_set 25 lib/pengine/pe_health.c switch (pe__health_strategy(data_set)) { data_set 46 lib/pengine/pe_health.c data_set); data_set 48 lib/pengine/pe_health.c data_set); data_set 50 lib/pengine/pe_health.c data_set); data_set 123 lib/pengine/pe_health.c strategy = pe__health_strategy(node->details->data_set); data_set 47 lib/pengine/pe_output.c add_extra_info(pe_node_t *node, GList *rsc_list, pe_working_set_t *data_set, data_set 59 lib/pengine/pe_output.c if (add_extra_info(node, rsc->children, data_set, attrname, data_set 69 lib/pengine/pe_output.c params = pe_rsc_params(rsc, node, data_set); data_set 178 lib/pengine/pe_output.c get_cluster_stack(pe_working_set_t *data_set) data_set 181 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 329 lib/pengine/pe_output.c is_mixed_version(pe_working_set_t *data_set) { data_set 331 lib/pengine/pe_output.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 358 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 363 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 372 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 376 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 377 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 378 lib/pengine/pe_output.c bool mixed_version = is_mixed_version(data_set); data_set 381 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, data_set 387 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 388 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 389 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 390 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 398 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 399 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 400 lib/pengine/pe_output.c data_set->blocked_resources); data_set 405 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 411 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 422 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 427 lib/pengine/pe_output.c const char *stack_s = get_cluster_stack(data_set); data_set 435 lib/pengine/pe_output.c if (data_set->dc_node == NULL || pcmk_is_set(section_opts, pcmk_section_dc)) { data_set 437 lib/pengine/pe_output.c data_set->input, LOG_DEBUG); data_set 441 lib/pengine/pe_output.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 442 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 443 lib/pengine/pe_output.c bool mixed_version = is_mixed_version(data_set); data_set 446 lib/pengine/pe_output.c out->message(out, "cluster-dc", data_set->dc_node, quorum, data_set 452 lib/pengine/pe_output.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 453 lib/pengine/pe_output.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 454 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 455 lib/pengine/pe_output.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 463 lib/pengine/pe_output.c out->message(out, "cluster-counts", g_list_length(data_set->nodes), data_set 464 lib/pengine/pe_output.c data_set->ninstances, data_set->disabled_resources, data_set 465 lib/pengine/pe_output.c data_set->blocked_resources); data_set 476 lib/pengine/pe_output.c out->message(out, "cluster-options", data_set); data_set 482 lib/pengine/pe_output.c if (out->message(out, "maint-mode", data_set->flags) == pcmk_rc_ok) { data_set 657 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 667 lib/pengine/pe_output.c for (gIter = data_set->placement_constraints; gIter != NULL; gIter = gIter->next) { data_set 929 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 932 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 935 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 937 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 960 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 967 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 984 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 986 lib/pengine/pe_output.c if (pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 988 lib/pengine/pe_output.c } else if (pcmk_is_set(data_set->flags, pe_flag_stop_everything)) { data_set 998 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1001 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 1004 lib/pengine/pe_output.c pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) ? "symmetric" : "asymmetric"); data_set 1006 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 1035 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1038 lib/pengine/pe_output.c char *stonith_timeout_str = pcmk__itoa(data_set->stonith_timeout); data_set 1039 lib/pengine/pe_output.c char *priority_fencing_delay_str = pcmk__itoa(data_set->priority_fencing_delay * 1000); data_set 1041 lib/pengine/pe_output.c switch (data_set->no_quorum_policy) { data_set 1064 lib/pengine/pe_output.c "stonith-enabled", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)), data_set 1065 lib/pengine/pe_output.c "symmetric-cluster", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)), data_set 1067 lib/pengine/pe_output.c "maintenance-mode", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode)), data_set 1068 lib/pengine/pe_output.c "stop-all-resources", pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything)), data_set 1413 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1424 lib/pengine/pe_output.c if (xmlChildElementCount(data_set->failed) == 0) { data_set 1428 lib/pengine/pe_output.c for (xml_op = pcmk__xml_first_child(data_set->failed); xml_op != NULL; data_set 1878 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1893 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 1934 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 1954 lib/pengine/pe_output.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 2008 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2017 lib/pengine/pe_output.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 2055 lib/pengine/pe_output.c data_set, name, &expected_score); data_set 2107 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2126 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 2150 lib/pengine/pe_output.c NULL, data_set); data_set 2166 lib/pengine/pe_output.c pe_resource_t *rsc = pe_find_resource(data_set->resources, data_set 2179 lib/pengine/pe_output.c out->message(out, "resource-operation-list", data_set, rsc, node, data_set 2349 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2357 lib/pengine/pe_output.c xmlNode *cib_status = pcmk_find_cib_element(data_set->input, data_set 2367 lib/pengine/pe_output.c pe_node_t *node = pe_find_node_id(data_set->nodes, ID(node_state)); data_set 2381 lib/pengine/pe_output.c out->message(out, "node-history-list", data_set, node, node_state, data_set 2646 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2668 lib/pengine/pe_output.c GList *rscs = pe__filter_rsc_list(data_set->resources, only_rsc); data_set 2679 lib/pengine/pe_output.c for (rsc_iter = data_set->resources; rsc_iter != NULL; rsc_iter = rsc_iter->next) { data_set 2753 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2783 lib/pengine/pe_output.c NULL, data_set); data_set 2907 lib/pengine/pe_output.c pe_working_set_t *data_set = va_arg(args, pe_working_set_t *); data_set 2913 lib/pengine/pe_output.c if (g_hash_table_size(data_set->tickets) == 0) { data_set 2923 lib/pengine/pe_output.c g_hash_table_iter_init(&iter, data_set->tickets); data_set 43 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 47 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 54 lib/pengine/pe_status_private.h pe_resource_t *parent, pe_working_set_t *data_set); data_set 57 lib/pengine/pe_status_private.h gboolean unpack_remote_nodes(xmlNode *xml_resources, pe_working_set_t *data_set); data_set 60 lib/pengine/pe_status_private.h gboolean unpack_resources(xmlNode *xml_resources, pe_working_set_t *data_set); data_set 63 lib/pengine/pe_status_private.h gboolean unpack_config(xmlNode *config, pe_working_set_t *data_set); data_set 66 lib/pengine/pe_status_private.h gboolean unpack_nodes(xmlNode *xml_nodes, pe_working_set_t *data_set); data_set 69 lib/pengine/pe_status_private.h gboolean unpack_tags(xmlNode *xml_tags, pe_working_set_t *data_set); data_set 72 lib/pengine/pe_status_private.h gboolean unpack_status(xmlNode *status, pe_working_set_t *data_set); data_set 78 lib/pengine/pe_status_private.h pe_working_set_t *data_set); data_set 81 lib/pengine/pe_status_private.h void pe__unpack_node_health_scores(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 75 lib/pengine/status.c if ((data_set == NULL) || (data_set->input == NULL)) { data_set 81 lib/pengine/status.c if (data_set->failed != NULL) { data_set 82 lib/pengine/status.c free_xml(data_set->failed); 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->now == NULL) { data_set 87 lib/pengine/status.c data_set->now = crm_time_new(NULL); data_set 90 lib/pengine/status.c if (data_set->dc_uuid == NULL) { data_set 91 lib/pengine/status.c data_set->dc_uuid = crm_element_value_copy(data_set->input, data_set 95 lib/pengine/status.c if (pcmk__xe_attr_is_true(data_set->input, XML_ATTR_HAVE_QUORUM)) { data_set 96 lib/pengine/status.c pe__set_working_set_flags(data_set, pe_flag_have_quorum); data_set 98 lib/pengine/status.c pe__clear_working_set_flags(data_set, pe_flag_have_quorum); data_set 101 lib/pengine/status.c data_set->op_defaults = get_xpath_object("//" XML_CIB_TAG_OPCONFIG, data_set 102 lib/pengine/status.c data_set->input, LOG_NEVER); data_set 103 lib/pengine/status.c data_set->rsc_defaults = get_xpath_object("//" XML_CIB_TAG_RSCCONFIG, data_set 104 lib/pengine/status.c data_set->input, LOG_NEVER); data_set 106 lib/pengine/status.c section = get_xpath_object("//" XML_CIB_TAG_CRMCONFIG, data_set->input, data_set 108 lib/pengine/status.c unpack_config(section, data_set); data_set 110 lib/pengine/status.c if (!pcmk_any_flags_set(data_set->flags, data_set 112 lib/pengine/status.c && (data_set->no_quorum_policy != no_quorum_ignore)) { data_set 116 lib/pengine/status.c section = get_xpath_object("//" XML_CIB_TAG_NODES, data_set->input, data_set 118 lib/pengine/status.c unpack_nodes(section, data_set); data_set 120 lib/pengine/status.c section = get_xpath_object("//" XML_CIB_TAG_RESOURCES, data_set->input, data_set 122 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 123 lib/pengine/status.c unpack_remote_nodes(section, data_set); data_set 125 lib/pengine/status.c unpack_resources(section, data_set); data_set 127 lib/pengine/status.c section = get_xpath_object("//" XML_CIB_TAG_TAGS, data_set->input, data_set 129 lib/pengine/status.c unpack_tags(section, data_set); data_set 131 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 132 lib/pengine/status.c section = get_xpath_object("//"XML_CIB_TAG_STATUS, data_set->input, data_set 134 lib/pengine/status.c unpack_status(section, data_set); data_set 137 lib/pengine/status.c if (!pcmk_is_set(data_set->flags, pe_flag_no_counts)) { data_set 138 lib/pengine/status.c for (GList *item = data_set->resources; item != NULL; data_set 143 lib/pengine/status.c data_set->ninstances, data_set->disabled_resources, data_set 144 lib/pengine/status.c data_set->blocked_resources); data_set 147 lib/pengine/status.c pe__set_working_set_flags(data_set, pe_flag_have_status); data_set 279 lib/pengine/status.c cleanup_calculations(pe_working_set_t * data_set) data_set 281 lib/pengine/status.c if (data_set == NULL) { data_set 285 lib/pengine/status.c pe__clear_working_set_flags(data_set, pe_flag_have_status); data_set 286 lib/pengine/status.c if (data_set->config_hash != NULL) { data_set 287 lib/pengine/status.c g_hash_table_destroy(data_set->config_hash); data_set 290 lib/pengine/status.c if (data_set->singletons != NULL) { data_set 291 lib/pengine/status.c g_hash_table_destroy(data_set->singletons); data_set 294 lib/pengine/status.c if (data_set->tickets) { data_set 295 lib/pengine/status.c g_hash_table_destroy(data_set->tickets); data_set 298 lib/pengine/status.c if (data_set->template_rsc_sets) { data_set 299 lib/pengine/status.c g_hash_table_destroy(data_set->template_rsc_sets); data_set 302 lib/pengine/status.c if (data_set->tags) { data_set 303 lib/pengine/status.c g_hash_table_destroy(data_set->tags); data_set 306 lib/pengine/status.c free(data_set->dc_uuid); data_set 309 lib/pengine/status.c pe_free_resources(data_set->resources); data_set 312 lib/pengine/status.c pe_free_actions(data_set->actions); data_set 315 lib/pengine/status.c pe_free_nodes(data_set->nodes); data_set 317 lib/pengine/status.c pe__free_param_checks(data_set); data_set 318 lib/pengine/status.c g_list_free(data_set->stop_needed); data_set 319 lib/pengine/status.c free_xml(data_set->graph); data_set 320 lib/pengine/status.c crm_time_free(data_set->now); data_set 321 lib/pengine/status.c free_xml(data_set->input); data_set 322 lib/pengine/status.c free_xml(data_set->failed); data_set 324 lib/pengine/status.c set_working_set_defaults(data_set); data_set 326 lib/pengine/status.c CRM_CHECK(data_set->ordering_constraints == NULL,; data_set 328 lib/pengine/status.c CRM_CHECK(data_set->placement_constraints == NULL,; data_set 338 lib/pengine/status.c pe_reset_working_set(pe_working_set_t *data_set) data_set 340 lib/pengine/status.c if (data_set == NULL) { data_set 345 lib/pengine/status.c g_list_length(data_set->ordering_constraints)); data_set 346 lib/pengine/status.c pe__free_ordering(data_set->ordering_constraints); data_set 347 lib/pengine/status.c data_set->ordering_constraints = NULL; data_set 350 lib/pengine/status.c g_list_length(data_set->placement_constraints)); data_set 351 lib/pengine/status.c pe__free_location(data_set->placement_constraints); data_set 352 lib/pengine/status.c data_set->placement_constraints = NULL; data_set 355 lib/pengine/status.c g_list_length(data_set->colocation_constraints)); data_set 356 lib/pengine/status.c g_list_free_full(data_set->colocation_constraints, free); data_set 357 lib/pengine/status.c data_set->colocation_constraints = NULL; data_set 360 lib/pengine/status.c g_list_length(data_set->ticket_constraints)); data_set 361 lib/pengine/status.c g_list_free_full(data_set->ticket_constraints, free); data_set 362 lib/pengine/status.c data_set->ticket_constraints = NULL; data_set 364 lib/pengine/status.c cleanup_calculations(data_set); data_set 368 lib/pengine/status.c set_working_set_defaults(pe_working_set_t * data_set) data_set 370 lib/pengine/status.c void *priv = data_set->priv; data_set 372 lib/pengine/status.c memset(data_set, 0, sizeof(pe_working_set_t)); data_set 374 lib/pengine/status.c data_set->priv = priv; data_set 375 lib/pengine/status.c data_set->order_id = 1; data_set 376 lib/pengine/status.c data_set->action_id = 1; data_set 377 lib/pengine/status.c data_set->no_quorum_policy = no_quorum_stop; data_set 379 lib/pengine/status.c data_set->flags = 0x0ULL; data_set 381 lib/pengine/status.c pe__set_working_set_flags(data_set, data_set 386 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 23 lib/pengine/tests/native/native_find_rsc_test.c pe_working_set_t *data_set = NULL; data_set 43 lib/pengine/tests/native/native_find_rsc_test.c data_set = pe_new_working_set(); data_set 45 lib/pengine/tests/native/native_find_rsc_test.c if (data_set == NULL) { data_set 49 lib/pengine/tests/native/native_find_rsc_test.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 50 lib/pengine/tests/native/native_find_rsc_test.c data_set->input = input; data_set 52 lib/pengine/tests/native/native_find_rsc_test.c cluster_status(data_set); data_set 55 lib/pengine/tests/native/native_find_rsc_test.c cluster01 = pe_find_node(data_set->nodes, "cluster01"); data_set 56 lib/pengine/tests/native/native_find_rsc_test.c cluster02 = pe_find_node(data_set->nodes, "cluster02"); data_set 57 lib/pengine/tests/native/native_find_rsc_test.c httpd_bundle_0 = pe_find_node(data_set->nodes, "httpd-bundle-0"); data_set 60 lib/pengine/tests/native/native_find_rsc_test.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 83 lib/pengine/tests/native/native_find_rsc_test.c pe_free_working_set(data_set); data_set 90 lib/pengine/tests/native/native_find_rsc_test.c pe_resource_t *rsc = (pe_resource_t *) g_list_first(data_set->resources)->data; data_set 123 lib/pengine/tests/native/native_find_rsc_test.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 20 lib/pengine/tests/native/pe_base_name_eq_test.c pe_working_set_t *data_set = NULL; data_set 39 lib/pengine/tests/native/pe_base_name_eq_test.c data_set = pe_new_working_set(); data_set 41 lib/pengine/tests/native/pe_base_name_eq_test.c if (data_set == NULL) { data_set 45 lib/pengine/tests/native/pe_base_name_eq_test.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 46 lib/pengine/tests/native/pe_base_name_eq_test.c data_set->input = input; data_set 48 lib/pengine/tests/native/pe_base_name_eq_test.c cluster_status(data_set); data_set 51 lib/pengine/tests/native/pe_base_name_eq_test.c for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) { data_set 88 lib/pengine/tests/native/pe_base_name_eq_test.c pe_free_working_set(data_set); data_set 30 lib/pengine/tests/status/pe_new_working_set_test.c pe_working_set_t *data_set = pe_new_working_set(); data_set 36 lib/pengine/tests/status/pe_new_working_set_test.c assert_non_null(data_set); data_set 41 lib/pengine/tests/status/pe_new_working_set_test.c free(data_set); data_set 22 lib/pengine/tests/status/set_working_set_defaults_test.c pe_working_set_t *data_set = calloc(1, sizeof(pe_working_set_t)); data_set 24 lib/pengine/tests/status/set_working_set_defaults_test.c set_working_set_defaults(data_set); data_set 33 lib/pengine/tests/status/set_working_set_defaults_test.c assert_null(data_set->priv); data_set 34 lib/pengine/tests/status/set_working_set_defaults_test.c assert_int_equal(data_set->order_id, 1); data_set 35 lib/pengine/tests/status/set_working_set_defaults_test.c assert_int_equal(data_set->action_id, 1); data_set 36 lib/pengine/tests/status/set_working_set_defaults_test.c assert_int_equal(data_set->no_quorum_policy, no_quorum_stop); data_set 37 lib/pengine/tests/status/set_working_set_defaults_test.c assert_int_equal(data_set->flags, flags); data_set 42 lib/pengine/tests/status/set_working_set_defaults_test.c free(data_set); data_set 34 lib/pengine/unpack.c #define set_config_flag(data_set, option, flag) do { \ data_set 35 lib/pengine/unpack.c const char *scf_value = pe_pref((data_set)->config_hash, (option)); \ data_set 38 lib/pengine/unpack.c (data_set)->flags = pcmk__set_flags_as(__func__, __LINE__, \ data_set 40 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 43 lib/pengine/unpack.c (data_set)->flags = pcmk__clear_flags_as(__func__, __LINE__,\ data_set 45 lib/pengine/unpack.c crm_system_name, (data_set)->flags, \ data_set 54 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 55 lib/pengine/unpack.c static void determine_remote_online_status(pe_working_set_t *data_set, data_set 58 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 60 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 63 lib/pengine/unpack.c pe_working_set_t *data_set); data_set 95 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, data_set 143 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 148 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, FALSE, data_set); data_set 153 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", data_set 159 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 162 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, priority_delay, data_set); data_set 182 lib/pengine/unpack.c set_if_xpath(uint64_t flag, const char *xpath, pe_working_set_t *data_set) data_set 186 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, flag)) { data_set 187 lib/pengine/unpack.c result = xpath_search(data_set->input, xpath); data_set 189 lib/pengine/unpack.c pe__set_working_set_flags(data_set, flag); data_set 196 lib/pengine/unpack.c unpack_config(xmlNode * config, pe_working_set_t * data_set) data_set 204 lib/pengine/unpack.c .now = data_set->now, data_set 210 lib/pengine/unpack.c data_set->config_hash = config_hash; data_set 213 lib/pengine/unpack.c CIB_OPTIONS_FIRST, FALSE, data_set); data_set 215 lib/pengine/unpack.c verify_pe_options(data_set->config_hash); data_set 217 lib/pengine/unpack.c set_config_flag(data_set, "enable-startup-probes", pe_flag_startup_probes); data_set 218 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_startup_probes)) { data_set 222 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, XML_ATTR_HAVE_WATCHDOG); data_set 226 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_stonith_resource); data_set 232 lib/pengine/unpack.c set_if_xpath(pe_flag_enable_unfencing, XPATH_ENABLE_UNFENCING, data_set); data_set 234 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 235 lib/pengine/unpack.c data_set->stonith_timeout = (int) crm_parse_interval_spec(value); data_set 236 lib/pengine/unpack.c crm_debug("STONITH timeout: %d", data_set->stonith_timeout); data_set 238 lib/pengine/unpack.c set_config_flag(data_set, "stonith-enabled", pe_flag_stonith_enabled); data_set 240 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)? "enabled" : "disabled"); data_set 242 lib/pengine/unpack.c data_set->stonith_action = pe_pref(data_set->config_hash, "stonith-action"); data_set 243 lib/pengine/unpack.c if (!strcmp(data_set->stonith_action, "poweroff")) { data_set 247 lib/pengine/unpack.c data_set->stonith_action = "off"; data_set 249 lib/pengine/unpack.c crm_trace("STONITH will %s nodes", data_set->stonith_action); data_set 251 lib/pengine/unpack.c set_config_flag(data_set, "concurrent-fencing", pe_flag_concurrent_fencing); data_set 253 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_concurrent_fencing)? "enabled" : "disabled"); data_set 255 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 258 lib/pengine/unpack.c data_set->priority_fencing_delay = crm_parse_interval_spec(value) / 1000; data_set 259 lib/pengine/unpack.c crm_trace("Priority fencing delay is %ds", data_set->priority_fencing_delay); data_set 262 lib/pengine/unpack.c set_config_flag(data_set, "stop-all-resources", pe_flag_stop_everything); data_set 264 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_stop_everything))); data_set 266 lib/pengine/unpack.c set_config_flag(data_set, "symmetric-cluster", pe_flag_symmetric_cluster); data_set 267 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 271 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "no-quorum-policy"); data_set 274 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_ignore; data_set 277 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_freeze; data_set 280 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_demote; data_set 283 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 286 lib/pengine/unpack.c crm_element_value_int(data_set->input, XML_ATTR_QUORUM_PANIC, data_set 288 lib/pengine/unpack.c if (do_panic || pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 289 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_suicide; data_set 292 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 297 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 301 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 304 lib/pengine/unpack.c switch (data_set->no_quorum_policy) { data_set 323 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-resources", pe_flag_stop_rsc_orphans); data_set 325 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)? "stopped" : "ignored"); data_set 327 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-actions", pe_flag_stop_action_orphans); data_set 329 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stop_action_orphans)? "stopped" : "ignored"); data_set 331 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "remove-after-stop"); data_set 334 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 341 lib/pengine/unpack.c pe__clear_working_set_flags(data_set, pe_flag_remove_after_stop); data_set 345 lib/pengine/unpack.c set_config_flag(data_set, "maintenance-mode", pe_flag_maintenance_mode); data_set 347 lib/pengine/unpack.c pcmk__btoa(pcmk_is_set(data_set->flags, pe_flag_maintenance_mode))); data_set 349 lib/pengine/unpack.c set_config_flag(data_set, "start-failure-is-fatal", pe_flag_start_failure_fatal); data_set 351 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_start_failure_fatal)? "always fatal" : "handled by failcount"); data_set 353 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 354 lib/pengine/unpack.c set_config_flag(data_set, "startup-fencing", pe_flag_startup_fencing); data_set 356 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 362 lib/pengine/unpack.c pe__unpack_node_health_scores(data_set); data_set 364 lib/pengine/unpack.c data_set->placement_strategy = pe_pref(data_set->config_hash, "placement-strategy"); data_set 365 lib/pengine/unpack.c crm_trace("Placement strategy: %s", data_set->placement_strategy); data_set 367 lib/pengine/unpack.c set_config_flag(data_set, "shutdown-lock", pe_flag_shutdown_lock); data_set 369 lib/pengine/unpack.c (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)? "" : " not")); data_set 370 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 371 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, data_set 373 lib/pengine/unpack.c data_set->shutdown_lock = crm_parse_interval_spec(value) / 1000; data_set 374 lib/pengine/unpack.c crm_trace("Shutdown locks expire after %us", data_set->shutdown_lock); data_set 382 lib/pengine/unpack.c const char *score, pe_working_set_t * data_set) data_set 386 lib/pengine/unpack.c if (pe_find_node(data_set->nodes, uname) != NULL) { data_set 411 lib/pengine/unpack.c new_node->details->data_set = data_set; data_set 418 lib/pengine/unpack.c pe__set_working_set_flags(data_set, pe_flag_have_remote_nodes); data_set 450 lib/pengine/unpack.c data_set->nodes = g_list_insert_sorted(data_set->nodes, new_node, data_set 513 lib/pengine/unpack.c handle_startup_fencing(pe_working_set_t *data_set, pe_node_t *new_node) data_set 523 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 538 lib/pengine/unpack.c unpack_nodes(xmlNode * xml_nodes, pe_working_set_t * data_set) data_set 550 lib/pengine/unpack.c .now = data_set->now, data_set 573 lib/pengine/unpack.c new_node = pe_create_node(id, uname, type, score, data_set); data_set 579 lib/pengine/unpack.c handle_startup_fencing(data_set, new_node); data_set 581 lib/pengine/unpack.c add_node_attrs(xml_obj, new_node, FALSE, data_set); data_set 584 lib/pengine/unpack.c FALSE, data_set); data_set 590 lib/pengine/unpack.c if (data_set->localhost && pe_find_node(data_set->nodes, data_set->localhost) == NULL) { data_set 592 lib/pengine/unpack.c pe_create_node(data_set->localhost, data_set->localhost, NULL, 0, data_set 593 lib/pengine/unpack.c data_set); data_set 600 lib/pengine/unpack.c setup_container(pe_resource_t * rsc, pe_working_set_t * data_set) data_set 605 lib/pengine/unpack.c g_list_foreach(rsc->children, (GFunc) setup_container, data_set); data_set 611 lib/pengine/unpack.c pe_resource_t *container = pe_find_resource(data_set->resources, container_id); data_set 625 lib/pengine/unpack.c unpack_remote_nodes(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 644 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 648 lib/pengine/unpack.c data_set); data_set 661 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj, xml_resources, data_set); data_set 662 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 666 lib/pengine/unpack.c data_set); data_set 679 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj2, xml_resources, data_set); data_set 681 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 685 lib/pengine/unpack.c data_set); data_set 702 lib/pengine/unpack.c link_rsc2remotenode(pe_working_set_t *data_set, pe_resource_t *new_rsc) data_set 710 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 715 lib/pengine/unpack.c remote_node = pe_find_node(data_set->nodes, new_rsc->id); data_set 726 lib/pengine/unpack.c handle_startup_fencing(data_set, remote_node); data_set 762 lib/pengine/unpack.c unpack_resources(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 767 lib/pengine/unpack.c data_set->template_rsc_sets = pcmk__strkey_table(free, destroy_tag); data_set 783 lib/pengine/unpack.c if (g_hash_table_lookup_extended(data_set->template_rsc_sets, id, data_set 786 lib/pengine/unpack.c g_hash_table_insert(data_set->template_rsc_sets, strdup(id), NULL); data_set 793 lib/pengine/unpack.c data_set) == pcmk_rc_ok) { data_set 794 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, data_set 813 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) { data_set 816 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 817 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 828 lib/pengine/unpack.c unpack_tags(xmlNode * xml_tags, pe_working_set_t * data_set) data_set 832 lib/pengine/unpack.c data_set->tags = pcmk__strkey_table(free, destroy_tag); data_set 865 lib/pengine/unpack.c if (add_tag_ref(data_set->tags, tag_id, obj_ref) == FALSE) { data_set 877 lib/pengine/unpack.c unpack_ticket_state(xmlNode * xml_ticket, pe_working_set_t * data_set) data_set 894 lib/pengine/unpack.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 896 lib/pengine/unpack.c ticket = ticket_new(ticket_id, data_set); data_set 945 lib/pengine/unpack.c unpack_tickets_state(xmlNode * xml_tickets, pe_working_set_t * data_set) data_set 955 lib/pengine/unpack.c unpack_ticket_state(xml_obj, data_set); data_set 962 lib/pengine/unpack.c unpack_handle_remote_attrs(pe_node_t *this_node, xmlNode *state, pe_working_set_t * data_set) data_set 986 lib/pengine/unpack.c add_node_attrs(attrs, this_node, TRUE, data_set); data_set 1007 lib/pengine/unpack.c && !pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1035 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 1040 lib/pengine/unpack.c add_node_attrs(attrs, node, TRUE, data_set); data_set 1073 lib/pengine/unpack.c unpack_node_state(xmlNode *state, pe_working_set_t *data_set) data_set 1093 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1111 lib/pengine/unpack.c unpack_transient_attributes(state, this_node, data_set); data_set 1121 lib/pengine/unpack.c determine_online_status(state, this_node, data_set); data_set 1123 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_have_quorum) data_set 1125 lib/pengine/unpack.c && (data_set->no_quorum_policy == no_quorum_suicide)) { data_set 1130 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "cluster does not have quorum", data_set 1153 lib/pengine/unpack.c unpack_node_history(xmlNode *status, bool fence, pe_working_set_t *data_set) data_set 1172 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1213 lib/pengine/unpack.c || (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock) data_set 1225 lib/pengine/unpack.c } else if (!pcmk_any_flags_set(data_set->flags, pe_flag_stonith_enabled data_set 1234 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1235 lib/pengine/unpack.c unpack_handle_remote_attrs(this_node, state, data_set); data_set 1242 lib/pengine/unpack.c unpack_node_lrm(this_node, state, data_set); data_set 1253 lib/pengine/unpack.c unpack_status(xmlNode * status, pe_working_set_t * data_set) data_set 1259 lib/pengine/unpack.c if (data_set->tickets == NULL) { data_set 1260 lib/pengine/unpack.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 1267 lib/pengine/unpack.c unpack_tickets_state((xmlNode *) state, data_set); data_set 1270 lib/pengine/unpack.c unpack_node_state(state, data_set); data_set 1274 lib/pengine/unpack.c while (unpack_node_history(status, FALSE, data_set) == EAGAIN) { data_set 1280 lib/pengine/unpack.c pcmk_is_set(data_set->flags, pe_flag_stonith_enabled), data_set 1281 lib/pengine/unpack.c data_set); data_set 1286 lib/pengine/unpack.c if (data_set->stop_needed != NULL) { data_set 1287 lib/pengine/unpack.c for (GList *item = data_set->stop_needed; item; item = item->next) { data_set 1295 lib/pengine/unpack.c g_list_free(data_set->stop_needed); data_set 1296 lib/pengine/unpack.c data_set->stop_needed = NULL; data_set 1303 lib/pengine/unpack.c for (GList *gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1315 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1323 lib/pengine/unpack.c determine_online_status_no_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1351 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is unexpectedly down", FALSE); data_set 1360 lib/pengine/unpack.c determine_online_status_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1409 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer has not been seen by the cluster", FALSE); data_set 1412 lib/pengine/unpack.c pe_fence_node(data_set, this_node, data_set 1435 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is no longer part of the cluster", TRUE); data_set 1438 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer process is no longer available", FALSE); data_set 1442 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "termination was requested", FALSE); data_set 1453 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer was in an unknown state", FALSE); data_set 1465 lib/pengine/unpack.c determine_remote_online_status(pe_working_set_t * data_set, pe_node_t * this_node) data_set 1534 lib/pengine/unpack.c determine_online_status(xmlNode * node_state, pe_node_t * this_node, pe_working_set_t * data_set) data_set 1558 lib/pengine/unpack.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1559 lib/pengine/unpack.c online = determine_online_status_no_fencing(data_set, node_state, this_node); data_set 1562 lib/pengine/unpack.c online = determine_online_status_fencing(data_set, node_state, this_node); data_set 1685 lib/pengine/unpack.c create_fake_resource(const char *rsc_id, xmlNode * rsc_entry, pe_working_set_t * data_set) data_set 1694 lib/pengine/unpack.c if (pe__unpack_resource(xml_rsc, &rsc, NULL, data_set) != pcmk_rc_ok) { data_set 1702 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); data_set 1704 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); data_set 1706 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 1720 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, rsc); data_set 1730 lib/pengine/unpack.c pe_node_t *node, pe_working_set_t *data_set) data_set 1732 lib/pengine/unpack.c pe_resource_t *top = pe__create_clone_child(parent, data_set); data_set 1757 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, pe_node_t * node, pe_resource_t * parent, data_set 1868 lib/pengine/unpack.c && !pe__is_universal_clone(parent, data_set)) { data_set 1874 lib/pengine/unpack.c rsc = create_anonymous_orphan(parent, rsc_id, node, data_set); data_set 1881 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, pe_node_t * node, const char *rsc_id, data_set 1888 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1896 lib/pengine/unpack.c pe_resource_t *clone0 = pe_find_resource(data_set->resources, clone0_id); data_set 1924 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); data_set 1942 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, pe_node_t * node, pe_working_set_t * data_set) data_set 1948 lib/pengine/unpack.c rsc = create_fake_resource(rsc_id, rsc_entry, data_set); data_set 1953 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_stop_rsc_orphans)) { data_set 1959 lib/pengine/unpack.c resource_location(rsc, NULL, -INFINITY, "__orphan_do_not_run__", data_set); data_set 1967 lib/pengine/unpack.c xmlNode * migrate_op, pe_working_set_t * data_set) data_set 2019 lib/pengine/unpack.c } else if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2042 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2072 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); data_set 2093 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); data_set 2115 lib/pengine/unpack.c data_set->stop_needed = g_list_prepend(data_set->stop_needed, data_set 2126 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2129 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2138 lib/pengine/unpack.c pe_fence_node(data_set, tmpnode, data_set 2161 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2180 lib/pengine/unpack.c native_add_running(rsc, node, data_set, (save_on_fail != action_fail_ignore)); data_set 2232 lib/pengine/unpack.c GList *sorted_op_list, pe_working_set_t * data_set) data_set 2285 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); data_set 2340 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2347 lib/pengine/unpack.c if ((data_set->shutdown_lock > 0) data_set 2348 lib/pengine/unpack.c && (get_effective_time(data_set) data_set 2349 lib/pengine/unpack.c > (lock_time + data_set->shutdown_lock))) { data_set 2352 lib/pengine/unpack.c pe__clear_resource_history(rsc, node, data_set); data_set 2372 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2408 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2416 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, lrm_resource); data_set 2422 lib/pengine/unpack.c rsc = process_orphan_resource(lrm_resource, node, data_set); data_set 2428 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_shutdown_lock)) { data_set 2429 lib/pengine/unpack.c unpack_shutdown_lock(lrm_resource, rsc, node, data_set); data_set 2445 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); data_set 2450 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); data_set 2455 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); data_set 2476 lib/pengine/unpack.c handle_orphaned_container_fillers(xmlNode * lrm_rsc_list, pe_working_set_t * data_set) data_set 2497 lib/pengine/unpack.c container = pe_find_resource(data_set->resources, container_id); data_set 2502 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 2525 lib/pengine/unpack.c unpack_node_lrm(pe_node_t *node, xmlNode *xml, pe_working_set_t *data_set) data_set 2543 lib/pengine/unpack.c pe_resource_t *rsc = unpack_lrm_resource(node, rsc_entry, data_set); data_set 2555 lib/pengine/unpack.c handle_orphaned_container_fillers(xml, data_set); data_set 2582 lib/pengine/unpack.c int target_rc, pe_working_set_t *data_set) data_set 2612 lib/pengine/unpack.c xml = get_xpath_object((const char *) xpath->str, data_set->input, data_set 2631 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2646 lib/pengine/unpack.c xml = get_xpath_object((const char *) xpath->str, data_set->input, data_set 2655 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2659 lib/pengine/unpack.c lrm_resource = find_lrm_resource(rsc_id, node_name, data_set); data_set 2682 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2688 lib/pengine/unpack.c NULL, PCMK_OCF_NOT_RUNNING, data_set); data_set 2707 lib/pengine/unpack.c bool same_node, pe_working_set_t *data_set) data_set 2711 lib/pengine/unpack.c lrm_resource = find_lrm_resource(rsc_id, node_name, data_set); data_set 2751 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2791 lib/pengine/unpack.c return non_monitor_after(rsc_id, node_name, xml_op, same_node, data_set) data_set 2793 lib/pengine/unpack.c data_set); data_set 2798 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2855 lib/pengine/unpack.c data_set); data_set 2859 lib/pengine/unpack.c source, -1, data_set); data_set 2872 lib/pengine/unpack.c migrate_from, data_set); data_set 2881 lib/pengine/unpack.c target_node = pe_find_node(data_set->nodes, target); data_set 2882 lib/pengine/unpack.c source_node = pe_find_node(data_set->nodes, source); data_set 2910 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, TRUE); data_set 2931 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2955 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 2971 lib/pengine/unpack.c source, PCMK_OCF_OK, data_set); data_set 2978 lib/pengine/unpack.c !unknown_on_node(rsc->id, target, data_set) data_set 2983 lib/pengine/unpack.c data_set)) { data_set 2988 lib/pengine/unpack.c pe_node_t *target_node = pe_find_node(data_set->nodes, target); data_set 2991 lib/pengine/unpack.c native_add_running(rsc, target_node, data_set, FALSE); data_set 2994 lib/pengine/unpack.c } else if (!non_monitor_after(rsc->id, source, xml_op, true, data_set)) { data_set 3007 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 3023 lib/pengine/unpack.c source, target, PCMK_OCF_OK, data_set); data_set 3030 lib/pengine/unpack.c !unknown_on_node(rsc->id, source, data_set) data_set 3035 lib/pengine/unpack.c data_set)) { data_set 3039 lib/pengine/unpack.c pe_node_t *source_node = pe_find_node(data_set->nodes, source); data_set 3042 lib/pengine/unpack.c native_add_running(rsc, source_node, data_set, TRUE); data_set 3049 lib/pengine/unpack.c const pe_resource_t *rsc, pe_working_set_t *data_set) data_set 3058 lib/pengine/unpack.c for (xIter = data_set->failed->children; xIter; xIter = xIter->next) { data_set 3072 lib/pengine/unpack.c add_node_copy(data_set->failed, op); data_set 3196 lib/pengine/unpack.c enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3217 lib/pengine/unpack.c if (!pcmk_is_set(data_set->flags, pe_flag_symmetric_cluster) data_set 3245 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3248 lib/pengine/unpack.c action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3256 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); data_set 3259 lib/pengine/unpack.c unpack_migrate_to_failure(rsc, node, xml_op, data_set); data_set 3262 lib/pengine/unpack.c unpack_migrate_from_failure(rsc, node, xml_op, data_set); data_set 3327 lib/pengine/unpack.c fail_rsc->allowed_nodes = pe__node_list2table(data_set->nodes); data_set 3356 lib/pengine/unpack.c if (pe_can_fence(node->details->data_set, node)) { data_set 3401 lib/pengine/unpack.c pe_working_set_t *data_set, enum action_fail_response *on_fail, data_set 3415 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3559 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3563 lib/pengine/unpack.c if (pe__bundle_needs_remote_name(rsc, data_set)) { data_set 3569 lib/pengine/unpack.c data_set); data_set 3574 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); data_set 3594 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3596 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, remote_conn->id); data_set 3600 lib/pengine/unpack.c FALSE, data_set); data_set 3609 lib/pengine/unpack.c bool is_last_failure, pe_working_set_t *data_set) data_set 3632 lib/pengine/unpack.c && pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3635 lib/pengine/unpack.c pe_node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 3672 lib/pengine/unpack.c xmlNode *xml_op, pe_working_set_t *data_set) data_set 3690 lib/pengine/unpack.c time_t now = get_effective_time(data_set); data_set 3696 lib/pengine/unpack.c is_last_failure, data_set)) { data_set 3703 lib/pengine/unpack.c data_set); data_set 3713 lib/pengine/unpack.c pe__update_recheck_time(last_failure, data_set); data_set 3718 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, NULL, pe_fc_default, xml_op, data_set)) { data_set 3745 lib/pengine/unpack.c && should_clear_for_param_change(xml_op, task, rsc, node, data_set)) { data_set 3752 lib/pengine/unpack.c data_set); data_set 3754 lib/pengine/unpack.c if (pcmk_is_set(data_set->flags, pe_flag_stonith_enabled) data_set 3766 lib/pengine/unpack.c order_after_remote_fencing(clear_op, rsc, data_set); data_set 3799 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 3802 lib/pengine/unpack.c pe_action_t *action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3812 lib/pengine/unpack.c xmlNode * last_failure, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3864 lib/pengine/unpack.c unpack_migrate_to_success(rsc, node, xml_op, data_set); data_set 3910 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 3980 lib/pengine/unpack.c && check_operation_expiry(rsc, node, rc, xml_op, data_set)) { data_set 3987 lib/pengine/unpack.c remap_operation(xml_op, rsc, node, data_set, on_fail, target_rc, data_set 4032 lib/pengine/unpack.c on_fail, data_set); data_set 4035 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 4036 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "masked-probe-failure", data_set); data_set 4061 lib/pengine/unpack.c pe_node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 4089 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); data_set 4093 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 4103 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 4104 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 4135 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 4148 lib/pengine/unpack.c on_fail, data_set); data_set 4152 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 4161 lib/pengine/unpack.c data_set); data_set 4171 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 4179 lib/pengine/unpack.c resource_location(parent, NULL, -INFINITY, "fatal-error", data_set); data_set 4191 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 4198 lib/pengine/unpack.c .now = data_set->now, data_set 4209 lib/pengine/unpack.c if (pcmk__str_eq(node->details->id, data_set->dc_uuid, pcmk__str_casei)) { data_set 4210 lib/pengine/unpack.c data_set->dc_node = node; data_set 4219 lib/pengine/unpack.c cluster_name = g_hash_table_lookup(data_set->config_hash, "cluster-name"); data_set 4226 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set); data_set 4311 lib/pengine/unpack.c pe_working_set_t * data_set) data_set 4317 lib/pengine/unpack.c xmlNode *status = find_xml_node(data_set->input, XML_CIB_TAG_STATUS, TRUE); data_set 4333 lib/pengine/unpack.c this_node = pe_find_node(data_set->nodes, uname); data_set 4339 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 4342 lib/pengine/unpack.c determine_online_status(node_state, this_node, data_set); data_set 4346 lib/pengine/unpack.c || pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 36 lib/pengine/utils.c pe_can_fence(pe_working_set_t *data_set, pe_node_t *node) data_set 48 lib/pengine/utils.c && !pe_can_fence(data_set, container_node)) { data_set 54 lib/pengine/utils.c } else if (!pcmk_is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 57 lib/pengine/utils.c } else if (!pcmk_is_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 60 lib/pengine/utils.c } else if (pcmk_is_set(data_set->flags, pe_flag_have_quorum)) { data_set 63 lib/pengine/utils.c } else if (data_set->no_quorum_policy == no_quorum_ignore) { data_set 211 lib/pengine/utils.c GHashTable *nodes, pe_working_set_t *data_set) data_set 213 lib/pengine/utils.c pcmk__output_t *out = data_set->priv; data_set 282 lib/pengine/utils.c GHashTable *nodes, pe_working_set_t *data_set) data_set 296 lib/pengine/utils.c pe__output_node_weights(rsc, comment, nodes, data_set); data_set 305 lib/pengine/utils.c comment, child->allowed_nodes, data_set); data_set 386 lib/pengine/utils.c pe_working_set_t * data_set) data_set 391 lib/pengine/utils.c } else if (data_set != NULL) { data_set 392 lib/pengine/utils.c GList *gIter = data_set->nodes; data_set 421 lib/pengine/utils.c get_effective_time(pe_working_set_t * data_set) data_set 423 lib/pengine/utils.c if(data_set) { data_set 424 lib/pengine/utils.c if (data_set->now == NULL) { data_set 426 lib/pengine/utils.c data_set->now = crm_time_new(NULL); data_set 428 lib/pengine/utils.c return crm_time_get_seconds_since_epoch(data_set->now); data_set 533 lib/pengine/utils.c ticket_new(const char *ticket_id, pe_working_set_t * data_set) data_set 541 lib/pengine/utils.c if (data_set->tickets == NULL) { data_set 542 lib/pengine/utils.c data_set->tickets = pcmk__strkey_table(free, destroy_ticket); data_set 545 lib/pengine/utils.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 562 lib/pengine/utils.c g_hash_table_insert(data_set->tickets, strdup(ticket->id), ticket); data_set 586 lib/pengine/utils.c pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag) data_set 588 lib/pengine/utils.c for (GList *lpc = data_set->resources; lpc != NULL; lpc = lpc->next) { data_set 605 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 607 lib/pengine/utils.c if (!pcmk_is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 620 lib/pengine/utils.c pe_action_t *unfence = pe_fence_op(node, "on", FALSE, reason, FALSE, data_set); data_set 632 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); data_set 703 lib/pengine/utils.c pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set) data_set 705 lib/pengine/utils.c if ((recheck > get_effective_time(data_set)) data_set 706 lib/pengine/utils.c && ((data_set->recheck_by == 0) data_set 707 lib/pengine/utils.c || (data_set->recheck_by > recheck))) { data_set 708 lib/pengine/utils.c data_set->recheck_by = recheck; data_set 720 lib/pengine/utils.c pe_working_set_t *data_set) data_set 724 lib/pengine/utils.c pe_eval_nvpairs(data_set->input, xml_obj, set_name, rule_data, hash, data_set 729 lib/pengine/utils.c pe__update_recheck_time(recheck, data_set); data_set 794 lib/pengine/utils.c pe__build_node_name_list(pe_working_set_t *data_set, const char *s) { data_set 804 lib/pengine/utils.c pe_node_t *node = pe_find_node(data_set->nodes, s); data_set 818 lib/pengine/utils.c nodes = pe__unames_with_tag(data_set, s); data_set 826 lib/pengine/utils.c pe__build_rsc_list(pe_working_set_t *data_set, const char *s) { data_set 832 lib/pengine/utils.c pe_resource_t *rsc = pe_find_resource_with_flags(data_set->resources, s, data_set 851 lib/pengine/utils.c resources = pe__rscs_with_tag(data_set, s); data_set 186 tools/crm_resource.c static pe_working_set_t *data_set = NULL; data_set 229 tools/crm_resource.c pe_free_working_set(data_set); data_set 230 tools/crm_resource.c data_set = NULL; data_set 1024 tools/crm_resource.c options.interval_spec, TRUE, data_set, options.force); data_set 1047 tools/crm_resource.c before = build_constraint_list(data_set->input); data_set 1051 tools/crm_resource.c rc = cli_resource_clear_all_expired(data_set->input, cib_conn, options.cib_options, data_set 1056 tools/crm_resource.c dest = pe_find_node(data_set->nodes, options.host_uname); data_set 1068 tools/crm_resource.c rc = cli_resource_clear(options.rsc_id, NULL, data_set->nodes, data_set 1085 tools/crm_resource.c data_set->input = *cib_xml_copy; data_set 1086 tools/crm_resource.c cluster_status(data_set); data_set 1088 tools/crm_resource.c after = build_constraint_list(data_set->input); data_set 1254 tools/crm_resource.c data_set = pe_new_working_set(); data_set 1255 tools/crm_resource.c if (data_set == NULL) { data_set 1258 tools/crm_resource.c pe__set_working_set_flags(data_set, data_set 1260 tools/crm_resource.c data_set->priv = out; data_set 1261 tools/crm_resource.c rc = update_working_set_xml(data_set, cib_xml_copy); data_set 1271 tools/crm_resource.c cluster_status(data_set); data_set 1283 tools/crm_resource.c pe_node_t *node = pe_find_node(data_set->nodes, options.host_uname); data_set 1331 tools/crm_resource.c FALSE, data_set, options.force); data_set 1765 tools/crm_resource.c rsc = pe_find_resource_with_flags(data_set->resources, options.rsc_id, data_set 1788 tools/crm_resource.c if ((options.host_uname != NULL) && (data_set != NULL)) { data_set 1789 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1827 tools/crm_resource.c rc = out->message(out, "resource-list", data_set, data_set 1839 tools/crm_resource.c rc = out->message(out, "resource-names-list", data_set->resources); data_set 1887 tools/crm_resource.c options.timeout_ms, cib_conn, data_set, data_set 1893 tools/crm_resource.c node = pe_find_node(data_set->nodes, options.host_uname); data_set 1903 tools/crm_resource.c rc = out->message(out, "locations-and-colocations", rsc, data_set, data_set 1909 tools/crm_resource.c g_list_foreach(data_set->resources, (GFunc) cli_resource_print_cts, out); data_set 1910 tools/crm_resource.c cli_resource_print_cts_constraints(data_set); data_set 1915 tools/crm_resource.c options.rsc_id, data_set); data_set 1924 tools/crm_resource.c data_set); data_set 1930 tools/crm_resource.c data_set); data_set 1934 tools/crm_resource.c GList *nodes = cli_resource_search(rsc, options.rsc_id, data_set); data_set 1941 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, true); data_set 1945 tools/crm_resource.c rc = cli_resource_print(rsc, data_set, false); data_set 1953 tools/crm_resource.c data_set->resources, rsc, node); data_set 1967 tools/crm_resource.c options.cib_options, data_set, data_set 2026 tools/crm_resource.c params = pe_rsc_params(rsc, current, data_set); data_set 2031 tools/crm_resource.c get_meta_attributes(params, rsc, current, data_set); data_set 2036 tools/crm_resource.c NULL, FALSE, data_set); data_set 2062 tools/crm_resource.c options.cib_options, data_set, data_set 2073 tools/crm_resource.c options.cib_options, data_set, data_set 2081 tools/crm_resource.c data_set); data_set 65 tools/crm_resource.h void cli_resource_print_cts_constraints(pe_working_set_t * data_set); data_set 67 tools/crm_resource.h int cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded); data_set 69 tools/crm_resource.h bool active, pe_working_set_t * data_set); data_set 75 tools/crm_resource.h const char *rsc_id, pe_working_set_t *data_set); data_set 77 tools/crm_resource.h pe_working_set_t *data_set); data_set 81 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 84 tools/crm_resource.h pe_working_set_t *data_set); data_set 90 tools/crm_resource.h pe_working_set_t *data_set, gboolean promoted_role_only, data_set 100 tools/crm_resource.h int timeout_ms, cib_t *cib, pe_working_set_t *data_set, data_set 108 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 113 tools/crm_resource.h pe_working_set_t *data_set, gboolean force); data_set 115 tools/crm_resource.h int update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml); data_set 23 tools/crm_resource_print.c pe_working_set_t *data_set = (pe_working_set_t *) userdata; data_set 24 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 34 tools/crm_resource_print.c if (pe_evaluate_rules(lifetime, NULL, data_set->now, NULL) == FALSE) { data_set 55 tools/crm_resource_print.c cli_resource_print_cts_constraints(pe_working_set_t * data_set) data_set 57 tools/crm_resource_print.c pcmk__xe_foreach_child(pcmk_find_cib_element(data_set->input, XML_CIB_TAG_CONSTRAINTS), data_set 58 tools/crm_resource_print.c NULL, print_constraint, data_set); data_set 93 tools/crm_resource_print.c bool active, pe_working_set_t * data_set) data_set 95 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 97 tools/crm_resource_print.c GList *ops = find_operations(rsc_id, host_uname, active, data_set); data_set 108 tools/crm_resource_print.c out->message(out, "node-and-op", data_set, xml_op); data_set 117 tools/crm_resource_print.c cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded) data_set 119 tools/crm_resource_print.c pcmk__output_t *out = data_set->priv; data_set 42 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 258 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 260 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 374 tools/crm_resource_runtime.c pcmk__unpack_constraints(data_set); data_set 375 tools/crm_resource_runtime.c pe__clear_resource_flags_on_all(data_set, pe_rsc_allocating); data_set 394 tools/crm_resource_runtime.c data_set, force); data_set 409 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 411 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 477 tools/crm_resource_runtime.c const char *host_uname, const char *rsc_id, pe_working_set_t *data_set) data_set 479 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 487 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 507 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, host_uname); data_set 570 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 579 tools/crm_resource_runtime.c rc = send_lrm_rsc_op(controld_api, false, host_uname, rsc_id, data_set); data_set 597 tools/crm_resource_runtime.c const char *interval_spec, pe_working_set_t *data_set) data_set 618 tools/crm_resource_runtime.c for (xmlNode *xml_op = pcmk__xml_first_child(data_set->failed); data_set 630 tools/crm_resource_runtime.c pe_resource_t *fail_rsc = pe_find_resource_with_flags(data_set->resources, data_set 665 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, node_name, failed_id, data_set); data_set 699 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean force) data_set 701 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 715 tools/crm_resource_runtime.c interval_spec, just_failures, data_set, force); data_set 727 tools/crm_resource_runtime.c nodes = pcmk__copy_node_list(data_set->nodes, false); data_set 750 tools/crm_resource_runtime.c data_set, force); data_set 762 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); data_set 791 tools/crm_resource_runtime.c interval_spec, data_set); data_set 793 tools/crm_resource_runtime.c rc = clear_rsc_history(controld_api, host_uname, rsc->id, data_set); data_set 808 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 810 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 822 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, node_name); data_set 843 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 850 tools/crm_resource_runtime.c for (GList *iter = data_set->nodes; iter; iter = iter->next) { data_set 854 tools/crm_resource_runtime.c operation, interval_spec, data_set); data_set 916 tools/crm_resource_runtime.c switch (pe__health_strategy(node->details->data_set)) { data_set 984 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t *data_set) data_set 987 tools/crm_resource_runtime.c return send_lrm_rsc_op(controld_api, true, host_uname, rsc_id, data_set); data_set 992 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 1003 tools/crm_resource_runtime.c params = pe_rsc_params(rsc, node, data_set); data_set 1012 tools/crm_resource_runtime.c get_meta_attributes(meta, rsc, node, data_set); data_set 1129 tools/crm_resource_runtime.c update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml) data_set 1134 tools/crm_resource_runtime.c data_set->input = *xml; data_set 1135 tools/crm_resource_runtime.c data_set->now = crm_time_new(NULL); data_set 1151 tools/crm_resource_runtime.c update_working_set_from_cib(pcmk__output_t *out, pe_working_set_t * data_set, data_set 1164 tools/crm_resource_runtime.c rc = update_working_set_xml(data_set, &cib_xml_copy); data_set 1176 tools/crm_resource_runtime.c update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate) data_set 1183 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1185 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1186 tools/crm_resource_runtime.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 1187 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1205 tools/crm_resource_runtime.c rc = write_xml_file(data_set->input, shadow_file, FALSE); data_set 1220 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set->input, data_set 1221 tools/crm_resource_runtime.c pe_flag_no_counts|pe_flag_no_compat, data_set); data_set 1225 tools/crm_resource_runtime.c pcmk__simulate_transition(data_set, shadow_cib, NULL); data_set 1228 tools/crm_resource_runtime.c rc = update_dataset(shadow_cib, data_set, false); data_set 1231 tools/crm_resource_runtime.c cluster_status(data_set); data_set 1248 tools/crm_resource_runtime.c max_delay_for_resource(pe_working_set_t * data_set, pe_resource_t *rsc) data_set 1259 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, child); data_set 1269 tools/crm_resource_runtime.c pe_action_t *stop = custom_action(rsc, key, RSC_STOP, NULL, TRUE, FALSE, data_set); data_set 1286 tools/crm_resource_runtime.c max_delay_in(pe_working_set_t * data_set, GList *resources) data_set 1293 tools/crm_resource_runtime.c pe_resource_t *rsc = pe_find_resource(data_set->resources, (const char *)item->data); data_set 1295 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, rsc); data_set 1346 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1419 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1420 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1426 tools/crm_resource_runtime.c data_set->priv = out; data_set 1427 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, false); data_set 1434 tools/crm_resource_runtime.c restart_target_active = get_active_resources(host, data_set->resources); data_set 1435 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1456 tools/crm_resource_runtime.c data_set, force); data_set 1471 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, true); data_set 1477 tools/crm_resource_runtime.c target_active = get_active_resources(host, data_set->resources); data_set 1488 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1498 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, FALSE); data_set 1508 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set->resources); data_set 1534 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1540 tools/crm_resource_runtime.c cib_options, data_set, force); data_set 1561 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(data_set, list_delta) / sleep_interval; data_set 1573 tools/crm_resource_runtime.c rc = update_dataset(cib, data_set, false); data_set 1587 tools/crm_resource_runtime.c current_active = get_active_resources(NULL, data_set->resources); data_set 1613 tools/crm_resource_runtime.c FALSE, cib, cib_options, data_set, force); data_set 1618 tools/crm_resource_runtime.c data_set, force); data_set 1636 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1718 tools/crm_resource_runtime.c pe_working_set_t *data_set = NULL; data_set 1725 tools/crm_resource_runtime.c data_set = pe_new_working_set(); data_set 1726 tools/crm_resource_runtime.c if (data_set == NULL) { data_set 1737 tools/crm_resource_runtime.c print_pending_actions(out, data_set->actions); data_set 1738 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1746 tools/crm_resource_runtime.c pe_reset_working_set(data_set); data_set 1747 tools/crm_resource_runtime.c rc = update_working_set_from_cib(out, data_set, cib); data_set 1749 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1752 tools/crm_resource_runtime.c pcmk__schedule_actions(data_set->input, data_set 1753 tools/crm_resource_runtime.c pe_flag_no_counts|pe_flag_no_compat, data_set); data_set 1764 tools/crm_resource_runtime.c const char *dc_version = g_hash_table_lookup(data_set->config_hash, data_set 1774 tools/crm_resource_runtime.c } while (actions_are_pending(data_set->actions)); data_set 1776 tools/crm_resource_runtime.c pe_free_working_set(data_set); data_set 1934 tools/crm_resource_runtime.c int timeout_ms, cib_t * cib, pe_working_set_t *data_set, data_set 1937 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 1948 tools/crm_resource_runtime.c GList *nodes = cli_resource_search(rsc, requested_name, data_set); data_set 1979 tools/crm_resource_runtime.c data_set); data_set 1982 tools/crm_resource_runtime.c timeout_ms = pe_get_configured_timeout(rsc, get_action(rsc_action), data_set); data_set 1997 tools/crm_resource_runtime.c pe_working_set_t *data_set, gboolean promoted_role_only, data_set 2000 tools/crm_resource_runtime.c pcmk__output_t *out = data_set->priv; data_set 2004 tools/crm_resource_runtime.c pe_node_t *dest = pe_find_node(data_set->nodes, host_name); data_set 2070 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, NULL, data_set->nodes, cib, cib_options, false, force); data_set 2073 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib, data_set 453 tools/crm_simulate.c pe_working_set_t *data_set = NULL; data_set 516 tools/crm_simulate.c data_set = pe_new_working_set(); data_set 517 tools/crm_simulate.c if (data_set == NULL) { data_set 524 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_scores); data_set 527 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_show_utilization); data_set 529 tools/crm_simulate.c pe__set_working_set_flags(data_set, pe_flag_no_compat); data_set 532 tools/crm_simulate.c data_set->priv = out; data_set 533 tools/crm_simulate.c pcmk__profile_dir(options.test_dir, options.repeat, data_set, options.use_date); data_set 543 tools/crm_simulate.c rc = pcmk__simulate(data_set, out, options.injections, options.flags, section_opts, data_set 563 tools/crm_simulate.c if (data_set) { data_set 564 tools/crm_simulate.c pe_free_working_set(data_set); data_set 257 tools/crm_ticket.c find_ticket(gchar *ticket_id, pe_working_set_t * data_set) data_set 259 tools/crm_ticket.c return g_hash_table_lookup(data_set->tickets, ticket_id); data_set 328 tools/crm_ticket.c print_ticket_list(pe_working_set_t * data_set, bool raw, bool details) data_set 333 tools/crm_ticket.c g_hash_table_iter_init(&iter, data_set->tickets); data_set 474 tools/crm_ticket.c pe_working_set_t * data_set) data_set 481 tools/crm_ticket.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 567 tools/crm_ticket.c modify_ticket_state(gchar * ticket_id, cib_t * cib, pe_working_set_t * data_set) data_set 608 tools/crm_ticket.c ticket = find_ticket(ticket_id, data_set); data_set 722 tools/crm_ticket.c pe_working_set_t *data_set = NULL; data_set 754 tools/crm_ticket.c data_set = pe_new_working_set(); data_set 755 tools/crm_ticket.c if (data_set == NULL) { data_set 760 tools/crm_ticket.c pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat); data_set 801 tools/crm_ticket.c data_set->input = cib_xml_copy; data_set 802 tools/crm_ticket.c data_set->now = crm_time_new(NULL); data_set 804 tools/crm_ticket.c cluster_status(data_set); data_set 808 tools/crm_ticket.c pcmk__unpack_constraints(data_set); data_set 821 tools/crm_ticket.c pe_ticket_t *ticket = find_ticket(options.ticket_id, data_set); data_set 832 tools/crm_ticket.c print_ticket_list(data_set, raw, details); data_set 863 tools/crm_ticket.c rc = get_ticket_state_attr(options.ticket_id, options.get_attr_name, &value, data_set); data_set 883 tools/crm_ticket.c ticket = find_ticket(options.ticket_id, data_set); data_set 937 tools/crm_ticket.c rc = modify_ticket_state(options.ticket_id, cib_conn, data_set); data_set 988 tools/crm_ticket.c pe_free_working_set(data_set); data_set 989 tools/crm_ticket.c data_set = NULL; data_set 108 tools/crm_verify.c pe_working_set_t *data_set = NULL; data_set 218 tools/crm_verify.c data_set = pe_new_working_set(); data_set 219 tools/crm_verify.c if (data_set == NULL) { data_set 224 tools/crm_verify.c data_set->priv = out; data_set 238 tools/crm_verify.c pcmk__schedule_actions(cib_object, flags, data_set); data_set 240 tools/crm_verify.c pe_free_working_set(data_set);