data_set 608 fencing/main.c static void cib_device_update(resource_t *rsc, pe_working_set_t *data_set) data_set 622 fencing/main.c cib_device_update(gIter->data, data_set); data_set 683 fencing/main.c get_rsc_attributes(rsc->parameters, rsc, node, data_set); data_set 684 fencing/main.c get_meta_attributes(rsc->meta, rsc, node, data_set); data_set 712 fencing/main.c extern xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 722 fencing/main.c pe_working_set_t data_set; data_set 729 fencing/main.c set_working_set_defaults(&data_set); data_set 730 fencing/main.c data_set.input = local_cib; data_set 731 fencing/main.c data_set.now = crm_time_new(NULL); data_set 732 fencing/main.c data_set.flags |= pe_flag_quick_location; data_set 733 fencing/main.c data_set.localhost = stonith_our_uname; data_set 735 fencing/main.c cluster_status(&data_set); data_set 736 fencing/main.c do_calculations(&data_set, NULL, NULL); data_set 738 fencing/main.c for (gIter = data_set.resources; gIter != NULL; gIter = gIter->next) { data_set 739 fencing/main.c cib_device_update(gIter->data, &data_set); data_set 741 fencing/main.c data_set.input = NULL; /* Wasn't a copy */ data_set 742 fencing/main.c cleanup_alloc_calculations(&data_set); data_set 56 include/crm/pengine/complex.h pe_working_set_t * data_set); data_set 58 include/crm/pengine/complex.h pe_working_set_t * data_set); data_set 62 include/crm/pengine/complex.h pe_working_set_t * data_set); data_set 57 include/crm/pengine/internal.h bool pe_can_fence(pe_working_set_t *data_set, node_t *node); data_set 64 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 71 include/crm/pengine/internal.h void native_add_running(resource_t * rsc, node_t * node, pe_working_set_t * data_set); data_set 74 include/crm/pengine/internal.h gboolean native_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 75 include/crm/pengine/internal.h gboolean group_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 76 include/crm/pengine/internal.h gboolean clone_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 77 include/crm/pengine/internal.h gboolean master_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 78 include/crm/pengine/internal.h gboolean container_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 107 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 113 include/crm/pengine/internal.h extern time_t get_effective_time(pe_working_set_t * data_set); data_set 126 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 143 include/crm/pengine/internal.h extern action_t *get_pseudo_op(const char *name, pe_working_set_t * data_set); data_set 178 include/crm/pengine/internal.h gboolean optional, gboolean foo, pe_working_set_t * data_set); data_set 183 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 188 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 193 include/crm/pengine/internal.h optional, TRUE, data_set); data_set 199 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 204 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 209 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 214 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 219 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 224 include/crm/pengine/internal.h optional, TRUE, data_set) data_set 227 include/crm/pengine/internal.h pe_working_set_t *data_set); data_set 241 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 247 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 250 include/crm/pengine/internal.h extern ticket_t *ticket_new(const char *ticket_id, pe_working_set_t * data_set); data_set 297 include/crm/pengine/internal.h pe_working_set_t * data_set); data_set 299 include/crm/pengine/internal.h action_t *pe_fence_op(node_t * node, const char *op, bool optional, const char *reason, pe_working_set_t * data_set); data_set 301 include/crm/pengine/internal.h resource_t * rsc, node_t *node, const char *reason, action_t *dependency, pe_working_set_t * data_set); data_set 316 include/crm/pengine/internal.h void pe_fence_node(pe_working_set_t * data_set, node_t * node, const char *reason); data_set 319 include/crm/pengine/internal.h const char *score, pe_working_set_t * data_set); data_set 25 include/crm/pengine/remote.h gboolean is_rsc_baremetal_remote_node(resource_t *rsc, pe_working_set_t * data_set); data_set 26 include/crm/pengine/remote.h resource_t * rsc_contains_remote_node(pe_working_set_t * data_set, resource_t *rsc); data_set 27 include/crm/pengine/remote.h void pe_foreach_guest_node(const pe_working_set_t *data_set, const node_t *host, data_set 466 include/crm/pengine/status.h gboolean cluster_status(pe_working_set_t * data_set); data_set 467 include/crm/pengine/status.h void set_working_set_defaults(pe_working_set_t * data_set); data_set 468 include/crm/pengine/status.h void cleanup_calculations(pe_working_set_t * data_set); data_set 475 include/crm/pengine/status.h pe_working_set_t * data_set); data_set 30 lib/pengine/clone.c void force_non_unique_clone(resource_t * rsc, const char *rid, pe_working_set_t * data_set); data_set 31 lib/pengine/clone.c resource_t *create_child_clone(resource_t * rsc, int sub_id, pe_working_set_t * data_set); data_set 48 lib/pengine/clone.c force_non_unique_clone(resource_t * rsc, const char *rid, pe_working_set_t * data_set) data_set 60 lib/pengine/clone.c clone_data->clone_max = g_list_length(data_set->nodes); data_set 66 lib/pengine/clone.c find_clone_instance(resource_t * rsc, const char *sub_id, pe_working_set_t * data_set) data_set 84 lib/pengine/clone.c create_child_clone(resource_t * rsc, int sub_id, pe_working_set_t * data_set) data_set 108 lib/pengine/clone.c if (common_unpack(child_copy, &child_rsc, rsc, data_set) == FALSE) { data_set 135 lib/pengine/clone.c master_unpack(resource_t * rsc, pe_working_set_t * data_set) data_set 141 lib/pengine/clone.c if (clone_unpack(rsc, data_set)) { data_set 153 lib/pengine/clone.c clone_unpack(resource_t * rsc, pe_working_set_t * data_set) data_set 177 lib/pengine/clone.c } else if (g_list_length(data_set->nodes) > 0) { data_set 178 lib/pengine/clone.c clone_data->clone_max = g_list_length(data_set->nodes); data_set 231 lib/pengine/clone.c if (create_child_clone(rsc, lpc, data_set) == NULL) { data_set 240 lib/pengine/clone.c if (create_child_clone(rsc, -1, data_set) == NULL) { data_set 132 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) data_set 135 lib/pengine/complex.c const char *version = crm_element_value(data_set->input, XML_ATTR_CRM_VERSION); data_set 152 lib/pengine/complex.c unpack_instance_attributes(data_set->input, rsc->xml, XML_TAG_META_SETS, node_hash, data_set 153 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set->now); data_set 159 lib/pengine/complex.c unpack_instance_attributes(data_set->input, rsc->xml, XML_TAG_ATTR_SETS, node_hash, data_set 160 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set->now); data_set 169 lib/pengine/complex.c unpack_instance_attributes(data_set->input, data_set->rsc_defaults, XML_TAG_META_SETS, data_set 170 lib/pengine/complex.c node_hash, meta_hash, NULL, FALSE, data_set->now); data_set 175 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) data_set 183 lib/pengine/complex.c unpack_instance_attributes(data_set->input, rsc->xml, XML_TAG_ATTR_SETS, node_hash, data_set 184 lib/pengine/complex.c meta_hash, NULL, FALSE, data_set->now); data_set 188 lib/pengine/complex.c get_rsc_attributes(meta_hash, rsc->parent, node, data_set); data_set 192 lib/pengine/complex.c unpack_instance_attributes(data_set->input, data_set->rsc_defaults, XML_TAG_ATTR_SETS, data_set 193 lib/pengine/complex.c node_hash, meta_hash, NULL, FALSE, data_set->now); data_set 200 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) data_set 208 lib/pengine/complex.c pe_unpack_versioned_attributes(data_set->input, rsc->xml, XML_TAG_ATTR_SETS, node_hash, data_set 209 lib/pengine/complex.c meta_hash, data_set->now); data_set 213 lib/pengine/complex.c pe_get_versioned_attributes(meta_hash, rsc->parent, node, data_set); data_set 217 lib/pengine/complex.c pe_unpack_versioned_attributes(data_set->input, data_set->rsc_defaults, XML_TAG_ATTR_SETS, data_set 218 lib/pengine/complex.c node_hash, meta_hash, data_set->now); 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 350 lib/pengine/complex.c add_template_rsc(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 376 lib/pengine/complex.c if (add_tag_ref(data_set->template_rsc_sets, template_ref, id) == FALSE) { data_set 466 lib/pengine/complex.c resource_t * parent, pe_working_set_t * data_set) data_set 491 lib/pengine/complex.c if (unpack_template(xml_obj, &expanded_xml, data_set) == FALSE) { data_set 496 lib/pengine/complex.c (*rsc)->cluster = data_set; data_set 513 lib/pengine/complex.c (*rsc)->ops_xml = expand_idref(ops, data_set->input); data_set 547 lib/pengine/complex.c get_meta_attributes((*rsc)->meta, *rsc, NULL, data_set); data_set 548 lib/pengine/complex.c get_rsc_attributes((*rsc)->parameters, *rsc, NULL, data_set); data_set 550 lib/pengine/complex.c pe_get_versioned_attributes((*rsc)->versioned_parameters, *rsc, NULL, data_set); data_set 557 lib/pengine/complex.c if (is_set(data_set->flags, pe_flag_is_managed_default)) { data_set 568 lib/pengine/complex.c (*rsc)->stickiness = data_set->default_resource_stickiness; data_set 631 lib/pengine/complex.c } else if (is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 699 lib/pengine/complex.c legacy = g_hash_table_lookup(data_set->config_hash, data_set 702 lib/pengine/complex.c legacy = g_hash_table_lookup(data_set->config_hash, data_set 739 lib/pengine/complex.c set_bit(data_set->flags, pe_flag_have_stonith_resource); data_set 759 lib/pengine/complex.c } else if (is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 772 lib/pengine/complex.c if (is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 780 lib/pengine/complex.c is_set(data_set->flags, pe_flag_stonith_enabled) ? "" : " (stonith-enabled=false)"); data_set 787 lib/pengine/complex.c } else if (is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 790 lib/pengine/complex.c } else if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 793 lib/pengine/complex.c } else if (data_set->no_quorum_policy == no_quorum_ignore) { data_set 825 lib/pengine/complex.c if ((*rsc)->fns->unpack(*rsc, data_set) == FALSE) { data_set 829 lib/pengine/complex.c if (is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 831 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "symmetric_default", data_set); data_set 836 lib/pengine/complex.c resource_location(*rsc, NULL, 0, "remote_connection_default", data_set); data_set 844 lib/pengine/complex.c unpack_instance_attributes(data_set->input, (*rsc)->xml, XML_TAG_UTILIZATION, NULL, data_set 845 lib/pengine/complex.c (*rsc)->utilization, NULL, FALSE, data_set->now); data_set 850 lib/pengine/complex.c if (add_template_rsc(xml_obj, data_set) == FALSE) { data_set 137 lib/pengine/container.c pe_working_set_t * data_set) data_set 171 lib/pengine/container.c if (common_unpack(xml_ip, &tuple->ip, parent, data_set) == false) { data_set 183 lib/pengine/container.c pe_working_set_t * data_set) data_set 330 lib/pengine/container.c if (common_unpack(xml_docker, &tuple->docker, parent, data_set) == FALSE) { data_set 340 lib/pengine/container.c pe_working_set_t * data_set) data_set 491 lib/pengine/container.c if (common_unpack(xml_docker, &tuple->docker, parent, data_set) == FALSE) { data_set 525 lib/pengine/container.c pe_working_set_t * data_set) data_set 537 lib/pengine/container.c if (remote_id_conflict(id, data_set)) { data_set 541 lib/pengine/container.c CRM_ASSERT(remote_id_conflict(id, data_set) == FALSE); data_set 578 lib/pengine/container.c node = pe_find_node(data_set->nodes, uname); data_set 581 lib/pengine/container.c data_set); data_set 604 lib/pengine/container.c for (rsc_iter = data_set->resources; rsc_iter; rsc_iter = rsc_iter->next) { data_set 623 lib/pengine/container.c if (common_unpack(xml_remote, &tuple->remote, parent, data_set) == FALSE) { data_set 661 lib/pengine/container.c pe_working_set_t * data_set) data_set 665 lib/pengine/container.c create_docker_resource(parent, data, tuple, data_set) == FALSE) { data_set 669 lib/pengine/container.c create_rkt_resource(parent, data, tuple, data_set) == FALSE) { data_set 673 lib/pengine/container.c if(create_ip_resource(parent, data, tuple, data_set) == FALSE) { data_set 676 lib/pengine/container.c if(create_remote_resource(parent, data, tuple, data_set) == FALSE) { data_set 829 lib/pengine/container.c container_unpack(resource_t * rsc, pe_working_set_t * data_set) data_set 1008 lib/pengine/container.c if (common_unpack(xml_resource, &new_rsc, rsc, data_set) == FALSE) { data_set 1100 lib/pengine/container.c if (create_container(rsc, container_data, tuple, data_set) == FALSE) { data_set 74 lib/pengine/failcounts.c pe_working_set_t *data_set) data_set 86 lib/pengine/failcounts.c if (rsc->container == NULL && is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 119 lib/pengine/failcounts.c lrm_op_xpathObj = xpath_search(data_set->input, lrm_op_xpath); data_set 220 lib/pengine/failcounts.c generate_fail_regexes(resource_t *rsc, pe_working_set_t *data_set, data_set 224 lib/pengine/failcounts.c const char *version = crm_element_value(data_set->input, XML_ATTR_CRM_VERSION); data_set 238 lib/pengine/failcounts.c uint32_t flags, xmlNode *xml_op, pe_working_set_t *data_set) data_set 247 lib/pengine/failcounts.c generate_fail_regexes(rsc, data_set, &failcount_re, &lastfailure_re); data_set 268 lib/pengine/failcounts.c && block_failure(node, rsc, xml_op, data_set)) { data_set 279 lib/pengine/failcounts.c time_t now = get_effective_time(data_set); data_set 296 lib/pengine/failcounts.c flags, xml_op, data_set); data_set 31 lib/pengine/group.c group_unpack(resource_t * rsc, pe_working_set_t * data_set) data_set 66 lib/pengine/group.c if (common_unpack(xml_native_rsc, &new_rsc, rsc, data_set) == FALSE) { data_set 32 lib/pengine/native.c native_add_running(resource_t * rsc, node_t * node, pe_working_set_t * data_set) data_set 62 lib/pengine/native.c resource_location(rsc, node, INFINITY, "not_managed_default", data_set); data_set 81 lib/pengine/native.c rsc->allowed_nodes = node_hash_from_list(data_set->nodes); data_set 120 lib/pengine/native.c native_add_running(rsc->parent, node, data_set); data_set 124 lib/pengine/native.c extern void force_non_unique_clone(resource_t * rsc, const char *rid, pe_working_set_t * data_set); data_set 127 lib/pengine/native.c native_unpack(resource_t * rsc, pe_working_set_t * data_set) data_set 143 lib/pengine/native.c force_non_unique_clone(top, rsc->id, data_set); data_set 243 lib/pengine/native.c pe_working_set_t * data_set) data_set 264 lib/pengine/native.c get_rsc_attributes(local_hash, rsc, node, data_set); data_set 25 lib/pengine/remote.c is_rsc_baremetal_remote_node(resource_t *rsc, pe_working_set_t * data_set) data_set 35 lib/pengine/remote.c node = pe_find_node(data_set->nodes, rsc->id); data_set 71 lib/pengine/remote.c rsc_contains_remote_node(pe_working_set_t * data_set, resource_t *rsc) data_set 73 lib/pengine/remote.c if (is_set(data_set->flags, pe_flag_have_remote_nodes) == FALSE) { data_set 114 lib/pengine/remote.c pe_foreach_guest_node(const pe_working_set_t *data_set, const node_t *host, data_set 119 lib/pengine/remote.c CRM_CHECK(data_set && host && host->details && helper, return); data_set 120 lib/pengine/remote.c if (!is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 127 lib/pengine/remote.c node_t *guest_node = pe_find_node(data_set->nodes, rsc->id); data_set 34 lib/pengine/status.c #define check_and_exit(stage) cleanup_calculations(data_set); \ data_set 51 lib/pengine/status.c cluster_status(pe_working_set_t * data_set) data_set 53 lib/pengine/status.c xmlNode *config = get_xpath_object("//"XML_CIB_TAG_CRMCONFIG, data_set->input, LOG_TRACE); data_set 54 lib/pengine/status.c xmlNode *cib_nodes = get_xpath_object("//"XML_CIB_TAG_NODES, data_set->input, LOG_TRACE); data_set 55 lib/pengine/status.c xmlNode *cib_resources = get_xpath_object("//"XML_CIB_TAG_RESOURCES, data_set->input, LOG_TRACE); data_set 56 lib/pengine/status.c xmlNode *cib_status = get_xpath_object("//"XML_CIB_TAG_STATUS, data_set->input, LOG_TRACE); data_set 57 lib/pengine/status.c xmlNode *cib_tags = get_xpath_object("//"XML_CIB_TAG_TAGS, data_set->input, LOG_TRACE); data_set 58 lib/pengine/status.c const char *value = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 61 lib/pengine/status.c pe_dataset = data_set; data_set 64 lib/pengine/status.c data_set->failed = create_xml_node(NULL, "failed-ops"); data_set 66 lib/pengine/status.c if (data_set->input == NULL) { data_set 70 lib/pengine/status.c if (data_set->now == NULL) { data_set 71 lib/pengine/status.c data_set->now = crm_time_new(NULL); data_set 74 lib/pengine/status.c if (data_set->dc_uuid == NULL) { data_set 75 lib/pengine/status.c data_set->dc_uuid = crm_element_value_copy(data_set->input, data_set 79 lib/pengine/status.c clear_bit(data_set->flags, pe_flag_have_quorum); data_set 81 lib/pengine/status.c set_bit(data_set->flags, pe_flag_have_quorum); data_set 84 lib/pengine/status.c data_set->op_defaults = get_xpath_object("//"XML_CIB_TAG_OPCONFIG, data_set->input, LOG_TRACE); data_set 85 lib/pengine/status.c data_set->rsc_defaults = get_xpath_object("//"XML_CIB_TAG_RSCCONFIG, data_set->input, LOG_TRACE); data_set 87 lib/pengine/status.c unpack_config(config, data_set); data_set 89 lib/pengine/status.c if (is_not_set(data_set->flags, pe_flag_quick_location) data_set 90 lib/pengine/status.c && is_not_set(data_set->flags, pe_flag_have_quorum) data_set 91 lib/pengine/status.c && data_set->no_quorum_policy != no_quorum_ignore) { data_set 95 lib/pengine/status.c unpack_nodes(cib_nodes, data_set); data_set 97 lib/pengine/status.c if(is_not_set(data_set->flags, pe_flag_quick_location)) { data_set 98 lib/pengine/status.c unpack_remote_nodes(cib_resources, data_set); data_set 101 lib/pengine/status.c unpack_resources(cib_resources, data_set); data_set 102 lib/pengine/status.c unpack_tags(cib_tags, data_set); data_set 104 lib/pengine/status.c if(is_not_set(data_set->flags, pe_flag_quick_location)) { data_set 105 lib/pengine/status.c unpack_status(cib_status, data_set); data_set 108 lib/pengine/status.c set_bit(data_set->flags, pe_flag_have_status); data_set 179 lib/pengine/status.c cleanup_calculations(pe_working_set_t * data_set) data_set 182 lib/pengine/status.c if (data_set == NULL) { data_set 186 lib/pengine/status.c clear_bit(data_set->flags, pe_flag_have_status); data_set 187 lib/pengine/status.c if (data_set->config_hash != NULL) { data_set 188 lib/pengine/status.c g_hash_table_destroy(data_set->config_hash); data_set 191 lib/pengine/status.c if (data_set->singletons != NULL) { data_set 192 lib/pengine/status.c g_hash_table_destroy(data_set->singletons); data_set 195 lib/pengine/status.c if (data_set->tickets) { data_set 196 lib/pengine/status.c g_hash_table_destroy(data_set->tickets); data_set 199 lib/pengine/status.c if (data_set->template_rsc_sets) { data_set 200 lib/pengine/status.c g_hash_table_destroy(data_set->template_rsc_sets); data_set 203 lib/pengine/status.c if (data_set->tags) { data_set 204 lib/pengine/status.c g_hash_table_destroy(data_set->tags); data_set 207 lib/pengine/status.c free(data_set->dc_uuid); data_set 210 lib/pengine/status.c pe_free_resources(data_set->resources); data_set 213 lib/pengine/status.c pe_free_actions(data_set->actions); data_set 216 lib/pengine/status.c pe_free_nodes(data_set->nodes); data_set 218 lib/pengine/status.c free_xml(data_set->graph); data_set 219 lib/pengine/status.c crm_time_free(data_set->now); data_set 220 lib/pengine/status.c free_xml(data_set->input); data_set 221 lib/pengine/status.c free_xml(data_set->failed); data_set 223 lib/pengine/status.c set_working_set_defaults(data_set); data_set 225 lib/pengine/status.c CRM_CHECK(data_set->ordering_constraints == NULL,; data_set 227 lib/pengine/status.c CRM_CHECK(data_set->placement_constraints == NULL,; data_set 232 lib/pengine/status.c set_working_set_defaults(pe_working_set_t * data_set) data_set 234 lib/pengine/status.c pe_dataset = data_set; data_set 235 lib/pengine/status.c memset(data_set, 0, sizeof(pe_working_set_t)); data_set 237 lib/pengine/status.c data_set->order_id = 1; data_set 238 lib/pengine/status.c data_set->action_id = 1; data_set 239 lib/pengine/status.c data_set->no_quorum_policy = no_quorum_freeze; data_set 241 lib/pengine/status.c data_set->flags = 0x0ULL; data_set 242 lib/pengine/status.c set_bit(data_set->flags, pe_flag_stop_rsc_orphans); data_set 243 lib/pengine/status.c set_bit(data_set->flags, pe_flag_symmetric_cluster); data_set 244 lib/pengine/status.c set_bit(data_set->flags, pe_flag_is_managed_default); data_set 245 lib/pengine/status.c set_bit(data_set->flags, pe_flag_stop_action_orphans); 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 *tmp = pe_pref(data_set->config_hash, option); \ data_set 38 lib/pengine/unpack.c set_bit(data_set->flags, flag); \ data_set 40 lib/pengine/unpack.c clear_bit(data_set->flags, flag); \ data_set 46 lib/pengine/unpack.c enum action_fail_response *failed, pe_working_set_t * data_set); data_set 47 lib/pengine/unpack.c static gboolean determine_remote_online_status(pe_working_set_t * data_set, node_t * this_node); data_set 77 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, node_t * node, const char *reason) data_set 123 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 127 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, data_set); data_set 132 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", data_set 138 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", data_set 141 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, data_set); data_set 162 lib/pengine/unpack.c pe_working_set_t *data_set) data_set 166 lib/pengine/unpack.c if (is_not_set(data_set->flags, flag)) { data_set 167 lib/pengine/unpack.c result = xpath_search(data_set->input, xpath); data_set 169 lib/pengine/unpack.c set_bit(data_set->flags, flag); data_set 176 lib/pengine/unpack.c unpack_config(xmlNode * config, pe_working_set_t * data_set) data_set 181 lib/pengine/unpack.c data_set->config_hash = config_hash; data_set 183 lib/pengine/unpack.c unpack_instance_attributes(data_set->input, config, XML_CIB_TAG_PROPSET, NULL, config_hash, data_set 184 lib/pengine/unpack.c CIB_OPTIONS_FIRST, FALSE, data_set->now); data_set 186 lib/pengine/unpack.c verify_pe_options(data_set->config_hash); data_set 188 lib/pengine/unpack.c set_config_flag(data_set, "enable-startup-probes", pe_flag_startup_probes); data_set 189 lib/pengine/unpack.c if(is_not_set(data_set->flags, pe_flag_startup_probes)) { data_set 193 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, XML_ATTR_HAVE_WATCHDOG); data_set 196 lib/pengine/unpack.c set_bit(data_set->flags, pe_flag_have_stonith_resource); data_set 202 lib/pengine/unpack.c set_if_xpath(pe_flag_enable_unfencing, XPATH_ENABLE_UNFENCING, data_set); data_set 204 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 205 lib/pengine/unpack.c data_set->stonith_timeout = crm_get_msec(value); data_set 206 lib/pengine/unpack.c crm_debug("STONITH timeout: %d", data_set->stonith_timeout); data_set 208 lib/pengine/unpack.c set_config_flag(data_set, "stonith-enabled", pe_flag_stonith_enabled); data_set 210 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_stonith_enabled) ? "enabled" : "disabled"); data_set 212 lib/pengine/unpack.c data_set->stonith_action = pe_pref(data_set->config_hash, "stonith-action"); data_set 213 lib/pengine/unpack.c crm_trace("STONITH will %s nodes", data_set->stonith_action); data_set 215 lib/pengine/unpack.c set_config_flag(data_set, "concurrent-fencing", pe_flag_concurrent_fencing); data_set 217 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_concurrent_fencing) ? "enabled" : "disabled"); data_set 219 lib/pengine/unpack.c set_config_flag(data_set, "stop-all-resources", pe_flag_stop_everything); data_set 221 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_stop_everything) ? "true" : "false"); data_set 223 lib/pengine/unpack.c set_config_flag(data_set, "symmetric-cluster", pe_flag_symmetric_cluster); data_set 224 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 228 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "default-resource-stickiness"); data_set 235 lib/pengine/unpack.c data_set->default_resource_stickiness = char2score(value); data_set 236 lib/pengine/unpack.c crm_debug("Default stickiness: %d", data_set->default_resource_stickiness); data_set 238 lib/pengine/unpack.c value = pe_pref(data_set->config_hash, "no-quorum-policy"); data_set 241 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_ignore; data_set 244 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_freeze; data_set 247 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 250 lib/pengine/unpack.c crm_element_value_int(data_set->input, XML_ATTR_QUORUM_PANIC, data_set 252 lib/pengine/unpack.c if (do_panic || is_set(data_set->flags, pe_flag_have_quorum)) { data_set 253 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_suicide; data_set 256 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 260 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 264 lib/pengine/unpack.c data_set->no_quorum_policy = no_quorum_stop; data_set 267 lib/pengine/unpack.c switch (data_set->no_quorum_policy) { data_set 282 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-resources", pe_flag_stop_rsc_orphans); data_set 284 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_stop_rsc_orphans) ? "stopped" : "ignored"); data_set 286 lib/pengine/unpack.c set_config_flag(data_set, "stop-orphan-actions", pe_flag_stop_action_orphans); data_set 288 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_stop_action_orphans) ? "stopped" : "ignored"); data_set 290 lib/pengine/unpack.c set_config_flag(data_set, "remove-after-stop", pe_flag_remove_after_stop); data_set 292 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_remove_after_stop) ? "true" : "false"); data_set 294 lib/pengine/unpack.c set_config_flag(data_set, "maintenance-mode", pe_flag_maintenance_mode); data_set 296 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_maintenance_mode) ? "true" : "false"); data_set 298 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 299 lib/pengine/unpack.c clear_bit(data_set->flags, pe_flag_is_managed_default); data_set 300 lib/pengine/unpack.c } else if (pe_pref(data_set->config_hash, "is-managed-default")) { data_set 301 lib/pengine/unpack.c set_config_flag(data_set, "is-managed-default", pe_flag_is_managed_default); data_set 308 lib/pengine/unpack.c is_set(data_set->flags, pe_flag_is_managed_default) ? "" : "not "); data_set 310 lib/pengine/unpack.c set_config_flag(data_set, "start-failure-is-fatal", pe_flag_start_failure_fatal); data_set 312 lib/pengine/unpack.c is_set(data_set->flags, data_set 315 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 316 lib/pengine/unpack.c set_config_flag(data_set, "startup-fencing", pe_flag_startup_fencing); data_set 318 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 324 lib/pengine/unpack.c node_score_red = char2score(pe_pref(data_set->config_hash, "node-health-red")); data_set 325 lib/pengine/unpack.c node_score_green = char2score(pe_pref(data_set->config_hash, "node-health-green")); data_set 326 lib/pengine/unpack.c node_score_yellow = char2score(pe_pref(data_set->config_hash, "node-health-yellow")); data_set 329 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-red"), data_set 330 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-yellow"), data_set 331 lib/pengine/unpack.c pe_pref(data_set->config_hash, "node-health-green")); data_set 333 lib/pengine/unpack.c data_set->placement_strategy = pe_pref(data_set->config_hash, "placement-strategy"); data_set 334 lib/pengine/unpack.c crm_trace("Placement strategy: %s", data_set->placement_strategy); data_set 357 lib/pengine/unpack.c const char *score, pe_working_set_t * data_set) data_set 361 lib/pengine/unpack.c if (pe_find_node(data_set->nodes, uname) != NULL) { data_set 391 lib/pengine/unpack.c set_bit(data_set->flags, pe_flag_have_remote_nodes); data_set 413 lib/pengine/unpack.c data_set->nodes = g_list_insert_sorted(data_set->nodes, new_node, sort_node_uname); data_set 500 lib/pengine/unpack.c handle_startup_fencing(pe_working_set_t *data_set, node_t *new_node) data_set 510 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_startup_fencing)) { data_set 525 lib/pengine/unpack.c unpack_nodes(xmlNode * xml_nodes, pe_working_set_t * data_set) data_set 548 lib/pengine/unpack.c new_node = pe_create_node(id, uname, type, score, data_set); data_set 560 lib/pengine/unpack.c handle_startup_fencing(data_set, new_node); data_set 562 lib/pengine/unpack.c add_node_attrs(xml_obj, new_node, FALSE, data_set); data_set 563 lib/pengine/unpack.c unpack_instance_attributes(data_set->input, xml_obj, XML_TAG_UTILIZATION, NULL, data_set 564 lib/pengine/unpack.c new_node->details->utilization, NULL, FALSE, data_set->now); data_set 570 lib/pengine/unpack.c if (data_set->localhost && pe_find_node(data_set->nodes, data_set->localhost) == NULL) { data_set 572 lib/pengine/unpack.c pe_create_node(data_set->localhost, data_set->localhost, NULL, 0, data_set 573 lib/pengine/unpack.c data_set); data_set 580 lib/pengine/unpack.c setup_container(resource_t * rsc, pe_working_set_t * data_set) data_set 590 lib/pengine/unpack.c setup_container(child_rsc, data_set); data_set 597 lib/pengine/unpack.c resource_t *container = pe_find_resource(data_set->resources, container_id); data_set 611 lib/pengine/unpack.c unpack_remote_nodes(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 625 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 628 lib/pengine/unpack.c data_set); data_set 643 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj, xml_resources, data_set); data_set 645 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 657 lib/pengine/unpack.c new_node_id = expand_remote_rsc_meta(xml_obj2, xml_resources, data_set); data_set 659 lib/pengine/unpack.c if (new_node_id && pe_find_node(data_set->nodes, new_node_id) == NULL) { data_set 662 lib/pengine/unpack.c data_set); data_set 680 lib/pengine/unpack.c link_rsc2remotenode(pe_working_set_t *data_set, resource_t *new_rsc) data_set 688 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_quick_location)) { data_set 695 lib/pengine/unpack.c remote_node = pe_find_node(data_set->nodes, new_rsc->id); data_set 703 lib/pengine/unpack.c handle_startup_fencing(data_set, remote_node); data_set 737 lib/pengine/unpack.c unpack_resources(xmlNode * xml_resources, pe_working_set_t * data_set) data_set 742 lib/pengine/unpack.c data_set->template_rsc_sets = data_set 752 lib/pengine/unpack.c if (template_id && g_hash_table_lookup_extended(data_set->template_rsc_sets, data_set 755 lib/pengine/unpack.c g_hash_table_insert(data_set->template_rsc_sets, strdup(template_id), NULL); data_set 761 lib/pengine/unpack.c if (common_unpack(xml_obj, &new_rsc, NULL, data_set)) { data_set 762 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, new_rsc); data_set 774 lib/pengine/unpack.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 777 lib/pengine/unpack.c setup_container(rsc, data_set); data_set 778 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 781 lib/pengine/unpack.c data_set->resources = g_list_sort(data_set->resources, sort_rsc_priority); data_set 782 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_quick_location)) { data_set 785 lib/pengine/unpack.c } else if (is_set(data_set->flags, pe_flag_stonith_enabled) data_set 786 lib/pengine/unpack.c && is_set(data_set->flags, pe_flag_have_stonith_resource) == FALSE) { data_set 797 lib/pengine/unpack.c unpack_tags(xmlNode * xml_tags, pe_working_set_t * data_set) data_set 801 lib/pengine/unpack.c data_set->tags = data_set 831 lib/pengine/unpack.c if (add_tag_ref(data_set->tags, tag_id, obj_ref) == FALSE) { data_set 843 lib/pengine/unpack.c unpack_ticket_state(xmlNode * xml_ticket, pe_working_set_t * data_set) data_set 860 lib/pengine/unpack.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 862 lib/pengine/unpack.c ticket = ticket_new(ticket_id, data_set); data_set 908 lib/pengine/unpack.c unpack_tickets_state(xmlNode * xml_tickets, pe_working_set_t * data_set) data_set 916 lib/pengine/unpack.c unpack_ticket_state(xml_obj, data_set); data_set 941 lib/pengine/unpack.c pe_working_set_t *data_set = user_data; data_set 978 lib/pengine/unpack.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 980 lib/pengine/unpack.c ticket = ticket_new(ticket_id, data_set); data_set 1004 lib/pengine/unpack.c unpack_handle_remote_attrs(node_t *this_node, xmlNode *state, pe_working_set_t * data_set) data_set 1029 lib/pengine/unpack.c add_node_attrs(attrs, this_node, TRUE, data_set); data_set 1053 lib/pengine/unpack.c if (is_baremetal_remote_node(this_node) && is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1068 lib/pengine/unpack.c unpack_node_loop(xmlNode * status, bool fence, pe_working_set_t * data_set) data_set 1085 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1095 lib/pengine/unpack.c } else if (is_remote_node(this_node) == FALSE && is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1126 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1127 lib/pengine/unpack.c unpack_handle_remote_attrs(this_node, state, data_set); data_set 1147 lib/pengine/unpack.c unpack_lrm_resources(this_node, lrm_rsc, data_set); data_set 1157 lib/pengine/unpack.c unpack_status(xmlNode * status, pe_working_set_t * data_set) data_set 1167 lib/pengine/unpack.c if (data_set->tickets == NULL) { data_set 1168 lib/pengine/unpack.c data_set->tickets = data_set 1181 lib/pengine/unpack.c unpack_instance_attributes(data_set->input, xml_tickets, XML_TAG_ATTR_SETS, NULL, data_set 1182 lib/pengine/unpack.c state_hash, NULL, TRUE, data_set->now); data_set 1184 lib/pengine/unpack.c g_hash_table_foreach(state_hash, get_ticket_state_legacy, data_set); data_set 1191 lib/pengine/unpack.c unpack_tickets_state(xml_tickets, data_set); data_set 1200 lib/pengine/unpack.c this_node = pe_find_node_any(data_set->nodes, id, uname); data_set 1228 lib/pengine/unpack.c add_node_attrs(attrs, this_node, TRUE, data_set); data_set 1247 lib/pengine/unpack.c determine_online_status(state, this_node, data_set); data_set 1249 lib/pengine/unpack.c if (is_not_set(data_set->flags, pe_flag_have_quorum) data_set 1251 lib/pengine/unpack.c && (data_set->no_quorum_policy == no_quorum_suicide)) { data_set 1255 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "cluster does not have quorum"); data_set 1261 lib/pengine/unpack.c while(unpack_node_loop(status, FALSE, data_set)) { data_set 1266 lib/pengine/unpack.c unpack_node_loop(status, is_set(data_set->flags, pe_flag_stonith_enabled), data_set); data_set 1268 lib/pengine/unpack.c for (GListPtr gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1278 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 1285 lib/pengine/unpack.c determine_online_status_no_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1311 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is unexpectedly down"); data_set 1319 lib/pengine/unpack.c determine_online_status_fencing(pe_working_set_t * data_set, xmlNode * node_state, data_set 1368 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer has not been seen by the cluster"); data_set 1371 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer failed the pacemaker membership criteria"); data_set 1390 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer is no longer part of the cluster"); data_set 1393 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer process is no longer available"); data_set 1397 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "termination was requested"); data_set 1409 lib/pengine/unpack.c pe_fence_node(data_set, this_node, "peer was in an unknown state"); data_set 1419 lib/pengine/unpack.c determine_remote_online_status(pe_working_set_t * data_set, node_t * this_node) data_set 1489 lib/pengine/unpack.c determine_online_status(xmlNode * node_state, node_t * this_node, pe_working_set_t * data_set) data_set 1518 lib/pengine/unpack.c } else if (is_set(data_set->flags, pe_flag_stonith_enabled) == FALSE) { data_set 1519 lib/pengine/unpack.c online = determine_online_status_no_fencing(data_set, node_state, this_node); data_set 1522 lib/pengine/unpack.c online = determine_online_status_fencing(data_set, node_state, this_node); data_set 1647 lib/pengine/unpack.c create_fake_resource(const char *rsc_id, xmlNode * rsc_entry, pe_working_set_t * data_set) data_set 1656 lib/pengine/unpack.c if (!common_unpack(xml_rsc, &rsc, NULL, data_set)) { data_set 1664 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); data_set 1666 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); data_set 1668 lib/pengine/unpack.c link_rsc2remotenode(data_set, rsc); data_set 1682 lib/pengine/unpack.c data_set->resources = g_list_append(data_set->resources, rsc); data_set 1686 lib/pengine/unpack.c extern resource_t *create_child_clone(resource_t * rsc, int sub_id, pe_working_set_t * data_set); data_set 1689 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, node_t * node, resource_t * parent, data_set 1762 lib/pengine/unpack.c resource_t *top = create_child_clone(parent, -1, data_set); data_set 1782 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, node_t * node, const char *rsc_id, data_set 1789 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1795 lib/pengine/unpack.c resource_t *clone0 = pe_find_resource(data_set->resources, tmp); data_set 1824 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); data_set 1839 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, node_t * node, pe_working_set_t * data_set) data_set 1845 lib/pengine/unpack.c rsc = create_fake_resource(rsc_id, rsc_entry, data_set); data_set 1847 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_stop_rsc_orphans) == FALSE) { data_set 1854 lib/pengine/unpack.c resource_location(rsc, NULL, -INFINITY, "__orphan_dont_run__", data_set); data_set 1862 lib/pengine/unpack.c xmlNode * migrate_op, pe_working_set_t * data_set) data_set 1909 lib/pengine/unpack.c } else if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1931 lib/pengine/unpack.c pe_fence_node(data_set, node, reason); data_set 1953 lib/pengine/unpack.c pe_fence_node(data_set, node, reason); data_set 1974 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); data_set 2000 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2003 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2011 lib/pengine/unpack.c pe_fence_node(data_set, tmpnode, data_set 2034 lib/pengine/unpack.c tmpnode = pe_find_node(data_set->nodes, rsc->id); data_set 2052 lib/pengine/unpack.c native_add_running(rsc, node, data_set); data_set 2085 lib/pengine/unpack.c GListPtr sorted_op_list, pe_working_set_t * data_set) data_set 2135 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); data_set 2188 lib/pengine/unpack.c unpack_lrm_rsc_state(node_t * node, xmlNode * rsc_entry, pe_working_set_t * data_set) data_set 2228 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, rsc_entry); data_set 2230 lib/pengine/unpack.c rsc = process_orphan_resource(rsc_entry, node, data_set); data_set 2248 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); data_set 2253 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); data_set 2258 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); data_set 2282 lib/pengine/unpack.c handle_orphaned_container_fillers(xmlNode * lrm_rsc_list, pe_working_set_t * data_set) data_set 2303 lib/pengine/unpack.c container = pe_find_resource(data_set->resources, container_id); data_set 2308 lib/pengine/unpack.c rsc = pe_find_resource(data_set->resources, rsc_id); data_set 2322 lib/pengine/unpack.c unpack_lrm_resources(node_t * node, xmlNode * lrm_rsc_list, pe_working_set_t * data_set) data_set 2335 lib/pengine/unpack.c resource_t *rsc = unpack_lrm_rsc_state(node, rsc_entry, data_set); data_set 2349 lib/pengine/unpack.c handle_orphaned_container_fillers(lrm_rsc_list, data_set); data_set 2378 lib/pengine/unpack.c pe_working_set_t * data_set) data_set 2406 lib/pengine/unpack.c return get_xpath_object(xpath, data_set->input, LOG_DEBUG); data_set 2410 lib/pengine/unpack.c unpack_rsc_migration(resource_t *rsc, node_t *node, xmlNode *xml_op, pe_working_set_t * data_set) data_set 2429 lib/pengine/unpack.c find_lrm_op(rsc->id, CRMD_ACTION_STOP, node->details->id, NULL, data_set); data_set 2444 lib/pengine/unpack.c node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 2445 lib/pengine/unpack.c node_t *source = pe_find_node(data_set->nodes, migrate_source); data_set 2448 lib/pengine/unpack.c data_set); data_set 2474 lib/pengine/unpack.c native_add_running(rsc, target, data_set); data_set 2482 lib/pengine/unpack.c native_add_running(rsc, target, data_set); data_set 2502 lib/pengine/unpack.c unpack_rsc_migration_failure(resource_t *rsc, node_t *node, xmlNode *xml_op, pe_working_set_t * data_set) data_set 2514 lib/pengine/unpack.c find_lrm_op(rsc->id, CRMD_ACTION_STOP, migrate_source, NULL, data_set); data_set 2517 lib/pengine/unpack.c data_set); data_set 2530 lib/pengine/unpack.c node_t *source = pe_find_node(data_set->nodes, migrate_source); data_set 2533 lib/pengine/unpack.c native_add_running(rsc, source, data_set); data_set 2544 lib/pengine/unpack.c find_lrm_op(rsc->id, CRMD_ACTION_STOP, migrate_target, NULL, data_set); data_set 2547 lib/pengine/unpack.c data_set); data_set 2560 lib/pengine/unpack.c node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 2565 lib/pengine/unpack.c native_add_running(rsc, target, data_set); data_set 2576 lib/pengine/unpack.c record_failed_op(xmlNode *op, node_t* node, resource_t *rsc, pe_working_set_t * data_set) data_set 2585 lib/pengine/unpack.c for (xIter = data_set->failed->children; xIter; xIter = xIter->next) { data_set 2598 lib/pengine/unpack.c add_node_copy(data_set->failed, op); data_set 2612 lib/pengine/unpack.c enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 2632 lib/pengine/unpack.c if (rc != PCMK_OCF_NOT_INSTALLED || is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 2637 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 2645 lib/pengine/unpack.c action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 2656 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); data_set 2659 lib/pengine/unpack.c unpack_rsc_migration_failure(rsc, node, xml_op, data_set); data_set 2685 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__legacy_start__", data_set); data_set 2726 lib/pengine/unpack.c fail_rsc->allowed_nodes = node_hash_from_list(data_set->nodes); data_set 2735 lib/pengine/unpack.c resource_t *rsc, int rc, int target_rc, node_t * node, xmlNode * xml_op, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 2834 lib/pengine/unpack.c } else if (pe_can_fence(data_set, node) == FALSE data_set 2856 lib/pengine/unpack.c static bool check_operation_expiry(resource_t *rsc, node_t *node, int rc, xmlNode *xml_op, pe_working_set_t * data_set) data_set 2880 lib/pengine/unpack.c if (is_set(data_set->flags, pe_flag_stonith_enabled) && data_set 2883 lib/pengine/unpack.c node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 2899 lib/pengine/unpack.c time_t now = get_effective_time(data_set); data_set 2910 lib/pengine/unpack.c xml_op, data_set)) { data_set 2913 lib/pengine/unpack.c xml_op, data_set) == 0) { data_set 2930 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); data_set 2947 lib/pengine/unpack.c node, FALSE, TRUE, data_set); data_set 2989 lib/pengine/unpack.c get_action_on_fail(resource_t *rsc, const char *key, const char *task, pe_working_set_t * data_set) data_set 2992 lib/pengine/unpack.c action_t *action = custom_action(rsc, strdup(key), task, NULL, TRUE, FALSE, data_set); data_set 3002 lib/pengine/unpack.c xmlNode * last_failure, enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3050 lib/pengine/unpack.c unpack_rsc_migration(rsc, node, xml_op, data_set); data_set 3092 lib/pengine/unpack.c enum action_fail_response * on_fail, pe_working_set_t * data_set) data_set 3152 lib/pengine/unpack.c expired = check_operation_expiry(rsc, node, rc, xml_op, data_set); data_set 3162 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3171 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3198 lib/pengine/unpack.c status = determine_op_status(rsc, rc, target_rc, node, xml_op, on_fail, data_set); data_set 3220 lib/pengine/unpack.c node_t *target = pe_find_node(data_set->nodes, migrate_target); data_set 3243 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); data_set 3247 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3255 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3256 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 3265 lib/pengine/unpack.c failure_strategy = get_action_on_fail(rsc, task_key, task, data_set); data_set 3273 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, target_rc, *last_failure, on_fail, data_set); data_set 3277 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); data_set 3284 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); data_set 3292 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); data_set 3298 lib/pengine/unpack.c resource_location(parent, NULL, -INFINITY, "fatal-error", data_set); data_set 3310 lib/pengine/unpack.c add_node_attrs(xmlNode * xml_obj, node_t * node, gboolean overwrite, pe_working_set_t * data_set) data_set 3319 lib/pengine/unpack.c if (safe_str_eq(node->details->id, data_set->dc_uuid)) { data_set 3320 lib/pengine/unpack.c data_set->dc_node = node; data_set 3329 lib/pengine/unpack.c cluster_name = g_hash_table_lookup(data_set->config_hash, "cluster-name"); data_set 3335 lib/pengine/unpack.c unpack_instance_attributes(data_set->input, xml_obj, XML_TAG_ATTR_SETS, NULL, data_set 3336 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set->now); data_set 3419 lib/pengine/unpack.c pe_working_set_t * data_set) data_set 3425 lib/pengine/unpack.c xmlNode *status = find_xml_node(data_set->input, XML_CIB_TAG_STATUS, TRUE); data_set 3441 lib/pengine/unpack.c this_node = pe_find_node(data_set->nodes, uname); data_set 3447 lib/pengine/unpack.c determine_remote_online_status(data_set, this_node); data_set 3450 lib/pengine/unpack.c determine_online_status(node_state, this_node, data_set); data_set 3453 lib/pengine/unpack.c if (this_node->details->online || is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 21 lib/pengine/unpack.h extern gboolean unpack_remote_nodes(xmlNode * xml_resources, pe_working_set_t * data_set); data_set 23 lib/pengine/unpack.h extern gboolean unpack_resources(xmlNode * xml_resources, pe_working_set_t * data_set); data_set 25 lib/pengine/unpack.h extern gboolean unpack_config(xmlNode * config, pe_working_set_t * data_set); data_set 27 lib/pengine/unpack.h extern gboolean unpack_nodes(xmlNode * xml_nodes, pe_working_set_t * data_set); data_set 29 lib/pengine/unpack.h extern gboolean unpack_tags(xmlNode * xml_tags, pe_working_set_t * data_set); data_set 31 lib/pengine/unpack.h extern gboolean unpack_status(xmlNode * status, pe_working_set_t * data_set); data_set 33 lib/pengine/unpack.h extern gboolean unpack_remote_status(xmlNode * status, pe_working_set_t * data_set); data_set 38 lib/pengine/unpack.h pe_working_set_t * data_set); data_set 41 lib/pengine/unpack.h pe_working_set_t * data_set); data_set 44 lib/pengine/unpack.h pe_working_set_t * data_set); data_set 37 lib/pengine/utils.c pe_working_set_t * data_set); data_set 100 lib/pengine/utils.c bool pe_can_fence(pe_working_set_t * data_set, node_t *node) data_set 102 lib/pengine/utils.c if(is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 105 lib/pengine/utils.c } else if (is_not_set(data_set->flags, pe_flag_have_stonith_resource)) { data_set 108 lib/pengine/utils.c } else if (is_set(data_set->flags, pe_flag_have_quorum)) { data_set 111 lib/pengine/utils.c } else if (data_set->no_quorum_policy == no_quorum_ignore) { data_set 421 lib/pengine/utils.c pe_working_set_t * data_set) data_set 433 lib/pengine/utils.c action = g_hash_table_lookup(data_set->singletons, key); data_set 436 lib/pengine/utils.c possible_matches = find_actions(data_set->actions, key, on_node); data_set 440 lib/pengine/utils.c if(data_set->singletons == NULL) { data_set 441 lib/pengine/utils.c data_set->singletons = g_hash_table_new_full(crm_str_hash, g_str_equal, NULL, NULL); data_set 461 lib/pengine/utils.c optional ? "" : " mandatory", data_set->action_id, key, data_set 467 lib/pengine/utils.c action->id = data_set->action_id++; data_set 503 lib/pengine/utils.c data_set->actions = g_list_prepend(data_set->actions, action); data_set 505 lib/pengine/utils.c g_hash_table_insert(data_set->singletons, action->uuid, action); data_set 512 lib/pengine/utils.c unpack_operation(action, action->op_entry, rsc->container, data_set); data_set 540 lib/pengine/utils.c unpack_instance_attributes(data_set->input, action->op_entry, XML_TAG_ATTR_SETS, data_set 542 lib/pengine/utils.c action->extra, NULL, FALSE, data_set->now); data_set 567 lib/pengine/utils.c pe_fence_node(data_set, action->node, "resource actions are unrunnable"); data_set 588 lib/pengine/utils.c } else if (is_set(data_set->flags, pe_flag_have_quorum) == FALSE data_set 589 lib/pengine/utils.c && data_set->no_quorum_policy == no_quorum_stop) { data_set 593 lib/pengine/utils.c } else if (is_set(data_set->flags, pe_flag_have_quorum) == FALSE data_set 594 lib/pengine/utils.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 845 lib/pengine/utils.c pe_get_configured_timeout(resource_t *rsc, const char *action, pe_working_set_t *data_set) data_set 859 lib/pengine/utils.c if (timeout == NULL && data_set->op_defaults) { data_set 861 lib/pengine/utils.c unpack_instance_attributes(data_set->input, data_set->op_defaults, XML_TAG_META_SETS, data_set 862 lib/pengine/utils.c NULL, action_meta, NULL, FALSE, data_set->now); data_set 866 lib/pengine/utils.c if (timeout == NULL && data_set->config_hash) { data_set 867 lib/pengine/utils.c timeout = pe_pref(data_set->config_hash, "default-action-timeout"); data_set 915 lib/pengine/utils.c pe_working_set_t * data_set) data_set 928 lib/pengine/utils.c unpack_instance_attributes(data_set->input, data_set->op_defaults, XML_TAG_META_SETS, NULL, data_set 929 lib/pengine/utils.c action->meta, NULL, FALSE, data_set->now); data_set 942 lib/pengine/utils.c unpack_instance_attributes(data_set->input, xml_obj, XML_TAG_META_SETS, data_set 943 lib/pengine/utils.c NULL, action->meta, NULL, FALSE, data_set->now); data_set 945 lib/pengine/utils.c unpack_instance_attributes(data_set->input, xml_obj, XML_TAG_ATTR_SETS, data_set 946 lib/pengine/utils.c NULL, action->meta, NULL, FALSE, data_set->now); data_set 950 lib/pengine/utils.c pe_unpack_versioned_attributes(data_set->input, xml_obj, XML_TAG_ATTR_SETS, NULL, data_set 951 lib/pengine/utils.c rsc_details->versioned_parameters, data_set->now); data_set 952 lib/pengine/utils.c pe_unpack_versioned_attributes(data_set->input, xml_obj, XML_TAG_META_SETS, NULL, data_set 953 lib/pengine/utils.c rsc_details->versioned_meta, data_set->now); data_set 993 lib/pengine/utils.c if (is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 997 lib/pengine/utils.c } else if (is_set(data_set->flags, pe_flag_stonith_enabled) data_set 1000 lib/pengine/utils.c if (is_not_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1032 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_stonith_enabled) == FALSE) { data_set 1090 lib/pengine/utils.c (is_rsc_baremetal_remote_node(action->rsc, data_set) && data_set 1100 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1113 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 1153 lib/pengine/utils.c unpack_interval_origin(value, action->meta, xml_obj, interval, data_set->now); data_set 1158 lib/pengine/utils.c timeout = unpack_timeout(value, action, xml_obj, interval, data_set->config_hash); data_set 1163 lib/pengine/utils.c data_set->now); data_set 1517 lib/pengine/utils.c pe_working_set_t * data_set) data_set 1522 lib/pengine/utils.c } else if (data_set != NULL) { data_set 1523 lib/pengine/utils.c GListPtr gIter = data_set->nodes; data_set 1675 lib/pengine/utils.c get_effective_time(pe_working_set_t * data_set) data_set 1677 lib/pengine/utils.c if(data_set) { data_set 1678 lib/pengine/utils.c if (data_set->now == NULL) { data_set 1680 lib/pengine/utils.c data_set->now = crm_time_new(NULL); data_set 1682 lib/pengine/utils.c return crm_time_get_seconds_since_epoch(data_set->now); data_set 1778 lib/pengine/utils.c get_pseudo_op(const char *name, pe_working_set_t * data_set) data_set 1782 lib/pengine/utils.c if(data_set->singletons) { data_set 1783 lib/pengine/utils.c op = g_hash_table_lookup(data_set->singletons, name); data_set 1786 lib/pengine/utils.c op = custom_action(NULL, strdup(name), name, NULL, TRUE, TRUE, data_set); data_set 1807 lib/pengine/utils.c ticket_new(const char *ticket_id, pe_working_set_t * data_set) data_set 1815 lib/pengine/utils.c if (data_set->tickets == NULL) { data_set 1816 lib/pengine/utils.c data_set->tickets = data_set 1820 lib/pengine/utils.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 1837 lib/pengine/utils.c g_hash_table_insert(data_set->tickets, strdup(ticket->id), ticket); data_set 1890 lib/pengine/utils.c node_t * node, xmlNode * xml_op, pe_working_set_t * data_set) data_set 1897 lib/pengine/utils.c action_t *action = custom_action(rsc, strdup(key), task, node, TRUE, FALSE, data_set); data_set 1910 lib/pengine/utils.c get_rsc_attributes(local_rsc_params, rsc, node, data_set); data_set 1912 lib/pengine/utils.c pe_get_versioned_attributes(local_versioned_params, rsc, node, data_set); data_set 1957 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 1981 lib/pengine/utils.c pe_working_set_t * data_set) data_set 2003 lib/pengine/utils.c data = rsc_action_digest(rsc, task, key, node, xml_op, data_set); data_set 2033 lib/pengine/utils.c fencing_action_digest_cmp(resource_t * rsc, node_t * node, pe_working_set_t * data_set) data_set 2036 lib/pengine/utils.c op_digest_cache_t *data = rsc_action_digest(rsc, STONITH_DIGEST_TASK, key, node, NULL, data_set); data_set 2059 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 2067 lib/pengine/utils.c if (data->rc == RSC_DIGEST_ALL && is_set(data_set->flags, pe_flag_sanitized) && data->digest_secure_calc) { data_set 2068 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 2139 lib/pengine/utils.c pe_fence_op(node_t * node, const char *op, bool optional, const char *reason, pe_working_set_t * data_set) data_set 2145 lib/pengine/utils.c op = data_set->stonith_action; data_set 2150 lib/pengine/utils.c if(data_set->singletons) { data_set 2151 lib/pengine/utils.c stonith_op = g_hash_table_lookup(data_set->singletons, op_key); data_set 2155 lib/pengine/utils.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); data_set 2161 lib/pengine/utils.c if(is_remote_node(node) && is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2176 lib/pengine/utils.c GListPtr matches = find_unfencing_devices(data_set->resources, NULL); data_set 2180 lib/pengine/utils.c op_digest_cache_t *data = fencing_action_digest_cmp(match, node, data_set); data_set 2185 lib/pengine/utils.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 2211 lib/pengine/utils.c if(optional == FALSE && pe_can_fence(data_set, node)) { data_set 2222 lib/pengine/utils.c resource_t * rsc, node_t *node, const char *reason, action_t *dependency, pe_working_set_t * data_set) data_set 2224 lib/pengine/utils.c if(is_not_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 2236 lib/pengine/utils.c action_t *unfence = pe_fence_op(node, "on", FALSE, reason, data_set); data_set 2248 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); data_set 66 lrmd/test.c extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 352 lrmd/test.c pe_working_set_t data_set; data_set 363 lrmd/test.c set_working_set_defaults(&data_set); data_set 390 lrmd/test.c data_set.input = cib_xml_copy; data_set 391 lrmd/test.c data_set.now = crm_time_new(NULL); data_set 393 lrmd/test.c cluster_status(&data_set); data_set 395 lrmd/test.c rsc = pe_find_resource_with_flags(data_set.resources, options.rsc_id, data_set 408 lrmd/test.c get_rsc_attributes(params, rsc, NULL, &data_set); data_set 409 lrmd/test.c get_meta_attributes(meta, rsc, NULL, &data_set); data_set 438 lrmd/test.c cleanup_alloc_calculations(&data_set); data_set 37 pengine/allocate.c void set_alloc_actions(pe_working_set_t * data_set); data_set 38 pengine/allocate.c extern void ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set); data_set 39 pengine/allocate.c extern gboolean DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set); data_set 40 pengine/allocate.c static void apply_remote_node_ordering(pe_working_set_t *data_set); data_set 154 pengine/allocate.c gboolean active_here, pe_working_set_t * data_set) data_set 179 pengine/allocate.c trigger_unfencing(rsc, node, "Device definition changed", NULL, data_set); data_set 201 pengine/allocate.c const char *reason, pe_working_set_t * data_set) data_set 227 pengine/allocate.c cancel = custom_action(rsc, strdup(key), RSC_CANCEL, active_node, FALSE, TRUE, data_set); data_set 238 pengine/allocate.c custom_action_order(rsc, stop_key(rsc), NULL, rsc, NULL, cancel, pe_order_optional, data_set); data_set 245 pengine/allocate.c pe_working_set_t * data_set) data_set 273 pengine/allocate.c if (op_match == NULL && is_set(data_set->flags, pe_flag_stop_action_orphans)) { data_set 274 pengine/allocate.c CancelXmlOp(rsc, xml_op, active_node, "orphan", data_set); data_set 301 pengine/allocate.c digest_data = rsc_action_digest_cmp(rsc, xml_op, active_node, data_set); data_set 303 pengine/allocate.c if(is_set(data_set->flags, pe_flag_sanitized)) { data_set 311 pengine/allocate.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 324 pengine/allocate.c required = custom_action(rsc, key, task, NULL, TRUE, TRUE, data_set); data_set 328 pengine/allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed", NULL, data_set); data_set 335 pengine/allocate.c trigger_unfencing(rsc, active_node, "Device parameters changed (reload)", NULL, data_set); data_set 344 pengine/allocate.c ReloadRsc(rsc, active_node, data_set); data_set 347 pengine/allocate.c op = custom_action(rsc, key, task, active_node, TRUE, TRUE, data_set); data_set 355 pengine/allocate.c ReloadRsc(rsc, active_node, data_set); data_set 365 pengine/allocate.c required = custom_action(rsc, key, task, NULL, TRUE, TRUE, data_set); data_set 376 pengine/allocate.c check_actions_for(xmlNode * rsc_entry, resource_t * rsc, node_t * node, pe_working_set_t * data_set) data_set 401 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 408 pengine/allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, FALSE, data_set)) { data_set 409 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 418 pengine/allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, TRUE, data_set)) { data_set 419 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); data_set 457 pengine/allocate.c CancelXmlOp(rsc, rsc_op, node, "maintenance mode", data_set); data_set 461 pengine/allocate.c did_change = check_action_definition(rsc, node, rsc_op, data_set); data_set 465 pengine/allocate.c NULL, data_set)) { data_set 472 pengine/allocate.c custom_action(rsc, key, CRM_OP_CLEAR_FAILCOUNT, node, FALSE, TRUE, data_set); data_set 487 pengine/allocate.c gboolean partial, pe_working_set_t * data_set) data_set 495 pengine/allocate.c } else if (rsc == NULL && data_set) { data_set 497 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 543 pengine/allocate.c check_actions(pe_working_set_t * data_set) data_set 548 pengine/allocate.c xmlNode *status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 559 pengine/allocate.c node = pe_find_node_id(data_set->nodes, id); data_set 572 pengine/allocate.c if (node->details->online || is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 586 pengine/allocate.c result = find_rsc_list(NULL, NULL, rsc_id, TRUE, FALSE, data_set); data_set 593 pengine/allocate.c check_actions_for(rsc_entry, rsc, node, data_set); data_set 605 pengine/allocate.c apply_placement_constraints(pe_working_set_t * data_set) data_set 611 pengine/allocate.c for (gIter = data_set->placement_constraints; gIter != NULL; gIter = gIter->next) { data_set 647 pengine/allocate.c pe_working_set_t *data_set) data_set 665 pengine/allocate.c data_set); data_set 680 pengine/allocate.c resource_location(failed, node, -INFINITY, "__fail_limit__", data_set); data_set 691 pengine/allocate.c common_apply_stickiness(resource_t * rsc, node_t * node, pe_working_set_t * data_set) data_set 699 pengine/allocate.c common_apply_stickiness(child_rsc, node, data_set); data_set 711 pengine/allocate.c } else if (match != NULL || is_set(data_set->flags, pe_flag_symmetric_cluster)) { data_set 714 pengine/allocate.c resource_location(sticky_rsc, node, rsc->stickiness, "stickiness", data_set); data_set 736 pengine/allocate.c check_migration_threshold(rsc, node, data_set); data_set 755 pengine/allocate.c set_alloc_actions(pe_working_set_t * data_set) data_set 758 pengine/allocate.c GListPtr gIter = data_set->resources; data_set 790 pengine/allocate.c apply_system_health(pe_working_set_t * data_set) data_set 793 pengine/allocate.c const char *health_strategy = pe_pref(data_set->config_hash, "node-health-strategy"); data_set 826 pengine/allocate.c base_health = crm_parse_int(pe_pref(data_set->config_hash, "node-health-base"), "0"); data_set 843 pengine/allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 858 pengine/allocate.c GListPtr gIter2 = data_set->resources; data_set 863 pengine/allocate.c rsc2node_new(health_strategy, rsc, system_health, NULL, node, data_set); data_set 872 pengine/allocate.c stage0(pe_working_set_t * data_set) data_set 874 pengine/allocate.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 876 pengine/allocate.c if (data_set->input == NULL) { data_set 880 pengine/allocate.c if (is_set(data_set->flags, pe_flag_have_status) == FALSE) { data_set 882 pengine/allocate.c cluster_status(data_set); data_set 885 pengine/allocate.c set_alloc_actions(data_set); data_set 886 pengine/allocate.c apply_system_health(data_set); data_set 887 pengine/allocate.c unpack_constraints(cib_constraints, data_set); data_set 896 pengine/allocate.c probe_resources(pe_working_set_t * data_set) data_set 900 pengine/allocate.c for (GListPtr gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 909 pengine/allocate.c pe_fence_node(data_set, node, "the connection is unrecoverable"); data_set 923 pengine/allocate.c CRM_OP_REPROBE, node, FALSE, TRUE, data_set); data_set 929 pengine/allocate.c for (GListPtr gIter2 = data_set->resources; gIter2 != NULL; gIter2 = gIter2->next) { data_set 932 pengine/allocate.c rsc->cmds->create_probe(rsc, node, probe_node_complete, FALSE, data_set); data_set 967 pengine/allocate.c stage2(pe_working_set_t * data_set) data_set 973 pengine/allocate.c gIter = data_set->nodes; data_set 982 pengine/allocate.c data_set->max_valid_nodes++; data_set 986 pengine/allocate.c apply_placement_constraints(data_set); data_set 988 pengine/allocate.c gIter = data_set->nodes; data_set 993 pengine/allocate.c gIter2 = data_set->resources; data_set 997 pengine/allocate.c common_apply_stickiness(rsc, node, data_set); data_set 1009 pengine/allocate.c stage3(pe_working_set_t * data_set) data_set 1012 pengine/allocate.c GListPtr gIter = data_set->resources; data_set 1017 pengine/allocate.c rsc->cmds->internal_constraints(rsc, data_set); data_set 1027 pengine/allocate.c stage4(pe_working_set_t * data_set) data_set 1029 pengine/allocate.c check_actions(data_set); data_set 1171 pengine/allocate.c allocate_resources(pe_working_set_t * data_set) data_set 1175 pengine/allocate.c if (is_set(data_set->flags, pe_flag_have_remote_nodes)) { data_set 1178 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1188 pengine/allocate.c rsc->cmds->allocate(rsc, rsc->partial_migration_target, data_set); data_set 1193 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1199 pengine/allocate.c rsc->cmds->allocate(rsc, NULL, data_set); data_set 1213 pengine/allocate.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 1215 pengine/allocate.c if (lh_rsc && rh_action && data_set) { data_set 1219 pengine/allocate.c data_set); data_set 1225 pengine/allocate.c enum pe_ordering extra, pe_working_set_t *data_set) data_set 1227 pengine/allocate.c if (lh_action && rh_rsc && data_set) { data_set 1230 pengine/allocate.c pe_order_preserve | extra, data_set); data_set 1235 pengine/allocate.c cleanup_orphans(resource_t * rsc, pe_working_set_t * data_set) data_set 1239 pengine/allocate.c if (is_set(data_set->flags, pe_flag_stop_rsc_orphans) == FALSE) { data_set 1248 pengine/allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1253 pengine/allocate.c data_set)) { data_set 1257 pengine/allocate.c node, FALSE, TRUE, data_set); data_set 1271 pengine/allocate.c pe_order_optional, data_set); data_set 1277 pengine/allocate.c stage5(pe_working_set_t * data_set) data_set 1281 pengine/allocate.c if (safe_str_neq(data_set->placement_strategy, "default")) { data_set 1282 pengine/allocate.c GListPtr nodes = g_list_copy(data_set->nodes); data_set 1286 pengine/allocate.c data_set->resources = data_set 1287 pengine/allocate.c g_list_sort_with_data(data_set->resources, sort_rsc_process_order, nodes); data_set 1292 pengine/allocate.c gIter = data_set->nodes; data_set 1302 pengine/allocate.c allocate_resources(data_set); data_set 1304 pengine/allocate.c gIter = data_set->nodes; data_set 1311 pengine/allocate.c if (is_set(data_set->flags, pe_flag_startup_probes)) { data_set 1347 pengine/allocate.c probe_resources(data_set); data_set 1352 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1354 pengine/allocate.c cleanup_orphans(rsc, data_set); data_set 1359 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 1362 pengine/allocate.c rsc->cmds->create_actions(rsc, data_set); data_set 1390 pengine/allocate.c any_managed_resources(pe_working_set_t * data_set) data_set 1393 pengine/allocate.c GListPtr gIter = data_set->resources; data_set 1414 pengine/allocate.c fence_guest(pe_node_t *node, pe_action_t *done, pe_working_set_t *data_set) data_set 1442 pengine/allocate.c stonith_op = pe_fence_op(node, fence_action, FALSE, "guest is unclean", data_set); data_set 1451 pengine/allocate.c pe_action_t *parent_stonith_op = pe_fence_op(stop->node, NULL, FALSE, NULL, data_set); data_set 1472 pengine/allocate.c stonith_constraints(node, stonith_op, data_set); data_set 1480 pengine/allocate.c stage6(pe_working_set_t * data_set) data_set 1487 pengine/allocate.c action_t *all_stopped = get_pseudo_op(ALL_STOPPED, data_set); data_set 1488 pengine/allocate.c action_t *done = get_pseudo_op(STONITH_DONE, data_set); data_set 1502 pengine/allocate.c apply_remote_node_ordering(data_set); data_set 1505 pengine/allocate.c if (any_managed_resources(data_set) == FALSE) { data_set 1511 pengine/allocate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1519 pengine/allocate.c fence_guest(node, done, data_set); data_set 1527 pengine/allocate.c && need_stonith && pe_can_fence(data_set, node)) { data_set 1529 pengine/allocate.c stonith_op = pe_fence_op(node, NULL, FALSE, "node is unclean", data_set); data_set 1532 pengine/allocate.c stonith_constraints(node, stonith_op, data_set); data_set 1538 pengine/allocate.c } else if (is_set(data_set->flags, pe_flag_concurrent_fencing) == FALSE) { data_set 1560 pengine/allocate.c CRM_OP_SHUTDOWN, node, FALSE, TRUE, data_set); data_set 1562 pengine/allocate.c shutdown_constraints(node, down_op, data_set); data_set 1577 pengine/allocate.c if (is_set(data_set->flags, pe_flag_stonith_enabled) == FALSE) { data_set 1581 pengine/allocate.c } else if (is_set(data_set->flags, pe_flag_have_quorum) == FALSE) { data_set 1595 pengine/allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 1737 pengine/allocate.c rsc_order_first(resource_t * lh_rsc, order_constraint_t * order, pe_working_set_t * data_set) data_set 1776 pengine/allocate.c lh_action = custom_action(lh_rsc, key, op_type, NULL, TRUE, TRUE, data_set); data_set 1817 pengine/allocate.c apply_container_ordering(action_t *action, pe_working_set_t *data_set) data_set 1841 pengine/allocate.c pe_fence_node(data_set, action->node, "container failed"); data_set 1864 pengine/allocate.c data_set); data_set 1868 pengine/allocate.c data_set); data_set 1890 pengine/allocate.c data_set); data_set 1903 pengine/allocate.c pe_order_implies_then, data_set); data_set 1907 pengine/allocate.c data_set); data_set 1989 pengine/allocate.c apply_remote_ordering(action_t *action, pe_working_set_t *data_set) data_set 2036 pengine/allocate.c order_start_then_action(remote_rsc, action, order_opts, data_set); data_set 2046 pengine/allocate.c data_set); data_set 2055 pengine/allocate.c pe_fence_node(data_set, action->node, "resources are active and the connection is unrecoverable"); data_set 2059 pengine/allocate.c pe_order_implies_first, data_set); data_set 2070 pengine/allocate.c data_set); data_set 2082 pengine/allocate.c pe_order_implies_then, data_set); data_set 2091 pengine/allocate.c pe_fence_node(data_set, action->node, "resources are in an unknown state and the connection is unrecoverable"); data_set 2103 pengine/allocate.c pe_order_runnable_left, data_set); data_set 2107 pengine/allocate.c data_set); data_set 2115 pengine/allocate.c apply_remote_node_ordering(pe_working_set_t *data_set) data_set 2117 pengine/allocate.c if (is_set(data_set->flags, pe_flag_have_remote_nodes) == FALSE) { data_set 2121 pengine/allocate.c for (GListPtr gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2144 pengine/allocate.c data_set); data_set 2185 pengine/allocate.c apply_container_ordering(action, data_set); data_set 2189 pengine/allocate.c apply_remote_ordering(action, data_set); data_set 2195 pengine/allocate.c order_probes(pe_working_set_t * data_set) data_set 2200 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2317 pengine/allocate.c stage7(pe_working_set_t * data_set) data_set 2329 pengine/allocate.c data_set->ordering_constraints = g_list_reverse(data_set->ordering_constraints); data_set 2331 pengine/allocate.c for (gIter = data_set->ordering_constraints; gIter != NULL; gIter = gIter->next) { data_set 2339 pengine/allocate.c rsc_order_first(rsc, order, data_set); data_set 2354 pengine/allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2361 pengine/allocate.c order_probes(data_set); data_set 2363 pengine/allocate.c crm_trace("Updating %d actions", g_list_length(data_set->actions)); data_set 2364 pengine/allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2370 pengine/allocate.c LogNodeActions(data_set, FALSE); data_set 2371 pengine/allocate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2374 pengine/allocate.c LogActions(rsc, data_set, FALSE); data_set 2385 pengine/allocate.c stage8(pe_working_set_t * data_set) data_set 2393 pengine/allocate.c data_set->graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 2395 pengine/allocate.c value = pe_pref(data_set->config_hash, "cluster-delay"); data_set 2396 pengine/allocate.c crm_xml_add(data_set->graph, "cluster-delay", value); data_set 2398 pengine/allocate.c value = pe_pref(data_set->config_hash, "stonith-timeout"); data_set 2399 pengine/allocate.c crm_xml_add(data_set->graph, "stonith-timeout", value); data_set 2401 pengine/allocate.c crm_xml_add(data_set->graph, "failed-stop-offset", "INFINITY"); data_set 2403 pengine/allocate.c if (is_set(data_set->flags, pe_flag_start_failure_fatal)) { data_set 2404 pengine/allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "INFINITY"); data_set 2406 pengine/allocate.c crm_xml_add(data_set->graph, "failed-start-offset", "1"); data_set 2409 pengine/allocate.c value = pe_pref(data_set->config_hash, "batch-limit"); data_set 2410 pengine/allocate.c crm_xml_add(data_set->graph, "batch-limit", value); data_set 2412 pengine/allocate.c crm_xml_add_int(data_set->graph, "transition_id", transition_id); data_set 2414 pengine/allocate.c value = pe_pref(data_set->config_hash, "migration-limit"); data_set 2416 pengine/allocate.c crm_xml_add(data_set->graph, "migration-limit", value); data_set 2427 pengine/allocate.c gIter = data_set->resources; data_set 2432 pengine/allocate.c rsc->cmds->expand(rsc, data_set); data_set 2435 pengine/allocate.c crm_log_xml_trace(data_set->graph, "created resource-driven action list"); data_set 2438 pengine/allocate.c add_maintenance_update(data_set); data_set 2443 pengine/allocate.c gIter = data_set->actions; data_set 2459 pengine/allocate.c if (is_set(data_set->flags, pe_flag_have_quorum) data_set 2460 pengine/allocate.c || data_set->no_quorum_policy == no_quorum_ignore) { data_set 2470 pengine/allocate.c graph_element_from_action(action, data_set); data_set 2473 pengine/allocate.c crm_log_xml_trace(data_set->graph, "created generic action list"); data_set 2480 pengine/allocate.c LogNodeActions(pe_working_set_t * data_set, gboolean terminal) data_set 2484 pengine/allocate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 2527 pengine/allocate.c cleanup_alloc_calculations(pe_working_set_t * data_set) data_set 2529 pengine/allocate.c if (data_set == NULL) { data_set 2534 pengine/allocate.c g_list_length(data_set->ordering_constraints), data_set->ordering_constraints); data_set 2535 pengine/allocate.c pe_free_ordering(data_set->ordering_constraints); data_set 2536 pengine/allocate.c data_set->ordering_constraints = NULL; data_set 2539 pengine/allocate.c g_list_length(data_set->placement_constraints), data_set->placement_constraints); data_set 2540 pengine/allocate.c pe_free_rsc_to_node(data_set->placement_constraints); data_set 2541 pengine/allocate.c data_set->placement_constraints = NULL; data_set 2544 pengine/allocate.c g_list_length(data_set->colocation_constraints), data_set->colocation_constraints); data_set 2545 pengine/allocate.c g_list_free_full(data_set->colocation_constraints, free); data_set 2546 pengine/allocate.c data_set->colocation_constraints = NULL; data_set 2549 pengine/allocate.c g_list_length(data_set->ticket_constraints), data_set->ticket_constraints); data_set 2550 pengine/allocate.c g_list_free_full(data_set->ticket_constraints, free); data_set 2551 pengine/allocate.c data_set->ticket_constraints = NULL; data_set 2553 pengine/allocate.c cleanup_calculations(data_set); data_set 67 pengine/allocate.h extern node_t *native_color(resource_t * rsc, node_t * preferred, pe_working_set_t * data_set); data_set 68 pengine/allocate.h extern void native_create_actions(resource_t * rsc, pe_working_set_t * data_set); data_set 69 pengine/allocate.h extern void native_internal_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 75 pengine/allocate.h pe_working_set_t * data_set); data_set 79 pengine/allocate.h extern void native_expand(resource_t * rsc, pe_working_set_t * data_set); data_set 82 pengine/allocate.h gboolean force, pe_working_set_t * data_set); data_set 86 pengine/allocate.h extern node_t *group_color(resource_t * rsc, node_t * preferred, pe_working_set_t * data_set); data_set 87 pengine/allocate.h extern void group_create_actions(resource_t * rsc, pe_working_set_t * data_set); data_set 88 pengine/allocate.h extern void group_internal_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 95 pengine/allocate.h extern void group_expand(resource_t * rsc, pe_working_set_t * data_set); data_set 99 pengine/allocate.h extern node_t *container_color(resource_t * rsc, node_t * preferred, pe_working_set_t * data_set); data_set 100 pengine/allocate.h extern void container_create_actions(resource_t * rsc, pe_working_set_t * data_set); data_set 101 pengine/allocate.h extern void container_internal_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 108 pengine/allocate.h extern void container_expand(resource_t * rsc, pe_working_set_t * data_set); data_set 110 pengine/allocate.h gboolean force, pe_working_set_t * data_set); data_set 114 pengine/allocate.h extern node_t *clone_color(resource_t * rsc, node_t * preferred, pe_working_set_t * data_set); data_set 115 pengine/allocate.h extern void clone_create_actions(resource_t * rsc, pe_working_set_t * data_set); data_set 116 pengine/allocate.h extern void clone_internal_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 123 pengine/allocate.h extern void clone_expand(resource_t * rsc, pe_working_set_t * data_set); data_set 125 pengine/allocate.h gboolean force, pe_working_set_t * data_set); data_set 128 pengine/allocate.h extern gboolean master_unpack(resource_t * rsc, pe_working_set_t * data_set); data_set 129 pengine/allocate.h extern node_t *master_color(resource_t * rsc, node_t * preferred, pe_working_set_t * data_set); data_set 130 pengine/allocate.h extern void master_create_actions(resource_t * rsc, pe_working_set_t * data_set); data_set 131 pengine/allocate.h extern void master_internal_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 143 pengine/allocate.h extern gboolean unpack_rsc_to_attr(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 145 pengine/allocate.h extern gboolean unpack_rsc_to_node(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 147 pengine/allocate.h extern gboolean unpack_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 149 pengine/allocate.h extern gboolean unpack_rsc_colocation(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 151 pengine/allocate.h extern gboolean unpack_location(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 153 pengine/allocate.h extern gboolean unpack_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set); data_set 155 pengine/allocate.h void LogNodeActions(pe_working_set_t * data_set, gboolean terminal); data_set 156 pengine/allocate.h void LogActions(resource_t * rsc, pe_working_set_t * data_set, gboolean terminal); data_set 157 pengine/allocate.h void container_LogActions(resource_t * rsc, pe_working_set_t * data_set, gboolean terminal); data_set 159 pengine/allocate.h extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 162 pengine/allocate.h pe_working_set_t * data_set); data_set 179 pengine/allocate.h void master_promotion_constraints(resource_t * rsc, pe_working_set_t * data_set); data_set 181 pengine/allocate.h resource_t * rsc, GListPtr children, notify_data_t **start_notify, notify_data_t **stop_notify, pe_working_set_t * data_set); data_set 30 pengine/clone.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 78 pengine/clone.c sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 413 pengine/clone.c color_instance(resource_t * rsc, node_t * prefer, gboolean all_coloc, int limit, pe_working_set_t * data_set) data_set 449 pengine/clone.c chosen = rsc->cmds->allocate(rsc, prefer, data_set); data_set 506 pengine/clone.c int max, int per_host_max, pe_working_set_t * data_set); data_set 510 pengine/clone.c int max, int per_host_max, pe_working_set_t * data_set) data_set 557 pengine/clone.c } else if (color_instance(child, child_node, max < available_nodes, per_host_max, data_set)) { data_set 583 pengine/clone.c resource_location(child, NULL, -INFINITY, "clone_color:limit_reached", data_set); data_set 585 pengine/clone.c if (color_instance(child, NULL, max < available_nodes, per_host_max, data_set)) { data_set 597 pengine/clone.c clone_color(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 623 pengine/clone.c constraint->rsc_rh->cmds->allocate(constraint->rsc_rh, prefer, data_set); data_set 640 pengine/clone.c rsc->children = g_list_sort_with_data(rsc->children, sort_clone_instance, data_set); data_set 641 pengine/clone.c distribute_children(rsc, rsc->children, nodes, clone_data->clone_max, clone_data->clone_node_max, data_set); data_set 762 pengine/clone.c child_ordering_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 811 pengine/clone.c clone_create_actions(resource_t * rsc, pe_working_set_t * data_set) data_set 816 pengine/clone.c clone_create_pseudo_actions(rsc, rsc->children, &clone_data->start_notify, &clone_data->stop_notify,data_set); data_set 817 pengine/clone.c child_ordering_constraints(rsc, data_set); data_set 822 pengine/clone.c resource_t * rsc, GListPtr children, notify_data_t **start_notify, notify_data_t **stop_notify, pe_working_set_t * data_set) data_set 842 pengine/clone.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 853 pengine/clone.c start = create_pseudo_resource_op(rsc, RSC_START, !child_starting, TRUE, data_set); data_set 854 pengine/clone.c started = create_pseudo_resource_op(rsc, RSC_STARTED, !child_starting, FALSE, data_set); data_set 862 pengine/clone.c *start_notify = create_notification_boundaries(rsc, RSC_START, start, started, data_set); data_set 866 pengine/clone.c stop = create_pseudo_resource_op(rsc, RSC_STOP, !child_stopping, TRUE, data_set); data_set 867 pengine/clone.c stopped = create_pseudo_resource_op(rsc, RSC_STOPPED, !child_stopping, TRUE, data_set); data_set 874 pengine/clone.c *stop_notify = create_notification_boundaries(rsc, RSC_STOP, stop, stopped, data_set); data_set 883 pengine/clone.c clone_internal_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 892 pengine/clone.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 893 pengine/clone.c new_rsc_order(rsc, RSC_START, rsc, RSC_STARTED, pe_order_runnable_left, data_set); data_set 894 pengine/clone.c new_rsc_order(rsc, RSC_STOP, rsc, RSC_STOPPED, pe_order_runnable_left, data_set); data_set 897 pengine/clone.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_STOP, pe_order_optional, data_set); data_set 898 pengine/clone.c new_rsc_order(rsc, RSC_STARTED, rsc, RSC_PROMOTE, pe_order_runnable_left, data_set); data_set 908 pengine/clone.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 912 pengine/clone.c data_set); data_set 919 pengine/clone.c data_set); data_set 1208 pengine/clone.c clone_expand(resource_t * rsc, pe_working_set_t * data_set) data_set 1224 pengine/clone.c expand_notification_data(rsc, clone_data->start_notify, data_set); data_set 1225 pengine/clone.c create_notifications(rsc, clone_data->start_notify, data_set); data_set 1230 pengine/clone.c expand_notification_data(rsc, clone_data->stop_notify, data_set); data_set 1231 pengine/clone.c create_notifications(rsc, clone_data->stop_notify, data_set); data_set 1236 pengine/clone.c expand_notification_data(rsc, clone_data->promote_notify, data_set); data_set 1237 pengine/clone.c create_notifications(rsc, clone_data->promote_notify, data_set); data_set 1242 pengine/clone.c expand_notification_data(rsc, clone_data->demote_notify, data_set); data_set 1243 pengine/clone.c create_notifications(rsc, clone_data->demote_notify, data_set); data_set 1252 pengine/clone.c child_rsc->cmds->expand(child_rsc, data_set); data_set 1255 pengine/clone.c native_expand(rsc, data_set); data_set 1339 pengine/clone.c gboolean force, pe_working_set_t * data_set) data_set 1379 pengine/clone.c return child->cmds->create_probe(child, node, complete, force, data_set); data_set 1395 pengine/clone.c return child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set); data_set 1402 pengine/clone.c return child->cmds->create_probe(child, node, complete, force, data_set); data_set 1409 pengine/clone.c if (child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set)) { data_set 45 pengine/constraints.c __rsc = pe_find_constraint_resource(data_set->resources, __name); \ data_set 56 pengine/constraints.c const char *discovery, pe_working_set_t * data_set, data_set 60 pengine/constraints.c unpack_constraints(xmlNode * xml_constraints, pe_working_set_t * data_set) data_set 84 pengine/constraints.c if (test_ruleset(lifetime, NULL, data_set->now) == FALSE) { data_set 88 pengine/constraints.c unpack_rsc_order(xml_obj, data_set); data_set 91 pengine/constraints.c unpack_rsc_colocation(xml_obj, data_set); data_set 94 pengine/constraints.c unpack_location(xml_obj, data_set); data_set 97 pengine/constraints.c unpack_rsc_ticket(xml_obj, data_set); data_set 201 pengine/constraints.c pe_find_constraint_tag(pe_working_set_t * data_set, const char * id, tag_t ** tag) data_set 206 pengine/constraints.c rc = g_hash_table_lookup_extended(data_set->template_rsc_sets, id, data_set 210 pengine/constraints.c rc = g_hash_table_lookup_extended(data_set->tags, id, data_set 231 pengine/constraints.c valid_resource_or_tag(pe_working_set_t * data_set, const char * id, data_set 238 pengine/constraints.c *rsc = pe_find_constraint_resource(data_set->resources, id); data_set 246 pengine/constraints.c rc = pe_find_constraint_tag(data_set, id, tag); data_set 253 pengine/constraints.c unpack_simple_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 307 pengine/constraints.c rsc_then = pe_find_constraint_resource(data_set->resources, id_then); data_set 308 pengine/constraints.c rsc_first = pe_find_constraint_resource(data_set->resources, id_first); data_set 332 pengine/constraints.c rsc_then = find_clone_instance(rsc_then, instance_then, data_set); data_set 341 pengine/constraints.c rsc_first = find_clone_instance(rsc_first, instance_first, data_set); data_set 385 pengine/constraints.c action_t *unordered_action = get_pseudo_op(task, data_set); data_set 399 pengine/constraints.c pe_order_one_or_more | pe_order_implies_then_printed, data_set); data_set 406 pengine/constraints.c cons_weight | pe_order_runnable_left, data_set); data_set 408 pengine/constraints.c order_id = new_rsc_order(rsc_first, action_first, rsc_then, action_then, cons_weight, data_set); data_set 441 pengine/constraints.c order_id = new_rsc_order(rsc_then, action_then, rsc_first, action_first, cons_weight, data_set); data_set 450 pengine/constraints.c expand_tags_in_sets(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 485 pengine/constraints.c if (valid_resource_or_tag(data_set, id, &rsc, &tag) == FALSE) { data_set 570 pengine/constraints.c gboolean convert_rsc, pe_working_set_t * data_set) data_set 601 pengine/constraints.c if (valid_resource_or_tag(data_set, id, &rsc, &tag) == FALSE) { data_set 649 pengine/constraints.c const char * score, pe_working_set_t * data_set, pe_match_data_t * match_data); data_set 652 pengine/constraints.c unpack_simple_location(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 658 pengine/constraints.c resource_t *rsc_lh = pe_find_constraint_resource(data_set->resources, value); data_set 660 pengine/constraints.c return unpack_rsc_location(xml_obj, rsc_lh, NULL, NULL, data_set, NULL); data_set 681 pengine/constraints.c for (rIter = data_set->resources; rIter; rIter = rIter->next) { data_set 708 pengine/constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, &match_data); data_set 712 pengine/constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, NULL); data_set 730 pengine/constraints.c const char * score, pe_working_set_t * data_set, pe_match_data_t * match_data) data_set 751 pengine/constraints.c node_t *match = pe_find_node(data_set->nodes, node); data_set 756 pengine/constraints.c location = rsc2node_new(id, rsc_lh, score_i, discovery, match, data_set); data_set 766 pengine/constraints.c generate_location_rule(rsc_lh, rule_xml, discovery, data_set, match_data); data_set 805 pengine/constraints.c unpack_location_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 832 pengine/constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 845 pengine/constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 859 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_LOC_ATTR_SOURCE, FALSE, data_set) == FALSE) { data_set 883 pengine/constraints.c unpack_location_set(xmlNode * location, xmlNode * set, pe_working_set_t * data_set) data_set 908 pengine/constraints.c unpack_rsc_location(location, resource, role, local_score, data_set, NULL); data_set 916 pengine/constraints.c unpack_location(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 924 pengine/constraints.c if (unpack_location_tags(xml_obj, &expanded_xml, data_set) == FALSE) { data_set 936 pengine/constraints.c set = expand_idref(set, data_set->input); data_set 937 pengine/constraints.c if (unpack_location_set(xml_obj, set, data_set) == FALSE) { data_set 952 pengine/constraints.c return unpack_simple_location(xml_obj, data_set); data_set 987 pengine/constraints.c generate_location_rule(resource_t * rsc, xmlNode * rule_xml, const char *discovery, pe_working_set_t * data_set, data_set 1005 pengine/constraints.c rule_xml = expand_idref(rule_xml, data_set->input); data_set 1028 pengine/constraints.c location_rule = rsc2node_new(rule_id, rsc, 0, discovery, NULL, data_set); data_set 1058 pengine/constraints.c match_L = node_list_dup(data_set->nodes, TRUE, FALSE); data_set 1066 pengine/constraints.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 1070 pengine/constraints.c accept = pe_test_rule_full(rule_xml, node->details->attrs, RSC_ROLE_UNKNOWN, data_set->now, match_data); data_set 1193 pengine/constraints.c pe_working_set_t * data_set) data_set 1227 pengine/constraints.c pe_order_anti_colocation, data_set); data_set 1235 pengine/constraints.c const char *state_lh, const char *state_rh, pe_working_set_t * data_set) data_set 1280 pengine/constraints.c data_set->colocation_constraints = g_list_append(data_set->colocation_constraints, new_con); data_set 1283 pengine/constraints.c anti_colocation_order(rsc_lh, new_con->role_lh, rsc_rh, new_con->role_rh, data_set); data_set 1284 pengine/constraints.c anti_colocation_order(rsc_rh, new_con->role_rh, rsc_lh, new_con->role_lh, data_set); data_set 1294 pengine/constraints.c enum pe_ordering type, pe_working_set_t * data_set) data_set 1315 pengine/constraints.c return custom_action_order(lh_rsc, lh_key, NULL, rh_rsc, rh_key, NULL, type, data_set); data_set 1347 pengine/constraints.c handle_migration_ordering(order_constraint_t *order, pe_working_set_t *data_set) data_set 1393 pengine/constraints.c flags, data_set); data_set 1405 pengine/constraints.c flags, data_set); data_set 1420 pengine/constraints.c flags, data_set); data_set 1427 pengine/constraints.c flags, data_set); data_set 1438 pengine/constraints.c flags, data_set); data_set 1449 pengine/constraints.c flags, data_set); data_set 1456 pengine/constraints.c flags, data_set); data_set 1470 pengine/constraints.c enum pe_ordering type, pe_working_set_t * data_set) data_set 1491 pengine/constraints.c crm_trace("Creating[%d] %s %s %s - %s %s %s", data_set->order_id, data_set 1497 pengine/constraints.c order->id = data_set->order_id++; data_set 1522 pengine/constraints.c data_set->ordering_constraints = g_list_prepend(data_set->ordering_constraints, order); data_set 1523 pengine/constraints.c handle_migration_ordering(order, data_set); data_set 1570 pengine/constraints.c const char *symmetrical, pe_working_set_t * data_set) data_set 1671 pengine/constraints.c flags, data_set); data_set 1676 pengine/constraints.c new_rsc_order(last, action, resource, action, flags, data_set); data_set 1729 pengine/constraints.c new_rsc_order(resource, action, last, action, flags, data_set); data_set 1742 pengine/constraints.c pe_working_set_t * data_set, gboolean invert, gboolean symmetrical) data_set 1792 pengine/constraints.c action_t *unordered_action = get_pseudo_op(task, data_set); data_set 1808 pengine/constraints.c pe_order_one_or_more | pe_order_implies_then_printed, data_set); data_set 1821 pengine/constraints.c flags | pe_order_runnable_left, data_set); data_set 1874 pengine/constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 1880 pengine/constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 1890 pengine/constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 1905 pengine/constraints.c new_rsc_order(rsc_1, action_1, rsc_2, action_2, flags, data_set); data_set 1916 pengine/constraints.c unpack_order_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 1948 pengine/constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 1962 pengine/constraints.c if (valid_resource_or_tag(data_set, id_first, &rsc_first, &tag_first) == FALSE) { data_set 1967 pengine/constraints.c if (valid_resource_or_tag(data_set, id_then, &rsc_then, &tag_then) == FALSE) { data_set 1983 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_first, XML_ORDER_ATTR_FIRST, TRUE, data_set) == FALSE) { data_set 1999 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_then, XML_ORDER_ATTR_THEN, TRUE, data_set) == FALSE) { data_set 2025 pengine/constraints.c unpack_rsc_order(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2067 pengine/constraints.c rc = unpack_order_tags(xml_obj, &expanded_xml, data_set); data_set 2079 pengine/constraints.c set = expand_idref(set, data_set->input); data_set 2081 pengine/constraints.c &set_inv_begin, &set_inv_end, invert, data_set) == FALSE) { data_set 2122 pengine/constraints.c if (order_rsc_sets(id, last, set, kind, data_set, FALSE, invert_bool) == FALSE) { data_set 2127 pengine/constraints.c && order_rsc_sets(id, set, last, kind, data_set, TRUE, invert_bool) == FALSE) { data_set 2149 pengine/constraints.c return unpack_simple_rsc_order(xml_obj, data_set); data_set 2156 pengine/constraints.c unpack_colocation_set(xmlNode * set, int score, pe_working_set_t * data_set) data_set 2187 pengine/constraints.c data_set); data_set 2201 pengine/constraints.c data_set); data_set 2234 pengine/constraints.c data_set); data_set 2246 pengine/constraints.c pe_working_set_t * data_set) data_set 2281 pengine/constraints.c rsc_colocation_new(id, NULL, score, rsc_1, rsc_2, role_1, role_2, data_set); data_set 2287 pengine/constraints.c rsc_colocation_new(id, NULL, score, rsc_1, rsc_2, role_1, role_2, data_set); data_set 2295 pengine/constraints.c rsc_colocation_new(id, NULL, score, rsc_1, rsc_2, role_1, role_2, data_set); data_set 2310 pengine/constraints.c rsc_colocation_new(id, NULL, score, rsc_1, rsc_2, role_1, role_2, data_set); data_set 2321 pengine/constraints.c unpack_simple_colocation(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2338 pengine/constraints.c resource_t *rsc_lh = pe_find_constraint_resource(data_set->resources, id_lh); data_set 2339 pengine/constraints.c resource_t *rsc_rh = pe_find_constraint_resource(data_set->resources, id_rh); data_set 2363 pengine/constraints.c rsc_lh = find_clone_instance(rsc_lh, instance_lh, data_set); data_set 2372 pengine/constraints.c rsc_rh = find_clone_instance(rsc_rh, instance_rh, data_set); data_set 2389 pengine/constraints.c rsc_colocation_new(id, attr, score_i, rsc_lh, rsc_rh, state_lh, state_rh, data_set); data_set 2394 pengine/constraints.c unpack_colocation_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 2427 pengine/constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 2441 pengine/constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 2446 pengine/constraints.c if (valid_resource_or_tag(data_set, id_rh, &rsc_rh, &tag_rh) == FALSE) { data_set 2469 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_COLOC_ATTR_SOURCE, TRUE, data_set) == FALSE) { data_set 2485 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_rh, XML_COLOC_ATTR_TARGET, TRUE, data_set) == FALSE) { data_set 2511 pengine/constraints.c unpack_rsc_colocation(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2530 pengine/constraints.c rc = unpack_colocation_tags(xml_obj, &expanded_xml, data_set); data_set 2542 pengine/constraints.c set = expand_idref(set, data_set->input); data_set 2543 pengine/constraints.c if (unpack_colocation_set(set, score_i, data_set) == FALSE) { data_set 2546 pengine/constraints.c } else if (last && colocate_rsc_sets(id, last, set, score_i, data_set) == FALSE) { data_set 2559 pengine/constraints.c return unpack_simple_colocation(xml_obj, data_set); data_set 2567 pengine/constraints.c const char *state_lh, const char *loss_policy, pe_working_set_t * data_set) data_set 2591 pengine/constraints.c if (is_set(data_set->flags, pe_flag_stonith_enabled)) { data_set 2643 pengine/constraints.c data_set->ticket_constraints = g_list_append(data_set->ticket_constraints, new_rsc_ticket); data_set 2646 pengine/constraints.c rsc_ticket_constraint(rsc_lh, new_rsc_ticket, data_set); data_set 2654 pengine/constraints.c pe_working_set_t * data_set) data_set 2678 pengine/constraints.c rsc_ticket_new(set_id, resource, ticket, role, loss_policy, data_set); data_set 2685 pengine/constraints.c unpack_simple_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2713 pengine/constraints.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 2725 pengine/constraints.c rsc_lh = pe_find_constraint_resource(data_set->resources, id_lh); data_set 2740 pengine/constraints.c rsc_lh = find_clone_instance(rsc_lh, instance_lh, data_set); data_set 2748 pengine/constraints.c rsc_ticket_new(id, rsc_lh, ticket, state_lh, loss_policy, data_set); data_set 2753 pengine/constraints.c unpack_rsc_ticket_tags(xmlNode * xml_obj, xmlNode ** expanded_xml, pe_working_set_t * data_set) data_set 2780 pengine/constraints.c expand_tags_in_sets(xml_obj, &new_xml, data_set); data_set 2793 pengine/constraints.c if (valid_resource_or_tag(data_set, id_lh, &rsc_lh, &tag_lh) == FALSE) { data_set 2807 pengine/constraints.c if (tag_to_set(new_xml, &rsc_set_lh, XML_COLOC_ATTR_SOURCE, FALSE, data_set) == FALSE) { data_set 2833 pengine/constraints.c unpack_rsc_ticket(xmlNode * xml_obj, pe_working_set_t * data_set) data_set 2859 pengine/constraints.c if (data_set->tickets == NULL) { data_set 2860 pengine/constraints.c data_set->tickets = data_set 2868 pengine/constraints.c ticket = g_hash_table_lookup(data_set->tickets, ticket_str); data_set 2872 pengine/constraints.c ticket = ticket_new(ticket_str, data_set); data_set 2878 pengine/constraints.c rc = unpack_rsc_ticket_tags(xml_obj, &expanded_xml, data_set); data_set 2890 pengine/constraints.c set = expand_idref(set, data_set->input); data_set 2891 pengine/constraints.c if (unpack_rsc_ticket_set(set, ticket, loss_policy, data_set) == FALSE) { data_set 2903 pengine/constraints.c return unpack_simple_rsc_ticket(xml_obj, data_set); data_set 41 pengine/container.c gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 43 pengine/container.c int max, int per_host_max, pe_working_set_t * data_set); data_set 79 pengine/container.c pe_working_set_t *data_set) data_set 96 pengine/container.c data_set); data_set 117 pengine/container.c container_color(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 134 pengine/container.c containers = g_list_sort_with_data(containers, sort_clone_instance, data_set); data_set 136 pengine/container.c container_data->replicas, container_data->replicas_per_host, data_set); data_set 146 pengine/container.c tuple->ip->cmds->allocate(tuple->ip, prefer, data_set); data_set 155 pengine/container.c INFINITY, tuple->remote, docker_host->details->remote_rsc, NULL, NULL, data_set); data_set 159 pengine/container.c tuple->remote->cmds->allocate(tuple->remote, prefer, data_set); data_set 170 pengine/container.c } else if(migration_threshold_reached(tuple->child, node, data_set) == FALSE) { data_set 176 pengine/container.c tuple->child->cmds->allocate(tuple->child, tuple->node, data_set); data_set 192 pengine/container.c container_data->child->cmds->allocate(container_data->child, prefer, data_set); data_set 202 pengine/container.c container_create_actions(resource_t * rsc, pe_working_set_t * data_set) data_set 217 pengine/container.c tuple->ip->cmds->create_actions(tuple->ip, data_set); data_set 220 pengine/container.c tuple->docker->cmds->create_actions(tuple->docker, data_set); data_set 223 pengine/container.c tuple->remote->cmds->create_actions(tuple->remote, data_set); data_set 227 pengine/container.c clone_create_pseudo_actions(rsc, containers, NULL, NULL, data_set); data_set 230 pengine/container.c container_data->child->cmds->create_actions(container_data->child, data_set); data_set 234 pengine/container.c action = create_pseudo_resource_op(rsc, RSC_PROMOTE, TRUE, TRUE, data_set); data_set 235 pengine/container.c action = create_pseudo_resource_op(rsc, RSC_PROMOTED, TRUE, TRUE, data_set); data_set 239 pengine/container.c action = create_pseudo_resource_op(rsc, RSC_DEMOTE, TRUE, TRUE, data_set); data_set 240 pengine/container.c action = create_pseudo_resource_op(rsc, RSC_DEMOTED, TRUE, TRUE, data_set); data_set 249 pengine/container.c container_internal_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 258 pengine/container.c new_rsc_order(rsc, RSC_START, container_data->child, RSC_START, pe_order_implies_first_printed, data_set); data_set 259 pengine/container.c new_rsc_order(rsc, RSC_STOP, container_data->child, RSC_STOP, pe_order_implies_first_printed, data_set); data_set 262 pengine/container.c new_rsc_order(container_data->child, RSC_STARTED, rsc, RSC_STARTED, pe_order_implies_then_printed, data_set); data_set 263 pengine/container.c new_rsc_order(container_data->child, RSC_STOPPED, rsc, RSC_STOPPED, pe_order_implies_then_printed, data_set); data_set 265 pengine/container.c new_rsc_order(container_data->child, RSC_START, rsc, RSC_STARTED, pe_order_implies_then_printed, data_set); data_set 266 pengine/container.c new_rsc_order(container_data->child, RSC_STOP, rsc, RSC_STOPPED, pe_order_implies_then_printed, data_set); data_set 276 pengine/container.c tuple->docker->cmds->internal_constraints(tuple->docker, data_set); data_set 284 pengine/container.c new_rsc_order(tuple->docker, RSC_START, rsc, RSC_STARTED, pe_order_implies_then_printed, data_set); data_set 285 pengine/container.c new_rsc_order(tuple->docker, RSC_STOP, rsc, RSC_STOPPED, pe_order_implies_then_printed, data_set); data_set 288 pengine/container.c tuple->ip->cmds->internal_constraints(tuple->ip, data_set); data_set 292 pengine/container.c pe_order_runnable_left|pe_order_preserve, data_set); data_set 294 pengine/container.c pe_order_implies_first|pe_order_preserve, data_set); data_set 296 pengine/container.c rsc_colocation_new("ip-with-docker", NULL, INFINITY, tuple->ip, tuple->docker, NULL, NULL, data_set); data_set 305 pengine/container.c tuple->remote->cmds->internal_constraints(tuple->remote, data_set); data_set 317 pengine/container.c container_data->child->cmds->internal_constraints(container_data->child, data_set); data_set 319 pengine/container.c master_promotion_constraints(rsc, data_set); data_set 322 pengine/container.c new_rsc_order(container_data->child, RSC_DEMOTED, rsc, RSC_DEMOTED, pe_order_implies_then_printed, data_set); data_set 325 pengine/container.c new_rsc_order(rsc, RSC_DEMOTE, container_data->child, RSC_DEMOTE, pe_order_implies_first_printed, data_set); data_set 328 pengine/container.c new_rsc_order(container_data->child, RSC_PROMOTED, rsc, RSC_PROMOTED, pe_order_implies_then_printed, data_set); data_set 331 pengine/container.c new_rsc_order(rsc, RSC_PROMOTE, container_data->child, RSC_PROMOTE, pe_order_implies_first_printed, data_set); data_set 818 pengine/container.c container_expand(resource_t * rsc, pe_working_set_t * data_set) data_set 827 pengine/container.c container_data->child->cmds->expand(container_data->child, data_set); data_set 847 pengine/container.c tuple->ip->cmds->expand(tuple->ip, data_set); data_set 850 pengine/container.c tuple->docker->cmds->expand(tuple->docker, data_set); data_set 853 pengine/container.c tuple->remote->cmds->expand(tuple->remote, data_set); data_set 860 pengine/container.c gboolean force, pe_working_set_t * data_set) data_set 873 pengine/container.c any_created |= tuple->ip->cmds->create_probe(tuple->ip, node, complete, force, data_set); data_set 876 pengine/container.c any_created |= tuple->child->cmds->create_probe(tuple->child, node, complete, force, data_set); data_set 879 pengine/container.c bool created = tuple->docker->cmds->create_probe(tuple->docker, node, complete, force, data_set); data_set 904 pengine/container.c pe_order_optional|pe_order_same_node, data_set); data_set 911 pengine/container.c force, data_set)) { data_set 927 pengine/container.c pe_order_probe, data_set); data_set 947 pengine/container.c resource_t * rsc, pe_working_set_t * data_set, gboolean terminal) data_set 959 pengine/container.c LogActions(tuple->ip, data_set, terminal); data_set 962 pengine/container.c LogActions(tuple->docker, data_set, terminal); data_set 965 pengine/container.c LogActions(tuple->remote, data_set, terminal); data_set 968 pengine/container.c LogActions(tuple->child, data_set, terminal); data_set 713 pengine/graph.c shutdown_constraints(node_t * node, action_t * shutdown_op, pe_working_set_t * data_set) data_set 720 pengine/graph.c for (lpc = data_set->actions; lpc != NULL; lpc = lpc->next) { data_set 750 pengine/graph.c pe_order_optional | pe_order_runnable_left, data_set); data_set 769 pengine/graph.c stonith_constraints(node_t * node, action_t * stonith_op, pe_working_set_t * data_set) data_set 774 pengine/graph.c for (r = data_set->resources; r != NULL; r = r->next) { data_set 775 pengine/graph.c rsc_stonith_ordering((resource_t *) r->data, stonith_op, data_set); data_set 880 pengine/graph.c add_maintenance_nodes(xmlNode *xml, const pe_working_set_t *data_set) data_set 887 pengine/graph.c for (gIter = data_set->nodes; gIter != NULL; data_set 917 pengine/graph.c add_maintenance_update(pe_working_set_t *data_set) data_set 921 pengine/graph.c if (add_maintenance_nodes(NULL, data_set)) { data_set 923 pengine/graph.c action = get_pseudo_op(CRM_OP_MAINTENANCE_NODES, data_set); data_set 942 pengine/graph.c const pe_working_set_t *data_set) data_set 944 pengine/graph.c CRM_CHECK(xml && action && action->node && data_set, return); data_set 960 pengine/graph.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); data_set 989 pengine/graph.c action2xml(action_t * action, gboolean as_input, pe_working_set_t *data_set) data_set 1161 pengine/graph.c get_rsc_attributes(p, action->rsc, action->node, data_set); data_set 1170 pengine/graph.c action->node, data_set); data_set 1276 pengine/graph.c add_downed_nodes(action_xml, action, data_set); data_set 1280 pengine/graph.c add_maintenance_nodes(action_xml, data_set); data_set 1697 pengine/graph.c graph_element_from_action(action_t * action, pe_working_set_t * data_set) data_set 1714 pengine/graph.c syn = create_xml_node(data_set->graph, "synapse"); data_set 1718 pengine/graph.c crm_xml_add_int(syn, XML_ATTR_ID, data_set->num_synapse); data_set 1719 pengine/graph.c data_set->num_synapse++; data_set 1731 pengine/graph.c xml_action = action2xml(action, FALSE, data_set); data_set 1749 pengine/graph.c xml_action = action2xml(wrapper->action, TRUE, data_set); data_set 31 pengine/group.c group_color(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 73 pengine/group.c node = child_rsc->cmds->allocate(child_rsc, prefer, data_set); data_set 92 pengine/group.c group_create_actions(resource_t * rsc, pe_working_set_t * data_set) data_set 103 pengine/group.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 111 pengine/group.c RSC_STARTED, NULL, TRUE /* !group_data->child_starting */ , TRUE, data_set); data_set 118 pengine/group.c RSC_STOPPED, NULL, TRUE /* !group_data->child_stopping */ , TRUE, data_set); data_set 123 pengine/group.c op = custom_action(rsc, demote_key(rsc), RSC_DEMOTE, NULL, TRUE, TRUE, data_set); data_set 126 pengine/group.c op = custom_action(rsc, demoted_key(rsc), RSC_DEMOTED, NULL, TRUE, TRUE, data_set); data_set 130 pengine/group.c op = custom_action(rsc, promote_key(rsc), RSC_PROMOTE, NULL, TRUE, TRUE, data_set); data_set 133 pengine/group.c op = custom_action(rsc, promoted_key(rsc), RSC_PROMOTED, NULL, TRUE, TRUE, data_set); data_set 175 pengine/group.c group_internal_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 185 pengine/group.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 186 pengine/group.c new_rsc_order(rsc, RSC_START, rsc, RSC_STARTED, pe_order_runnable_left, data_set); data_set 187 pengine/group.c new_rsc_order(rsc, RSC_STOP, rsc, RSC_STOPPED, pe_order_runnable_left, data_set); data_set 197 pengine/group.c child_rsc->cmds->internal_constraints(child_rsc, data_set); data_set 207 pengine/group.c child_rsc, last_rsc, NULL, NULL, data_set); data_set 212 pengine/group.c stop | pe_order_implies_first_printed, data_set); data_set 214 pengine/group.c new_rsc_order(child_rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, stopped, data_set); data_set 216 pengine/group.c new_rsc_order(child_rsc, RSC_PROMOTE, rsc, RSC_PROMOTED, started, data_set); data_set 219 pengine/group.c pe_order_implies_first_printed, data_set); data_set 226 pengine/group.c new_rsc_order(child_rsc, RSC_STOP, rsc, RSC_STOPPED, stopped, data_set); data_set 228 pengine/group.c new_rsc_order(child_rsc, RSC_START, rsc, RSC_STARTED, started, data_set); data_set 234 pengine/group.c start | pe_order_implies_first_printed, data_set); data_set 244 pengine/group.c new_rsc_order(last_rsc, RSC_PROMOTE, child_rsc, RSC_PROMOTE, start, data_set); data_set 246 pengine/group.c data_set); data_set 260 pengine/group.c new_rsc_order(rsc, RSC_PROMOTE, child_rsc, RSC_PROMOTE, flags, data_set); data_set 285 pengine/group.c new_rsc_order(last_rsc, RSC_STOP, rsc, RSC_STOPPED, stop_stopped_flags, data_set); data_set 288 pengine/group.c new_rsc_order(rsc, RSC_DEMOTE, last_rsc, RSC_DEMOTE, stop_stop_flags, data_set); data_set 289 pengine/group.c new_rsc_order(last_rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, stop_stopped_flags, data_set); data_set 466 pengine/group.c group_expand(resource_t * rsc, pe_working_set_t * data_set) data_set 473 pengine/group.c native_expand(rsc, data_set); data_set 478 pengine/group.c child_rsc->cmds->expand(child_rsc, data_set); data_set 29 pengine/master.c extern gint sort_clone_instance(gconstpointer a, gconstpointer b, gpointer data_set); data_set 34 pengine/master.c pe_working_set_t * data_set) data_set 40 pengine/master.c new_rsc_order(last, RSC_PROMOTE, rsc, RSC_PROMOTED, type, data_set); data_set 46 pengine/master.c new_rsc_order(child, RSC_PROMOTE, rsc, RSC_PROMOTED, type, data_set); data_set 49 pengine/master.c new_rsc_order(rsc, RSC_PROMOTE, child, RSC_PROMOTE, type, data_set); data_set 60 pengine/master.c new_rsc_order(last, RSC_PROMOTE, child, RSC_PROMOTE, type, data_set); data_set 70 pengine/master.c pe_working_set_t * data_set) data_set 76 pengine/master.c new_rsc_order(rsc, RSC_DEMOTE, last, RSC_DEMOTE, pe_order_optional, data_set); data_set 82 pengine/master.c new_rsc_order(child, RSC_DEMOTE, rsc, RSC_DEMOTED, pe_order_implies_then_printed, data_set); data_set 85 pengine/master.c new_rsc_order(rsc, RSC_DEMOTE, child, RSC_DEMOTE, pe_order_implies_first_printed, data_set); data_set 91 pengine/master.c new_rsc_order(child, RSC_DEMOTE, last, RSC_DEMOTE, type, data_set); data_set 96 pengine/master.c new_rsc_order(child, RSC_DEMOTE, rsc, RSC_DEMOTED, type, data_set); data_set 232 pengine/master.c sort_master_instance(gconstpointer a, gconstpointer b, gpointer data_set) data_set 262 pengine/master.c return sort_clone_instance(a, b, data_set); data_set 273 pengine/master.c master_promotion_order(resource_t * rsc, pe_working_set_t * data_set) data_set 365 pengine/master.c resource_location(rsc, NULL, -INFINITY, "__stateful_without_ticket__", data_set); data_set 393 pengine/master.c rsc->children = g_list_sort_with_data(rsc->children, sort_master_instance, data_set); data_set 651 pengine/master.c master_color(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 679 pengine/master.c clone_color(rsc, prefer, data_set); data_set 759 pengine/master.c master_promotion_order(rsc, data_set); data_set 769 pengine/master.c if (is_set(data_set->flags, pe_flag_sanitized)) { data_set 798 pengine/master.c && is_set(data_set->flags, pe_flag_have_quorum) == FALSE data_set 799 pengine/master.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 824 pengine/master.c master_create_actions(resource_t * rsc, pe_working_set_t * data_set) data_set 841 pengine/master.c clone_create_actions(rsc, data_set); data_set 849 pengine/master.c child_rsc->cmds->create_actions(child_rsc, data_set); data_set 859 pengine/master.c action = create_pseudo_resource_op(rsc, RSC_PROMOTE, !any_promoting, TRUE, data_set); data_set 860 pengine/master.c action_complete = create_pseudo_resource_op(rsc, RSC_PROMOTED, !any_promoting, TRUE, data_set); data_set 864 pengine/master.c rsc, NULL, last_promote_rsc, data_set); data_set 868 pengine/master.c create_notification_boundaries(rsc, RSC_PROMOTE, action, action_complete, data_set); data_set 872 pengine/master.c action = create_pseudo_resource_op(rsc, RSC_DEMOTE, !any_demoting, TRUE, data_set); data_set 873 pengine/master.c action_complete = create_pseudo_resource_op(rsc, RSC_DEMOTED, !any_demoting, TRUE, data_set); data_set 876 pengine/master.c child_demoting_constraints(clone_data, pe_order_optional, rsc, NULL, last_demote_rsc, data_set); data_set 880 pengine/master.c create_notification_boundaries(rsc, RSC_DEMOTE, action, action_complete, data_set); data_set 910 pengine/master.c master_promotion_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 913 pengine/master.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_START, pe_order_optional, data_set); data_set 916 pengine/master.c new_rsc_order(rsc, RSC_STOPPED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 919 pengine/master.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_START, pe_order_optional, data_set); data_set 922 pengine/master.c new_rsc_order(rsc, RSC_STARTED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 925 pengine/master.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_STOP, pe_order_optional, data_set); data_set 928 pengine/master.c new_rsc_order(rsc, RSC_DEMOTE, rsc, RSC_DEMOTED, pe_order_optional, data_set); data_set 931 pengine/master.c new_rsc_order(rsc, RSC_DEMOTED, rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 936 pengine/master.c master_internal_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 944 pengine/master.c clone_internal_constraints(rsc, data_set); data_set 945 pengine/master.c master_promotion_constraints(rsc, data_set); data_set 951 pengine/master.c new_rsc_order(child_rsc, RSC_DEMOTE, child_rsc, RSC_PROMOTE, pe_order_optional, data_set); data_set 954 pengine/master.c rsc, child_rsc, last_rsc, data_set); data_set 957 pengine/master.c rsc, child_rsc, last_rsc, data_set); data_set 42 pengine/native.c void Recurring(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set); data_set 44 pengine/native.c xmlNode * operation, pe_working_set_t * data_set); data_set 46 pengine/native.c pe_working_set_t * data_set); data_set 48 pengine/native.c xmlNode * operation, pe_working_set_t * data_set); data_set 50 pengine/native.c void ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set); data_set 51 pengine/native.c gboolean DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set); data_set 52 pengine/native.c gboolean StopRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 53 pengine/native.c gboolean StartRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 54 pengine/native.c gboolean DemoteRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 56 pengine/native.c pe_working_set_t * data_set); data_set 57 pengine/native.c gboolean RoleError(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 58 pengine/native.c gboolean NullOp(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set); data_set 83 pengine/native.c native_choose_node(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 92 pengine/native.c process_utilization(rsc, &prefer, data_set); data_set 433 pengine/native.c native_color(resource_t * rsc, node_t * prefer, pe_working_set_t * data_set) data_set 442 pengine/native.c rsc->parent->cmds->allocate(rsc->parent, prefer, data_set); data_set 471 pengine/native.c rsc_rh->cmds->allocate(rsc_rh, NULL, data_set); data_set 500 pengine/native.c resource_location(rsc, NULL, -INFINITY, XML_RSC_ATTR_TARGET_ROLE, data_set); data_set 503 pengine/native.c && is_set(data_set->flags, pe_flag_have_quorum) == FALSE data_set 504 pengine/native.c && data_set->no_quorum_policy == no_quorum_freeze) { data_set 512 pengine/native.c if (is_set(data_set->flags, pe_flag_stonith_enabled) data_set 513 pengine/native.c && is_set(data_set->flags, pe_flag_have_stonith_resource) == FALSE) { data_set 538 pengine/native.c } else if (is_set(data_set->flags, pe_flag_stop_everything)) { data_set 543 pengine/native.c && native_choose_node(rsc, prefer, data_set)) { data_set 563 pengine/native.c node_t *remote_node = pe_find_node(data_set->nodes, rsc->id); data_set 630 pengine/native.c xmlNode * operation, pe_working_set_t * data_set) data_set 728 pengine/native.c mon = custom_action(rsc, local_key, RSC_CANCEL, node, FALSE, TRUE, data_set); data_set 759 pengine/native.c pe_order_runnable_left, data_set); data_set 773 pengine/native.c mon = custom_action(rsc, key, name, node, is_optional, TRUE, data_set); data_set 804 pengine/native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 808 pengine/native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 813 pengine/native.c pe_order_optional | pe_order_runnable_left, data_set); data_set 818 pengine/native.c pe_order_optional | pe_order_runnable_left, data_set); data_set 824 pengine/native.c Recurring(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set) data_set 833 pengine/native.c RecurringOp(rsc, start, node, operation, data_set); data_set 841 pengine/native.c xmlNode * operation, pe_working_set_t * data_set) data_set 909 pengine/native.c cancel_op = custom_action(rsc, local_key, RSC_CANCEL, node, FALSE, TRUE, data_set); data_set 924 pengine/native.c pe_order_runnable_left, data_set); data_set 932 pengine/native.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 965 pengine/native.c stopped_mon = custom_action(rsc, strdup(key), name, stop_node, is_optional, TRUE, data_set); data_set 1010 pengine/native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 1048 pengine/native.c Recurring_Stopped(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set) data_set 1057 pengine/native.c RecurringOp_Stopped(rsc, start, node, operation, data_set); data_set 1064 pengine/native.c handle_migration_actions(resource_t * rsc, node_t *current, node_t *chosen, pe_working_set_t * data_set) data_set 1078 pengine/native.c migrate_to = custom_action(rsc, generate_op_key(rsc->id, RSC_MIGRATE, 0), RSC_MIGRATE, current, TRUE, TRUE, data_set); data_set 1081 pengine/native.c migrate_from = custom_action(rsc, generate_op_key(rsc->id, RSC_MIGRATED, 0), RSC_MIGRATED, chosen, TRUE, TRUE, data_set); data_set 1096 pengine/native.c rsc, generate_op_key(rsc->id, RSC_MIGRATED, 0), NULL, pe_order_optional, data_set); data_set 1104 pengine/native.c rsc, generate_op_key(rsc->id, RSC_MIGRATE, 0), NULL, pe_order_optional, data_set); data_set 1106 pengine/native.c rsc, generate_op_key(rsc->id, RSC_MIGRATED, 0), NULL, pe_order_optional | pe_order_implies_first_migratable, data_set); data_set 1110 pengine/native.c rsc, generate_op_key(rsc->id, RSC_STOP, 0), NULL, pe_order_optional | pe_order_implies_first_migratable, data_set); data_set 1112 pengine/native.c rsc, generate_op_key(rsc->id, RSC_START, 0), NULL, pe_order_optional | pe_order_implies_first_migratable | pe_order_pseudo_left, data_set); data_set 1141 pengine/native.c native_create_actions(resource_t * rsc, pe_working_set_t * data_set) data_set 1190 pengine/native.c if (is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 1191 pengine/native.c DeleteRsc(rsc, current, FALSE, data_set); data_set 1276 pengine/native.c if (rsc_action_matrix[role][next_role] (rsc, current, !need_stop, data_set) == FALSE) { data_set 1287 pengine/native.c if (rsc_action_matrix[role][next_role] (rsc, chosen, !need_stop, data_set) == FALSE) { data_set 1298 pengine/native.c if (rsc_action_matrix[role][next_role] (rsc, chosen, FALSE, data_set) == FALSE) { data_set 1310 pengine/native.c Recurring(rsc, start, chosen, data_set); data_set 1311 pengine/native.c Recurring_Stopped(rsc, start, chosen, data_set); data_set 1314 pengine/native.c Recurring_Stopped(rsc, NULL, NULL, data_set); data_set 1335 pengine/native.c handle_migration_actions(rsc, current, chosen, data_set); data_set 1353 pengine/native.c native_internal_constraints(resource_t * rsc, pe_working_set_t * data_set) data_set 1362 pengine/native.c rsc, generate_op_key(rsc->id, RSC_START, 0), NULL, type, data_set); data_set 1367 pengine/native.c pe_order_implies_first_master, data_set); data_set 1371 pengine/native.c pe_order_runnable_left, data_set); data_set 1375 pengine/native.c && is_set(data_set->flags, pe_flag_enable_unfencing) data_set 1383 pengine/native.c action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, data_set); data_set 1405 pengine/native.c pe_order_optional|pe_order_same_node, data_set); data_set 1410 pengine/native.c data_set); data_set 1420 pengine/native.c action_t *all_stopped = get_pseudo_op(ALL_STOPPED, data_set); data_set 1424 pengine/native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 1428 pengine/native.c && safe_str_neq(data_set->placement_strategy, "default")) { data_set 1434 pengine/native.c rsc->id, data_set->placement_strategy); data_set 1440 pengine/native.c action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1448 pengine/native.c NULL, load_stopped_task, load_stopped, pe_order_load, data_set); data_set 1454 pengine/native.c action_t *load_stopped = get_pseudo_op(load_stopped_task, data_set); data_set 1462 pengine/native.c rsc, start_key(rsc), NULL, pe_order_load, data_set); data_set 1466 pengine/native.c pe_order_load, data_set); data_set 1485 pengine/native.c remote_rsc = rsc_contains_remote_node(data_set, rsc->container); data_set 1513 pengine/native.c pe_order_implies_then | pe_order_runnable_left, data_set); data_set 1517 pengine/native.c pe_order_implies_first, data_set); data_set 1525 pengine/native.c rsc->container, NULL, NULL, data_set); data_set 1788 pengine/native.c rsc_ticket_constraint(resource_t * rsc_lh, rsc_ticket_t * rsc_ticket, pe_working_set_t * data_set) data_set 1812 pengine/native.c rsc_ticket_constraint(child_rsc, rsc_ticket, data_set); data_set 1826 pengine/native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 1832 pengine/native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 1841 pengine/native.c resource_location(rsc_lh, NULL, -INFINITY, "__loss_of_ticket__", data_set); data_set 1846 pengine/native.c pe_fence_node(data_set, node, "deadman ticket was lost"); data_set 1864 pengine/native.c resource_location(rsc_lh, NULL, -INFINITY, "__no_ticket__", data_set); data_set 1870 pengine/native.c resource_location(rsc_lh, NULL, -INFINITY, "__ticket_standby__", data_set); data_set 2138 pengine/native.c native_expand(resource_t * rsc, pe_working_set_t * data_set) data_set 2149 pengine/native.c graph_element_from_action(action, data_set); data_set 2155 pengine/native.c child_rsc->cmds->expand(child_rsc, data_set); data_set 2286 pengine/native.c LogActions(resource_t * rsc, pe_working_set_t * data_set, gboolean terminal) data_set 2301 pengine/native.c container_LogActions(rsc, data_set, terminal); data_set 2311 pengine/native.c LogActions(child_rsc, data_set, terminal); data_set 2488 pengine/native.c StopRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2521 pengine/native.c if (is_set(data_set->flags, pe_flag_remove_after_stop)) { data_set 2522 pengine/native.c DeleteRsc(rsc, current, optional, data_set); data_set 2526 pengine/native.c action_t *unfence = pe_fence_op(current, "on", TRUE, NULL, data_set); data_set 2540 pengine/native.c StartRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2549 pengine/native.c action_t *unfence = pe_fence_op(next, "on", TRUE, NULL, data_set); data_set 2556 pengine/native.c trigger_unfencing(NULL, next, reason, NULL, data_set); data_set 2570 pengine/native.c PromoteRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2616 pengine/native.c DemoteRsc(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2634 pengine/native.c RoleError(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2643 pengine/native.c NullOp(resource_t * rsc, node_t * next, gboolean optional, pe_working_set_t * data_set) data_set 2651 pengine/native.c DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set) data_set 2672 pengine/native.c optional ? pe_order_implies_then : pe_order_optional, data_set); data_set 2675 pengine/native.c optional ? pe_order_implies_then : pe_order_optional, data_set); data_set 2753 pengine/native.c pe_working_set_t *data_set) data_set 2789 pengine/native.c peer = pe_find_resource(data_set->resources, clone_id); data_set 2799 pengine/native.c gboolean force, pe_working_set_t * data_set) data_set 2817 pengine/native.c if (force == FALSE && is_not_set(data_set->flags, pe_flag_startup_probes)) { data_set 2830 pengine/native.c } else if (is_container_remote_node(node) && rsc_contains_remote_node(data_set, rsc)) { data_set 2850 pengine/native.c any_created = child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set) data_set 2874 pengine/native.c running = probe_anon_group_member(rsc, node, data_set); data_set 2944 pengine/native.c pe_order_optional, data_set); data_set 2966 pengine/native.c pe_order_optional, data_set); data_set 2977 pengine/native.c probe = custom_action(rsc, key, RSC_STATUS, node, FALSE, TRUE, data_set); data_set 2994 pengine/native.c action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, data_set); data_set 3013 pengine/native.c if(is_set(rsc->flags, pe_rsc_fence_device) && is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 3032 pengine/native.c flags, data_set); data_set 3037 pengine/native.c pe_order_optional, data_set); data_set 3039 pengine/native.c if(is_set(rsc->flags, pe_rsc_fence_device) && is_set(data_set->flags, pe_flag_enable_unfencing)) { data_set 3054 pengine/native.c native_start_constraints(resource_t * rsc, action_t * stonith_op, pe_working_set_t * data_set) data_set 3058 pengine/native.c action_t *all_stopped = get_pseudo_op(ALL_STOPPED, data_set); data_set 3059 pengine/native.c action_t *stonith_done = get_pseudo_op(STONITH_DONE, data_set); data_set 3099 pengine/native.c native_stop_constraints(resource_t * rsc, action_t * stonith_op, pe_working_set_t * data_set) data_set 3175 pengine/native.c create_secondary_notification(action, rsc, stonith_op, data_set); data_set 3248 pengine/native.c rsc_stonith_ordering(resource_t * rsc, action_t * stonith_op, pe_working_set_t * data_set) data_set 3256 pengine/native.c rsc_stonith_ordering(child_rsc, stonith_op, data_set); data_set 3263 pengine/native.c native_start_constraints(rsc, stonith_op, data_set); data_set 3264 pengine/native.c native_stop_constraints(rsc, stonith_op, data_set); data_set 3276 pengine/native.c ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set) data_set 3285 pengine/native.c ReloadRsc(child_rsc, node, data_set); data_set 3311 pengine/native.c rsc, reload_key(rsc), CRMD_ACTION_RELOAD, node, FALSE, TRUE, data_set); data_set 3316 pengine/native.c data_set); data_set 3319 pengine/native.c data_set); data_set 238 pengine/notif.c notify_data_t * n_data, pe_working_set_t * data_set) data_set 268 pengine/notif.c is_set(op->flags, pe_action_optional), TRUE, data_set); data_set 282 pengine/notif.c pe_post_notify(resource_t * rsc, node_t * node, notify_data_t * n_data, pe_working_set_t * data_set) data_set 292 pengine/notif.c notify = pe_notify(rsc, node, n_data->post, n_data->post_done, n_data, data_set); data_set 320 pengine/notif.c action_t * end, pe_working_set_t * data_set) data_set 347 pengine/notif.c TRUE, data_set); data_set 362 pengine/notif.c TRUE, data_set); data_set 382 pengine/notif.c data_set); data_set 402 pengine/notif.c TRUE, data_set); data_set 427 pengine/notif.c action_t *all_stopped = get_pseudo_op(ALL_STOPPED, data_set); data_set 530 pengine/notif.c expand_notification_data(resource_t *rsc, notify_data_t * n_data, pe_working_set_t * data_set) data_set 619 pengine/notif.c expand_node_list(data_set->nodes, &node_list, &metal_list); data_set 623 pengine/notif.c expand_node_list(data_set->nodes, &node_list, NULL); data_set 640 pengine/notif.c create_notifications(resource_t * rsc, notify_data_t * n_data, pe_working_set_t * data_set) data_set 652 pengine/notif.c create_notifications(child, n_data, data_set); data_set 702 pengine/notif.c pe_notify(rsc, current_node, n_data->pre, n_data->pre_done, n_data, data_set); data_set 705 pengine/notif.c pe_post_notify(rsc, current_node, n_data, data_set); data_set 719 pengine/notif.c pe_notify(rsc, rsc->allocated_to, n_data->pre, n_data->pre_done, n_data, data_set); data_set 721 pengine/notif.c pe_post_notify(rsc, rsc->allocated_to, n_data, data_set); data_set 748 pengine/notif.c pe_working_set_t *data_set) data_set 754 pengine/notif.c data_set); data_set 760 pengine/notif.c create_notifications(uber_parent(rsc), n_data, data_set); data_set 26 pengine/notif.h pe_working_set_t *data_set); data_set 32 pengine/notif.h pe_working_set_t *data_set); data_set 35 pengine/notif.h pe_working_set_t *data_set); data_set 41 pengine/notif.h pe_working_set_t *data_set); data_set 37 pengine/pengine.c xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 94 pengine/pengine.c pe_working_set_t data_set; data_set 106 pengine/pengine.c set_working_set_defaults(&data_set); data_set 111 pengine/pengine.c data_set.graph = create_xml_node(NULL, XML_TAG_GRAPH); data_set 112 pengine/pengine.c crm_xml_add_int(data_set.graph, "transition_id", 0); data_set 113 pengine/pengine.c crm_xml_add_int(data_set.graph, "cluster-delay", 0); data_set 128 pengine/pengine.c do_calculations(&data_set, converted, NULL); data_set 133 pengine/pengine.c value = pe_pref(data_set.config_hash, series[series_id].param); data_set 150 pengine/pengine.c data_set.input = NULL; data_set 151 pengine/pengine.c reply = create_reply(msg, data_set.graph); data_set 179 pengine/pengine.c write_xml_fd(data_set.graph, graph_file, graph_file_fd, FALSE); data_set 187 pengine/pengine.c cleanup_alloc_calculations(&data_set); data_set 223 pengine/pengine.c do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now) data_set 230 pengine/pengine.c CRM_ASSERT(xml_input || is_set(data_set->flags, pe_flag_have_status)); data_set 232 pengine/pengine.c if (is_set(data_set->flags, pe_flag_have_status) == FALSE) { data_set 233 pengine/pengine.c set_working_set_defaults(data_set); data_set 234 pengine/pengine.c data_set->input = xml_input; data_set 235 pengine/pengine.c data_set->now = now; data_set 241 pengine/pengine.c if (data_set->now == NULL) { data_set 242 pengine/pengine.c data_set->now = crm_time_new(NULL); data_set 246 pengine/pengine.c stage0(data_set); data_set 248 pengine/pengine.c if(is_not_set(data_set->flags, pe_flag_quick_location)) { data_set 249 pengine/pengine.c gIter = data_set->resources; data_set 261 pengine/pengine.c stage2(data_set); data_set 263 pengine/pengine.c if(is_set(data_set->flags, pe_flag_quick_location)){ data_set 268 pengine/pengine.c stage3(data_set); data_set 271 pengine/pengine.c stage4(data_set); data_set 274 pengine/pengine.c stage5(data_set); data_set 277 pengine/pengine.c stage6(data_set); data_set 280 pengine/pengine.c stage7(data_set); data_set 283 pengine/pengine.c stage8(data_set); data_set 288 pengine/pengine.c gIter = data_set->actions; data_set 300 pengine/pengine.c return data_set->graph; data_set 106 pengine/pengine.h extern gboolean stage0(pe_working_set_t * data_set); data_set 107 pengine/pengine.h extern gboolean probe_resources(pe_working_set_t * data_set); data_set 108 pengine/pengine.h extern gboolean stage2(pe_working_set_t * data_set); data_set 109 pengine/pengine.h extern gboolean stage3(pe_working_set_t * data_set); data_set 110 pengine/pengine.h extern gboolean stage4(pe_working_set_t * data_set); data_set 111 pengine/pengine.h extern gboolean stage5(pe_working_set_t * data_set); data_set 112 pengine/pengine.h extern gboolean stage6(pe_working_set_t * data_set); data_set 113 pengine/pengine.h extern gboolean stage7(pe_working_set_t * data_set); data_set 114 pengine/pengine.h extern gboolean stage8(pe_working_set_t * data_set); data_set 118 pengine/pengine.h extern gboolean unpack_constraints(xmlNode * xml_constraints, pe_working_set_t * data_set); data_set 123 pengine/pengine.h pe_working_set_t * data_set); data_set 126 pengine/pengine.h pe_working_set_t * data_set); data_set 130 pengine/pengine.h enum pe_ordering type, pe_working_set_t * data_set); data_set 134 pengine/pengine.h enum pe_ordering type, pe_working_set_t * data_set); data_set 137 pengine/pengine.h new_rsc_order(rsc1, CRMD_ACTION_START, rsc2, CRMD_ACTION_START, type, data_set) data_set 139 pengine/pengine.h new_rsc_order(rsc1, CRMD_ACTION_STOP, rsc2, CRMD_ACTION_STOP, type, data_set) data_set 141 pengine/pengine.h extern void graph_element_from_action(action_t * action, pe_working_set_t * data_set); data_set 142 pengine/pengine.h extern void add_maintenance_update(pe_working_set_t *data_set); data_set 49 pengine/ptest.c extern xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 50 pengine/ptest.c extern void cleanup_calculations(pe_working_set_t * data_set); data_set 162 pengine/ptest.c pe_working_set_t data_set; data_set 343 pengine/ptest.c set_working_set_defaults(&data_set); data_set 352 pengine/ptest.c do_calculations(&data_set, cib_object, a_date); data_set 355 pengine/ptest.c msg_buffer = dump_xml_formatted(data_set.graph); data_set 386 pengine/ptest.c for (lpc = data_set.actions; lpc != NULL; lpc = lpc->next) { data_set 430 pengine/ptest.c for (lpc = data_set.actions; lpc != NULL; lpc = lpc->next) { data_set 479 pengine/ptest.c transition = unpack_graph(data_set.graph, "ptest"); data_set 496 pengine/ptest.c cleanup_alloc_calculations(&data_set); data_set 340 pengine/utilization.c process_utilization(resource_t * rsc, node_t ** prefer, pe_working_set_t * data_set) data_set 344 pengine/utilization.c if (safe_str_neq(data_set->placement_strategy, "default")) { data_set 387 pengine/utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 415 pengine/utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); data_set 65 pengine/utils.c node_t * foo_node, pe_working_set_t * data_set) data_set 103 pengine/utils.c data_set->placement_constraints = g_list_prepend(data_set->placement_constraints, new_con); data_set 433 pengine/utils.c create_pseudo_resource_op(resource_t * rsc, const char *task, bool optional, bool runnable, pe_working_set_t *data_set) data_set 435 pengine/utils.c pe_action_t *action = custom_action(rsc, generate_op_key(rsc->id, task, 0), task, NULL, optional, TRUE, data_set); data_set 28 pengine/utils.h pe_working_set_t * data_set); data_set 36 pengine/utils.h pe_working_set_t * data_set); data_set 40 pengine/utils.h pe_working_set_t * data_set); data_set 42 pengine/utils.h extern gint sort_node_weight(gconstpointer a, gconstpointer b, gpointer data_set); data_set 77 pengine/utils.h extern void process_utilization(resource_t * rsc, node_t ** prefer, pe_working_set_t * data_set); data_set 78 pengine/utils.h pe_action_t *create_pseudo_resource_op(resource_t * rsc, const char *task, bool optional, bool runnable, pe_working_set_t *data_set); data_set 52 tools/crm_mon.c extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 855 tools/crm_mon.c count_resources(pe_working_set_t * data_set, resource_t * rsc) data_set 861 tools/crm_mon.c gIter = data_set->resources; data_set 869 tools/crm_mon.c count += count_resources(data_set, gIter->data); data_set 884 tools/crm_mon.c print_simple_status(pe_working_set_t * data_set) data_set 891 tools/crm_mon.c if (data_set->dc_node == NULL) { data_set 895 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 910 tools/crm_mon.c int nresources = count_resources(data_set, NULL); data_set 1165 tools/crm_mon.c print_resources(FILE *stream, pe_working_set_t *data_set, int print_opts) data_set 1190 tools/crm_mon.c print_rscs_brief(data_set->resources, NULL, print_opts, stream, data_set 1195 tools/crm_mon.c for (rsc_iter = data_set->resources; rsc_iter != NULL; rsc_iter = rsc_iter->next) { data_set 1246 tools/crm_mon.c print_rsc_history_start(FILE *stream, pe_working_set_t *data_set, node_t *node, data_set 1252 tools/crm_mon.c NULL, data_set) data_set 1412 tools/crm_mon.c print_op_history(FILE *stream, pe_working_set_t *data_set, node_t *node, data_set 1510 tools/crm_mon.c print_rsc_history(FILE *stream, pe_working_set_t *data_set, node_t *node, data_set 1517 tools/crm_mon.c resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 1522 tools/crm_mon.c print_rsc_history_start(stream, data_set, node, rsc, rsc_id, FALSE); data_set 1556 tools/crm_mon.c print_rsc_history_start(stream, data_set, node, rsc, rsc_id, TRUE); data_set 1560 tools/crm_mon.c print_op_history(stream, data_set, node, xml_op, task, interval, rc); data_set 1582 tools/crm_mon.c print_node_history(FILE *stream, pe_working_set_t *data_set, data_set 1585 tools/crm_mon.c node_t *node = pe_find_node_id(data_set->nodes, ID(node_state)); data_set 1600 tools/crm_mon.c print_rsc_history(stream, data_set, node, rsc_entry, operations); data_set 1783 tools/crm_mon.c print_node_summary(FILE *stream, pe_working_set_t * data_set, gboolean operations) data_set 1786 tools/crm_mon.c xmlNode *cib_status = get_object_root(XML_CIB_TAG_STATUS, data_set->input); data_set 1820 tools/crm_mon.c print_node_history(stream, data_set, node_state, operations); data_set 1889 tools/crm_mon.c print_cluster_tickets(FILE *stream, pe_working_set_t * data_set) data_set 1912 tools/crm_mon.c g_hash_table_foreach(data_set->tickets, print_ticket, stream); data_set 2053 tools/crm_mon.c static void print_neg_locations(FILE *stream, pe_working_set_t *data_set) data_set 2078 tools/crm_mon.c for (gIter = data_set->placement_constraints; gIter != NULL; gIter = gIter->next) { data_set 2108 tools/crm_mon.c crm_mon_get_parameters(resource_t *rsc, pe_working_set_t * data_set) data_set 2110 tools/crm_mon.c get_rsc_attributes(rsc->parameters, rsc, NULL, data_set); data_set 2116 tools/crm_mon.c crm_mon_get_parameters(gIter->data, data_set); data_set 2129 tools/crm_mon.c print_node_attributes(FILE *stream, pe_working_set_t *data_set) data_set 2156 tools/crm_mon.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 2157 tools/crm_mon.c crm_mon_get_parameters(gIter->data, data_set); data_set 2161 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 2310 tools/crm_mon.c print_cluster_times(FILE *stream, pe_working_set_t *data_set) data_set 2312 tools/crm_mon.c const char *last_written = crm_element_value(data_set->input, XML_CIB_ATTR_WRITTEN); data_set 2313 tools/crm_mon.c const char *user = crm_element_value(data_set->input, XML_ATTR_UPDATE_USER); data_set 2314 tools/crm_mon.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); data_set 2315 tools/crm_mon.c const char *origin = crm_element_value(data_set->input, XML_ATTR_UPDATE_ORIG); data_set 2401 tools/crm_mon.c print_cluster_dc(FILE *stream, pe_working_set_t *data_set) data_set 2403 tools/crm_mon.c node_t *dc = data_set->dc_node; data_set 2405 tools/crm_mon.c data_set->input, LOG_DEBUG); data_set 2409 tools/crm_mon.c const char *quorum = crm_element_value(data_set->input, XML_ATTR_HAVE_QUORUM); data_set 2466 tools/crm_mon.c print_cluster_counts(FILE *stream, pe_working_set_t *data_set, const char *stack_s) data_set 2468 tools/crm_mon.c int nnodes = g_list_length(data_set->nodes); data_set 2469 tools/crm_mon.c int nresources = count_resources(data_set, NULL); data_set 2471 tools/crm_mon.c data_set->input, LOG_DEBUG); data_set 2488 tools/crm_mon.c if(data_set->disabled_resources || data_set->blocked_resources) { data_set 2490 tools/crm_mon.c if (data_set->disabled_resources) { data_set 2491 tools/crm_mon.c print_as("%d DISABLED", data_set->disabled_resources); data_set 2493 tools/crm_mon.c if (data_set->disabled_resources && data_set->blocked_resources) { data_set 2496 tools/crm_mon.c if (data_set->blocked_resources) { data_set 2498 tools/crm_mon.c data_set->blocked_resources); data_set 2517 tools/crm_mon.c if (data_set->disabled_resources || data_set->blocked_resources) { data_set 2519 tools/crm_mon.c if (data_set->disabled_resources) { data_set 2521 tools/crm_mon.c data_set->disabled_resources); data_set 2523 tools/crm_mon.c if (data_set->disabled_resources && data_set->blocked_resources) { data_set 2526 tools/crm_mon.c if (data_set->blocked_resources) { data_set 2529 tools/crm_mon.c data_set->blocked_resources); data_set 2539 tools/crm_mon.c g_list_length(data_set->nodes), quorum_votes); data_set 2542 tools/crm_mon.c count_resources(data_set, NULL), data_set 2543 tools/crm_mon.c data_set->disabled_resources, data_set->blocked_resources); data_set 2562 tools/crm_mon.c print_cluster_options(FILE *stream, pe_working_set_t *data_set) data_set 2567 tools/crm_mon.c if (is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 2578 tools/crm_mon.c is_set(data_set->flags, pe_flag_stonith_enabled)? "enabled" : "disabled"); data_set 2581 tools/crm_mon.c is_set(data_set->flags, pe_flag_symmetric_cluster)? "" : "a"); data_set 2584 tools/crm_mon.c switch (data_set->no_quorum_policy) { data_set 2601 tools/crm_mon.c if (is_set(data_set->flags, pe_flag_maintenance_mode)) { data_set 2615 tools/crm_mon.c is_set(data_set->flags, pe_flag_stonith_enabled)? data_set 2618 tools/crm_mon.c is_set(data_set->flags, pe_flag_symmetric_cluster)? data_set 2621 tools/crm_mon.c switch (data_set->no_quorum_policy) { data_set 2637 tools/crm_mon.c is_set(data_set->flags, pe_flag_maintenance_mode)? data_set 2656 tools/crm_mon.c get_cluster_stack(pe_working_set_t *data_set) data_set 2659 tools/crm_mon.c data_set->input, LOG_DEBUG); data_set 2671 tools/crm_mon.c print_cluster_summary(FILE *stream, pe_working_set_t *data_set) data_set 2673 tools/crm_mon.c const char *stack_s = get_cluster_stack(data_set); data_set 2685 tools/crm_mon.c if ((data_set->dc_node == NULL) || (show & mon_show_dc)) { data_set 2690 tools/crm_mon.c print_cluster_dc(stream, data_set); data_set 2698 tools/crm_mon.c print_cluster_times(stream, data_set); data_set 2701 tools/crm_mon.c if (is_set(data_set->flags, pe_flag_maintenance_mode) data_set 2702 tools/crm_mon.c || data_set->disabled_resources data_set 2703 tools/crm_mon.c || data_set->blocked_resources data_set 2709 tools/crm_mon.c print_cluster_counts(stream, data_set, stack_s); data_set 2716 tools/crm_mon.c print_cluster_options(stream, data_set); data_set 2856 tools/crm_mon.c print_failed_actions(FILE *stream, pe_working_set_t *data_set) data_set 2881 tools/crm_mon.c for (xml_op = __xml_first_child(data_set->failed); xml_op != NULL; data_set 2917 tools/crm_mon.c print_status(pe_working_set_t * data_set) data_set 2932 tools/crm_mon.c print_cluster_summary(stdout, data_set); data_set 2936 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 3052 tools/crm_mon.c print_resources(stdout, data_set, print_opts); data_set 3056 tools/crm_mon.c print_node_attributes(stdout, data_set); data_set 3063 tools/crm_mon.c print_node_summary(stdout, data_set, data_set 3068 tools/crm_mon.c if (xml_has_children(data_set->failed)) { data_set 3069 tools/crm_mon.c print_failed_actions(stdout, data_set); data_set 3074 tools/crm_mon.c print_cluster_tickets(stdout, data_set); data_set 3079 tools/crm_mon.c print_neg_locations(stdout, data_set); data_set 3096 tools/crm_mon.c print_xml_status(pe_working_set_t * data_set) data_set 3105 tools/crm_mon.c print_cluster_summary(stream, data_set); data_set 3109 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 3159 tools/crm_mon.c print_resources(stream, data_set, print_opts); data_set 3163 tools/crm_mon.c print_node_attributes(stream, data_set); data_set 3170 tools/crm_mon.c print_node_summary(stream, data_set, data_set 3175 tools/crm_mon.c if (xml_has_children(data_set->failed)) { data_set 3176 tools/crm_mon.c print_failed_actions(stream, data_set); data_set 3181 tools/crm_mon.c print_cluster_tickets(stream, data_set); data_set 3186 tools/crm_mon.c print_neg_locations(stream, data_set); data_set 3204 tools/crm_mon.c print_html_status(pe_working_set_t * data_set, const char *filename) data_set 3232 tools/crm_mon.c print_cluster_summary(stream, data_set); data_set 3238 tools/crm_mon.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 3283 tools/crm_mon.c print_resources(stream, data_set, print_opts); data_set 3287 tools/crm_mon.c print_node_attributes(stream, data_set); data_set 3294 tools/crm_mon.c print_node_summary(stream, data_set, data_set 3299 tools/crm_mon.c if (xml_has_children(data_set->failed)) { data_set 3300 tools/crm_mon.c print_failed_actions(stream, data_set); data_set 3305 tools/crm_mon.c print_cluster_tickets(stream, data_set); data_set 3310 tools/crm_mon.c print_neg_locations(stream, data_set); data_set 4129 tools/crm_mon.c pe_working_set_t data_set; data_set 4145 tools/crm_mon.c set_working_set_defaults(&data_set); data_set 4146 tools/crm_mon.c data_set.input = cib_copy; data_set 4147 tools/crm_mon.c cluster_status(&data_set); data_set 4153 tools/crm_mon.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set.input); data_set 4154 tools/crm_mon.c unpack_constraints(cib_constraints, &data_set); data_set 4160 tools/crm_mon.c if (print_html_status(&data_set, output_filename) != 0) { data_set 4167 tools/crm_mon.c print_xml_status(&data_set); data_set 4171 tools/crm_mon.c print_simple_status(&data_set); data_set 4179 tools/crm_mon.c print_status(&data_set); data_set 4186 tools/crm_mon.c cleanup_alloc_calculations(&data_set); data_set 436 tools/crm_resource.c pe_working_set_t data_set = { 0, }; data_set 803 tools/crm_resource.c data_set.input = NULL; /* make clean-up easier */ data_set 839 tools/crm_resource.c set_working_set_defaults(&data_set); data_set 840 tools/crm_resource.c rc = update_working_set_xml(&data_set, &cib_xml_copy); data_set 844 tools/crm_resource.c cluster_status(&data_set); data_set 849 tools/crm_resource.c rsc = pe_find_resource_with_flags(data_set.resources, rsc_id, data_set 879 tools/crm_resource.c cli_resource_print_list(&data_set, FALSE); data_set 886 tools/crm_resource.c for (lpc = data_set.resources; lpc != NULL; lpc = lpc->next) { data_set 907 tools/crm_resource.c timeout_ms, cib_conn, &data_set); data_set 914 tools/crm_resource.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set.input); data_set 916 tools/crm_resource.c unpack_constraints(cib_constraints, &data_set); data_set 921 tools/crm_resource.c for (lpc = data_set.resources; lpc != NULL; lpc = lpc->next) { data_set 932 tools/crm_resource.c for (lpc = data_set.resources; lpc != NULL; lpc = lpc->next) { data_set 944 tools/crm_resource.c for (lpc = data_set.resources; lpc != NULL; lpc = lpc->next) { data_set 948 tools/crm_resource.c cli_resource_print_cts_constraints(&data_set); data_set 951 tools/crm_resource.c rc = cli_resource_fail(crmd_channel, host_uname, rsc_id, &data_set); data_set 957 tools/crm_resource.c rc = cli_resource_print_operations(rsc_id, host_uname, TRUE, &data_set); data_set 960 tools/crm_resource.c rc = cli_resource_print_operations(rsc_id, host_uname, FALSE, &data_set); data_set 963 tools/crm_resource.c rc = cli_resource_search(rsc, rsc_id, &data_set); data_set 969 tools/crm_resource.c rc = cli_resource_print(rsc, &data_set, TRUE); data_set 972 tools/crm_resource.c rc = cli_resource_print(rsc, &data_set, FALSE); data_set 978 tools/crm_resource.c dest = pe_find_node(data_set.nodes, host_uname); data_set 985 tools/crm_resource.c cli_resource_why(cib_conn, data_set.resources, rsc, dest); data_set 992 tools/crm_resource.c dest = pe_find_node(data_set.nodes, host_uname); data_set 1001 tools/crm_resource.c rc = cli_resource_clear(rsc_id, NULL, data_set.nodes, cib_conn); data_set 1005 tools/crm_resource.c rc = cli_resource_move(rsc, rsc_id, host_uname, cib_conn, &data_set); data_set 1008 tools/crm_resource.c node_t *dest = pe_find_node(data_set.nodes, host_uname); data_set 1054 tools/crm_resource.c rc = cli_resource_print_property(rsc, prop_name, &data_set); data_set 1080 tools/crm_resource.c rc = cli_resource_print_attribute(rsc, prop_name, &data_set); data_set 1092 tools/crm_resource.c cib_conn, &data_set); data_set 1097 tools/crm_resource.c prop_name, cib_conn, &data_set); data_set 1101 tools/crm_resource.c for (xmlNode *xml_op = __xml_first_child(data_set.failed); xml_op != NULL; data_set 1124 tools/crm_resource.c task_interval, &data_set); data_set 1145 tools/crm_resource.c interval, &data_set); data_set 1164 tools/crm_resource.c node_t *node = pe_find_node(data_set.nodes, host_uname); data_set 1209 tools/crm_resource.c for (rIter = data_set.resources; rIter; rIter = rIter->next) { data_set 1212 tools/crm_resource.c &data_set); data_set 1241 tools/crm_resource.c if (data_set.input != NULL) { data_set 1242 tools/crm_resource.c cleanup_alloc_calculations(&data_set); data_set 58 tools/crm_resource.h void cli_resource_print_cts_constraints(pe_working_set_t * data_set); data_set 62 tools/crm_resource.h int cli_resource_print(resource_t *rsc, pe_working_set_t *data_set, data_set 64 tools/crm_resource.h int cli_resource_print_list(pe_working_set_t * data_set, bool raw); data_set 66 tools/crm_resource.h pe_working_set_t *data_set); data_set 68 tools/crm_resource.h pe_working_set_t *data_set); data_set 69 tools/crm_resource.h int cli_resource_print_operations(const char *rsc_id, const char *host_uname, bool active, pe_working_set_t * data_set); data_set 73 tools/crm_resource.h int cli_resource_fail(crm_ipc_t * crmd_channel, const char *host_uname, const char *rsc_id, pe_working_set_t * data_set); data_set 75 tools/crm_resource.h pe_working_set_t *data_set); data_set 78 tools/crm_resource.h const char *interval, pe_working_set_t *data_set); data_set 82 tools/crm_resource.h pe_working_set_t *data_set); data_set 86 tools/crm_resource.h pe_working_set_t *data_set); data_set 92 tools/crm_resource.h pe_working_set_t *data_set); data_set 96 tools/crm_resource.h pe_working_set_t *data_set); data_set 98 tools/crm_resource.h int update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml); data_set 103 tools/crm_resource.h extern xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 104 tools/crm_resource.h extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 26 tools/crm_resource_print.c cli_resource_print_cts_constraints(pe_working_set_t * data_set) data_set 30 tools/crm_resource_print.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 42 tools/crm_resource_print.c if (test_ruleset(lifetime, NULL, data_set->now) == FALSE) { data_set 131 tools/crm_resource_print.c cli_resource_print_list(pe_working_set_t * data_set, bool raw) data_set 142 tools/crm_resource_print.c for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) { data_set 163 tools/crm_resource_print.c pe_working_set_t * data_set) data_set 167 tools/crm_resource_print.c GListPtr ops = find_operations(rsc_id, host_uname, active, data_set); data_set 183 tools/crm_resource_print.c rsc = pe_find_resource(data_set->resources, op_rsc); data_set 297 tools/crm_resource_print.c cli_resource_print(resource_t *rsc, pe_working_set_t *data_set, bool expanded) data_set 315 tools/crm_resource_print.c cli_resource_print_attribute(resource_t *rsc, const char *attr, pe_working_set_t * data_set) data_set 333 tools/crm_resource_print.c get_rsc_attributes(params, rsc, current, data_set); data_set 337 tools/crm_resource_print.c get_meta_attributes(params, rsc, current, data_set); data_set 340 tools/crm_resource_print.c unpack_instance_attributes(data_set->input, rsc->xml, data_set 342 tools/crm_resource_print.c params, NULL, FALSE, data_set->now); data_set 361 tools/crm_resource_print.c cli_resource_print_property(resource_t *rsc, const char *attr, pe_working_set_t * data_set) data_set 29 tools/crm_resource_runtime.c do_find_resource(const char *rsc, resource_t * the_rsc, pe_working_set_t * data_set) data_set 60 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 67 tools/crm_resource_runtime.c found += do_find_resource(requested_name, iter->data, data_set); data_set 78 tools/crm_resource_runtime.c found += do_find_resource(requested_name, iter->data, data_set); data_set 82 tools/crm_resource_runtime.c found += do_find_resource(requested_name, rsc, data_set); data_set 232 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 354 tools/crm_resource_runtime.c xmlNode *cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set->input); data_set 357 tools/crm_resource_runtime.c unpack_constraints(cib_constraints, data_set); data_set 359 tools/crm_resource_runtime.c for (lpc = data_set->resources; lpc != NULL; lpc = lpc->next) { data_set 378 tools/crm_resource_runtime.c cib, data_set); data_set 390 tools/crm_resource_runtime.c pe_working_set_t *data_set) data_set 448 tools/crm_resource_runtime.c bool only_failed, pe_working_set_t * data_set) data_set 459 tools/crm_resource_runtime.c resource_t *rsc = pe_find_resource(data_set->resources, rsc_id); data_set 473 tools/crm_resource_runtime.c node_t *node = pe_find_node(data_set->nodes, host_uname); data_set 564 tools/crm_resource_runtime.c const char *interval, pe_working_set_t *data_set) data_set 581 tools/crm_resource_runtime.c interval, data_set); data_set 593 tools/crm_resource_runtime.c nodes = node_list_dup(data_set->nodes, FALSE, FALSE); data_set 615 tools/crm_resource_runtime.c operation, interval, data_set); data_set 623 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); data_set 649 tools/crm_resource_runtime.c TRUE, data_set); data_set 725 tools/crm_resource_runtime.c const char *rsc_id, pe_working_set_t * data_set) data_set 728 tools/crm_resource_runtime.c return send_lrm_rsc_op(crmd_channel, CRM_OP_LRM_FAIL, host_uname, rsc_id, FALSE, data_set); data_set 732 tools/crm_resource_runtime.c generate_resource_params(resource_t * rsc, pe_working_set_t * data_set) data_set 748 tools/crm_resource_runtime.c get_rsc_attributes(params, rsc, NULL /* TODO: Pass in local node */ , data_set); data_set 749 tools/crm_resource_runtime.c get_meta_attributes(meta, rsc, NULL /* TODO: Pass in local node */ , data_set); data_set 905 tools/crm_resource_runtime.c update_working_set_xml(pe_working_set_t *data_set, xmlNode **xml) data_set 910 tools/crm_resource_runtime.c data_set->input = *xml; data_set 911 tools/crm_resource_runtime.c data_set->now = crm_time_new(NULL); data_set 927 tools/crm_resource_runtime.c update_working_set_from_cib(pe_working_set_t * data_set, cib_t *cib) data_set 937 tools/crm_resource_runtime.c rc = update_working_set_xml(data_set, &cib_xml_copy); data_set 947 tools/crm_resource_runtime.c update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate) data_set 954 tools/crm_resource_runtime.c cleanup_alloc_calculations(data_set); data_set 955 tools/crm_resource_runtime.c rc = update_working_set_from_cib(data_set, cib); data_set 971 tools/crm_resource_runtime.c rc = write_xml_file(data_set->input, shadow_file, FALSE); data_set 984 tools/crm_resource_runtime.c do_calculations(data_set, data_set->input, NULL); data_set 985 tools/crm_resource_runtime.c run_simulation(data_set, shadow_cib, NULL, TRUE); data_set 986 tools/crm_resource_runtime.c rc = update_dataset(shadow_cib, data_set, FALSE); data_set 989 tools/crm_resource_runtime.c cluster_status(data_set); data_set 1006 tools/crm_resource_runtime.c max_delay_for_resource(pe_working_set_t * data_set, resource_t *rsc) data_set 1017 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, child); data_set 1027 tools/crm_resource_runtime.c action_t *stop = custom_action(rsc, key, RSC_STOP, NULL, TRUE, FALSE, data_set); data_set 1039 tools/crm_resource_runtime.c max_delay_in(pe_working_set_t * data_set, GList *resources) data_set 1046 tools/crm_resource_runtime.c resource_t *rsc = pe_find_resource(data_set->resources, (const char *)item->data); data_set 1048 tools/crm_resource_runtime.c delay = max_delay_for_resource(data_set, rsc); data_set 1096 tools/crm_resource_runtime.c pe_working_set_t data_set; data_set 1135 tools/crm_resource_runtime.c set_working_set_defaults(&data_set); data_set 1136 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); data_set 1143 tools/crm_resource_runtime.c restart_target_active = get_active_resources(host, data_set.resources); data_set 1144 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set.resources); data_set 1165 tools/crm_resource_runtime.c RSC_STOPPED, FALSE, cib, &data_set); data_set 1179 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, TRUE); data_set 1185 tools/crm_resource_runtime.c target_active = get_active_resources(host, data_set.resources); data_set 1196 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(&data_set, list_delta) / sleep_interval; data_set 1206 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); data_set 1215 tools/crm_resource_runtime.c current_active = get_active_resources(host, data_set.resources); data_set 1240 tools/crm_resource_runtime.c &data_set); data_set 1246 tools/crm_resource_runtime.c &data_set); data_set 1270 tools/crm_resource_runtime.c step_timeout_s = max_delay_in(&data_set, list_delta) / sleep_interval; data_set 1282 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); data_set 1295 tools/crm_resource_runtime.c current_active = get_active_resources(NULL, data_set.resources); data_set 1321 tools/crm_resource_runtime.c orig_target_role, FALSE, cib, &data_set); data_set 1325 tools/crm_resource_runtime.c XML_RSC_ATTR_TARGET_ROLE, cib, &data_set); data_set 1341 tools/crm_resource_runtime.c cleanup_alloc_calculations(&data_set); data_set 1422 tools/crm_resource_runtime.c pe_working_set_t data_set; data_set 1428 tools/crm_resource_runtime.c set_working_set_defaults(&data_set); data_set 1436 tools/crm_resource_runtime.c print_pending_actions(data_set.actions); data_set 1437 tools/crm_resource_runtime.c cleanup_alloc_calculations(&data_set); data_set 1445 tools/crm_resource_runtime.c cleanup_alloc_calculations(&data_set); data_set 1446 tools/crm_resource_runtime.c rc = update_working_set_from_cib(&data_set, cib); data_set 1448 tools/crm_resource_runtime.c cleanup_alloc_calculations(&data_set); data_set 1451 tools/crm_resource_runtime.c do_calculations(&data_set, data_set.input, NULL); data_set 1453 tools/crm_resource_runtime.c } while (actions_are_pending(data_set.actions)); data_set 1461 tools/crm_resource_runtime.c int timeout_ms, cib_t * cib, pe_working_set_t *data_set) data_set 1487 tools/crm_resource_runtime.c rc = cli_resource_search(rsc, requested_name, data_set); data_set 1516 tools/crm_resource_runtime.c params = generate_resource_params(rsc, data_set); data_set 1520 tools/crm_resource_runtime.c timeout_ms = pe_get_configured_timeout(rsc, action, data_set); data_set 1618 tools/crm_resource_runtime.c cib_t *cib, pe_working_set_t *data_set) data_set 1623 tools/crm_resource_runtime.c node_t *dest = pe_find_node(data_set->nodes, host_name); data_set 1692 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib); data_set 53 tools/crm_simulate.c extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 55 tools/crm_simulate.c extern xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 60 tools/crm_simulate.c get_date(pe_working_set_t * data_set) data_set 65 tools/crm_simulate.c crm_element_value_int(data_set->input, "execution-date", &value); data_set 69 tools/crm_simulate.c data_set->now = crm_time_new(use_date); data_set 74 tools/crm_simulate.c data_set->now = crm_time_new(NULL); data_set 75 tools/crm_simulate.c crm_time_set_timet(data_set->now, &original_date); data_set 77 tools/crm_simulate.c when = crm_time_as_string(data_set->now, crm_time_log_date|crm_time_log_timeofday); data_set 85 tools/crm_simulate.c print_cluster_status(pe_working_set_t * data_set, long options) data_set 95 tools/crm_simulate.c for (gIter = data_set->nodes; gIter != NULL; gIter = gIter->next) { data_set 195 tools/crm_simulate.c for (gIter = data_set->resources; gIter != NULL; gIter = gIter->next) { data_set 278 tools/crm_simulate.c create_dotfile(pe_working_set_t * data_set, const char *dot_file, gboolean all_actions) data_set 289 tools/crm_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 334 tools/crm_simulate.c for (gIter = data_set->actions; gIter != NULL; gIter = gIter->next) { data_set 520 tools/crm_simulate.c pe_working_set_t data_set; data_set 538 tools/crm_simulate.c set_working_set_defaults(&data_set); data_set 540 tools/crm_simulate.c data_set.input = cib_object; data_set 541 tools/crm_simulate.c get_date(&data_set); data_set 542 tools/crm_simulate.c do_calculations(&data_set, cib_object, NULL); data_set 544 tools/crm_simulate.c cleanup_alloc_calculations(&data_set); data_set 587 tools/crm_simulate.c count_resources(pe_working_set_t * data_set, resource_t * rsc) data_set 593 tools/crm_simulate.c gIter = data_set->resources; data_set 601 tools/crm_simulate.c count += count_resources(data_set, gIter->data); data_set 618 tools/crm_simulate.c pe_working_set_t data_set; data_set 800 tools/crm_simulate.c set_working_set_defaults(&data_set); data_set 802 tools/crm_simulate.c if (data_set.now != NULL) { data_set 804 tools/crm_simulate.c crm_time_log(LOG_WARNING, "Set fake 'now' to", data_set.now, data_set 811 tools/crm_simulate.c data_set.input = input; data_set 812 tools/crm_simulate.c get_date(&data_set); data_set 814 tools/crm_simulate.c set_bit(data_set.flags, pe_flag_sanitized); data_set 816 tools/crm_simulate.c cluster_status(&data_set); data_set 821 tools/crm_simulate.c if(is_set(data_set.flags, pe_flag_maintenance_mode)) { data_set 827 tools/crm_simulate.c if(data_set.disabled_resources || data_set.blocked_resources) { data_set 829 tools/crm_simulate.c data_set.disabled_resources, count_resources(&data_set, NULL), data_set.blocked_resources); data_set 833 tools/crm_simulate.c print_cluster_status(&data_set, options); data_set 838 tools/crm_simulate.c modify_configuration(&data_set, global_cib, quorum, watchdog, node_up, node_down, node_fail, op_inject, data_set 847 tools/crm_simulate.c cleanup_calculations(&data_set); data_set 848 tools/crm_simulate.c data_set.input = input; data_set 849 tools/crm_simulate.c get_date(&data_set); data_set 852 tools/crm_simulate.c set_bit(data_set.flags, pe_flag_sanitized); data_set 854 tools/crm_simulate.c cluster_status(&data_set); data_set 877 tools/crm_simulate.c do_calculations(&data_set, input, local_date); data_set 881 tools/crm_simulate.c write_xml_file(data_set.graph, graph_file, FALSE); data_set 885 tools/crm_simulate.c create_dotfile(&data_set, dot_file, all_actions); data_set 895 tools/crm_simulate.c LogNodeActions(&data_set, TRUE); data_set 896 tools/crm_simulate.c for (gIter = data_set.resources; gIter != NULL; gIter = gIter->next) { data_set 899 tools/crm_simulate.c LogActions(rsc, &data_set, TRUE); data_set 905 tools/crm_simulate.c rc = run_simulation(&data_set, global_cib, op_fail, quiet); data_set 907 tools/crm_simulate.c get_date(&data_set); data_set 910 tools/crm_simulate.c cluster_status(&data_set); data_set 911 tools/crm_simulate.c print_cluster_status(&data_set, 0); data_set 916 tools/crm_simulate.c cleanup_alloc_calculations(&data_set); data_set 58 tools/crm_ticket.c extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 66 tools/crm_ticket.c find_ticket(const char *ticket_id, pe_working_set_t * data_set) data_set 70 tools/crm_ticket.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 139 tools/crm_ticket.c print_ticket_list(pe_working_set_t * data_set, gboolean raw, gboolean details) data_set 144 tools/crm_ticket.c g_hash_table_iter_init(&iter, data_set->tickets); data_set 406 tools/crm_ticket.c pe_working_set_t * data_set) data_set 413 tools/crm_ticket.c ticket = g_hash_table_lookup(data_set->tickets, ticket_id); data_set 508 tools/crm_ticket.c cib_t * cib, pe_working_set_t * data_set) data_set 555 tools/crm_ticket.c ticket = find_ticket(ticket_id, data_set); data_set 705 tools/crm_ticket.c pe_working_set_t data_set; data_set 839 tools/crm_ticket.c set_working_set_defaults(&data_set); data_set 869 tools/crm_ticket.c data_set.input = cib_xml_copy; data_set 870 tools/crm_ticket.c data_set.now = crm_time_new(NULL); data_set 872 tools/crm_ticket.c cluster_status(&data_set); data_set 876 tools/crm_ticket.c cib_constraints = get_object_root(XML_CIB_TAG_CONSTRAINTS, data_set.input); data_set 877 tools/crm_ticket.c unpack_constraints(cib_constraints, &data_set); data_set 890 tools/crm_ticket.c ticket_t *ticket = find_ticket(ticket_id, &data_set); data_set 899 tools/crm_ticket.c rc = print_ticket_list(&data_set, raw, details); data_set 917 tools/crm_ticket.c rc = get_ticket_state_attr(ticket_id, get_attr_name, &value, &data_set); data_set 935 tools/crm_ticket.c ticket = find_ticket(ticket_id, &data_set); data_set 976 tools/crm_ticket.c rc = modify_ticket_state(ticket_id, attr_delete, attr_set, cib_conn, &data_set); data_set 1017 tools/crm_ticket.c cleanup_alloc_calculations(&data_set); data_set 42 tools/crm_verify.c extern gboolean stage0(pe_working_set_t * data_set); data_set 43 tools/crm_verify.c extern void cleanup_alloc_calculations(pe_working_set_t * data_set); data_set 44 tools/crm_verify.c extern xmlNode *do_calculations(pe_working_set_t * data_set, xmlNode * xml_input, crm_time_t * now); data_set 82 tools/crm_verify.c pe_working_set_t data_set; data_set 241 tools/crm_verify.c set_working_set_defaults(&data_set); data_set 245 tools/crm_verify.c do_calculations(&data_set, cib_object, NULL); data_set 246 tools/crm_verify.c cleanup_alloc_calculations(&data_set); data_set 249 tools/crm_verify.c data_set.now = crm_time_new(NULL); data_set 250 tools/crm_verify.c data_set.input = cib_object; data_set 251 tools/crm_verify.c stage0(&data_set); data_set 252 tools/crm_verify.c cleanup_alloc_calculations(&data_set); data_set 416 tools/fake_transition.c modify_configuration(pe_working_set_t * data_set, cib_t *cib, data_set 574 tools/fake_transition.c rsc = pe_find_resource(data_set->resources, resource); data_set 802 tools/fake_transition.c run_simulation(pe_working_set_t * data_set, cib_t *cib, GListPtr op_fail_list, bool quiet) data_set 821 tools/fake_transition.c transition = unpack_graph(data_set->graph, crm_system_name); data_set 824 tools/fake_transition.c fake_resource_list = data_set->resources; data_set 845 tools/fake_transition.c cleanup_alloc_calculations(data_set); data_set 846 tools/fake_transition.c data_set->input = cib_object; data_set 2 tools/fake_transition.h pe_working_set_t * data_set, cib_t *cib, data_set 7 tools/fake_transition.h int run_simulation(pe_working_set_t * data_set, cib_t *cib, GListPtr op_fail_list, bool quiet);