cluster 30 daemons/controld/controld_control.c extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster); cluster 44 daemons/controld/controld_control.c static pcmk_cluster_t *cluster = NULL; cluster 46 daemons/controld/controld_control.c if (cluster == NULL) { cluster 47 daemons/controld/controld_control.c cluster = pcmk_cluster_new(); cluster 51 daemons/controld/controld_control.c pcmk_cluster_disconnect(cluster); cluster 63 daemons/controld/controld_control.c registered = crm_connect_corosync(cluster); cluster 68 daemons/controld/controld_control.c controld_election_init(cluster->uname); cluster 69 daemons/controld/controld_control.c controld_globals.our_nodename = cluster->uname; cluster 70 daemons/controld/controld_control.c controld_globals.our_uuid = cluster->uuid; cluster 71 daemons/controld/controld_control.c if(cluster->uuid == NULL) { cluster 141 daemons/controld/controld_corosync.c extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster); cluster 144 daemons/controld/controld_corosync.c crm_connect_corosync(pcmk_cluster_t *cluster) cluster 149 daemons/controld/controld_corosync.c pcmk_cluster_set_destroy_fn(cluster, crmd_cs_destroy); cluster 150 daemons/controld/controld_corosync.c pcmk_cpg_set_deliver_fn(cluster, crmd_cs_dispatch); cluster 151 daemons/controld/controld_corosync.c pcmk_cpg_set_confchg_fn(cluster, cpg_membership_callback); cluster 153 daemons/controld/controld_corosync.c if (pcmk_cluster_connect(cluster) == pcmk_rc_ok) { cluster 536 daemons/fenced/pacemaker-fenced.c pcmk_cluster_t *cluster = NULL; cluster 621 daemons/fenced/pacemaker-fenced.c cluster = pcmk_cluster_new(); cluster 626 daemons/fenced/pacemaker-fenced.c pcmk_cluster_set_destroy_fn(cluster, stonith_peer_cs_destroy); cluster 627 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_deliver_fn(cluster, stonith_peer_ais_callback); cluster 628 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_confchg_fn(cluster, pcmk__cpg_confchg_cb); cluster 634 daemons/fenced/pacemaker-fenced.c if (pcmk_cluster_connect(cluster) != pcmk_rc_ok) { cluster 639 daemons/fenced/pacemaker-fenced.c pcmk__str_update(&stonith_our_uname, cluster->uname); cluster 668 daemons/fenced/pacemaker-fenced.c pcmk_cluster_free(cluster); cluster 171 include/crm/cluster.h int pcmk_cluster_connect(pcmk_cluster_t *cluster); cluster 172 include/crm/cluster.h int pcmk_cluster_disconnect(pcmk_cluster_t *cluster); cluster 175 include/crm/cluster.h void pcmk_cluster_free(pcmk_cluster_t *cluster); cluster 177 include/crm/cluster.h int pcmk_cluster_set_destroy_fn(pcmk_cluster_t *cluster, void (*fn)(gpointer)); cluster 179 include/crm/cluster.h int pcmk_cpg_set_deliver_fn(pcmk_cluster_t *cluster, cpg_deliver_fn_t fn); cluster 180 include/crm/cluster.h int pcmk_cpg_set_confchg_fn(pcmk_cluster_t *cluster, cpg_confchg_fn_t fn); cluster 72 include/crm/cluster/compat.h gboolean cluster_connect_cpg(pcmk_cluster_t *cluster); cluster 75 include/crm/cluster/compat.h void cluster_disconnect_cpg(pcmk_cluster_t *cluster); cluster 106 include/crm/cluster/compat.h gboolean crm_cluster_connect(pcmk_cluster_t *cluster); cluster 109 include/crm/cluster/compat.h void crm_cluster_disconnect(pcmk_cluster_t *cluster); cluster 408 include/crm/common/resources.h pcmk_scheduler_t *cluster; // Cluster that resource is part of cluster 211 include/crm/pengine/internal.h optional, rsc->cluster); cluster 216 include/crm/pengine/internal.h optional, rsc->cluster); cluster 222 include/crm/pengine/internal.h optional, rsc->cluster) cluster 227 include/crm/pengine/internal.h optional, rsc->cluster) cluster 232 include/crm/pengine/internal.h optional, rsc->cluster) cluster 145 include/pcmki/pcmki_transition.h int (*cluster) (pcmk__graph_t *graph, pcmk__graph_action_t *action); cluster 33 lib/cluster/cluster.c CRM_TRACE_INIT_DATA(cluster); cluster 123 lib/cluster/cluster.c pcmk_cluster_connect(pcmk_cluster_t *cluster) cluster 134 lib/cluster/cluster.c return pcmk__corosync_connect(cluster); cluster 154 lib/cluster/cluster.c pcmk_cluster_disconnect(pcmk_cluster_t *cluster) cluster 164 lib/cluster/cluster.c pcmk__corosync_disconnect(cluster); cluster 197 lib/cluster/cluster.c pcmk_cluster_free(pcmk_cluster_t *cluster) cluster 199 lib/cluster/cluster.c if (cluster == NULL) { cluster 202 lib/cluster/cluster.c free(cluster->uuid); cluster 203 lib/cluster/cluster.c free(cluster->uname); cluster 204 lib/cluster/cluster.c free(cluster); cluster 216 lib/cluster/cluster.c pcmk_cluster_set_destroy_fn(pcmk_cluster_t *cluster, void (*fn)(gpointer)) cluster 218 lib/cluster/cluster.c if (cluster == NULL) { cluster 221 lib/cluster/cluster.c cluster->destroy = fn; cluster 418 lib/cluster/cluster.c const char *cluster = NULL; cluster 425 lib/cluster/cluster.c cluster = pcmk__env_option(PCMK__ENV_CLUSTER_TYPE); cluster 427 lib/cluster/cluster.c if (cluster != NULL) { cluster 428 lib/cluster/cluster.c crm_info("Verifying configured cluster layer '%s'", cluster); cluster 432 lib/cluster/cluster.c if (pcmk__str_eq(cluster, PCMK_VALUE_COROSYNC, pcmk__str_casei)) { cluster 440 lib/cluster/cluster.c cluster); cluster 443 lib/cluster/cluster.c crm_info("Assuming an active '%s' cluster", cluster); cluster 477 lib/cluster/cluster.c crm_cluster_connect(pcmk_cluster_t *cluster) cluster 479 lib/cluster/cluster.c return pcmk_cluster_connect(cluster) == pcmk_rc_ok; cluster 483 lib/cluster/cluster.c crm_cluster_disconnect(pcmk_cluster_t *cluster) cluster 485 lib/cluster/cluster.c pcmk_cluster_disconnect(cluster); cluster 223 lib/cluster/corosync.c pcmk__corosync_disconnect(pcmk_cluster_t *cluster) cluster 225 lib/cluster/corosync.c pcmk__cpg_disconnect(cluster); cluster 455 lib/cluster/corosync.c pcmk__corosync_connect(pcmk_cluster_t *cluster) cluster 470 lib/cluster/corosync.c rc = pcmk__cpg_connect(cluster); cluster 477 lib/cluster/corosync.c cluster->nodeid = pcmk__cpg_local_nodeid(0); cluster 478 lib/cluster/corosync.c if (cluster->nodeid == 0) { cluster 483 lib/cluster/corosync.c cluster->uname = pcmk__cluster_node_name(0); cluster 484 lib/cluster/corosync.c if (cluster->uname == NULL) { cluster 490 lib/cluster/corosync.c peer = pcmk__get_node(cluster->nodeid, cluster->uname, NULL, cluster 492 lib/cluster/corosync.c cluster->uuid = pcmk__corosync_uuid(peer); cluster 271 lib/cluster/cpg.c pcmk_cluster_t *cluster = (pcmk_cluster_t *) user_data; cluster 273 lib/cluster/cpg.c rc = cpg_dispatch(cluster->cpg_handle, CS_DISPATCH_ONE); cluster 277 lib/cluster/cpg.c cpg_finalize(cluster->cpg_handle); cluster 278 lib/cluster/cpg.c cluster->cpg_handle = 0; cluster 794 lib/cluster/cpg.c pcmk_cpg_set_deliver_fn(pcmk_cluster_t *cluster, cpg_deliver_fn_t fn) cluster 796 lib/cluster/cpg.c if (cluster == NULL) { cluster 799 lib/cluster/cpg.c cluster->cpg.cpg_deliver_fn = fn; cluster 812 lib/cluster/cpg.c pcmk_cpg_set_confchg_fn(pcmk_cluster_t *cluster, cpg_confchg_fn_t fn) cluster 814 lib/cluster/cpg.c if (cluster == NULL) { cluster 817 lib/cluster/cpg.c cluster->cpg.cpg_confchg_fn = fn; cluster 829 lib/cluster/cpg.c pcmk__cpg_connect(pcmk_cluster_t *cluster) cluster 845 lib/cluster/cpg.c .destroy = cluster->destroy, cluster 850 lib/cluster/cpg.c .cpg_deliver_fn = cluster->cpg.cpg_deliver_fn, cluster 851 lib/cluster/cpg.c .cpg_confchg_fn = cluster->cpg.cpg_confchg_fn, cluster 857 lib/cluster/cpg.c cluster->group.length = 0; cluster 858 lib/cluster/cpg.c cluster->group.value[0] = 0; cluster 861 lib/cluster/cpg.c strncpy(cluster->group.value, message_name, 127); cluster 862 lib/cluster/cpg.c cluster->group.value[127] = 0; cluster 863 lib/cluster/cpg.c cluster->group.length = 1 + QB_MIN(127, strlen(cluster->group.value)); cluster 901 lib/cluster/cpg.c cluster->nodeid = id; cluster 904 lib/cluster/cpg.c cs_repeat(rc, retries, 30, cpg_join(handle, &cluster->group)); cluster 911 lib/cluster/cpg.c cluster->cpg_handle = handle; cluster 912 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); cluster 933 lib/cluster/cpg.c pcmk__cpg_disconnect(pcmk_cluster_t *cluster) cluster 936 lib/cluster/cpg.c if (cluster->cpg_handle != 0) { cluster 938 lib/cluster/cpg.c cpg_leave(cluster->cpg_handle, &cluster->group); cluster 939 lib/cluster/cpg.c cpg_finalize(cluster->cpg_handle); cluster 940 lib/cluster/cpg.c cluster->cpg_handle = 0; cluster 1110 lib/cluster/cpg.c cluster_connect_cpg(pcmk_cluster_t *cluster) cluster 1112 lib/cluster/cpg.c return pcmk__cpg_connect(cluster) == pcmk_rc_ok; cluster 1116 lib/cluster/cpg.c cluster_disconnect_cpg(pcmk_cluster_t *cluster) cluster 1118 lib/cluster/cpg.c pcmk__cpg_disconnect(cluster); cluster 42 lib/cluster/crmcluster_private.h int pcmk__corosync_connect(pcmk_cluster_t *cluster); cluster 45 lib/cluster/crmcluster_private.h void pcmk__corosync_disconnect(pcmk_cluster_t *cluster); cluster 51 lib/cluster/crmcluster_private.h int pcmk__cpg_connect(pcmk_cluster_t *cluster); cluster 54 lib/cluster/crmcluster_private.h void pcmk__cpg_disconnect(pcmk_cluster_t *cluster); cluster 39 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c pcmk_cluster_t cluster = { cluster 43 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_int_equal(pcmk_cluster_set_destroy_fn(&cluster, NULL), pcmk_rc_ok); cluster 44 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_ptr_equal(cluster.destroy, NULL); cluster 46 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c cluster.destroy = destroy_fn1; cluster 47 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_int_equal(pcmk_cluster_set_destroy_fn(&cluster, NULL), pcmk_rc_ok); cluster 48 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_ptr_equal(cluster.destroy, NULL); cluster 54 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c pcmk_cluster_t cluster = { cluster 58 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_int_equal(pcmk_cluster_set_destroy_fn(&cluster, destroy_fn1), cluster 60 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_ptr_equal(cluster.destroy, destroy_fn1); cluster 66 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c pcmk_cluster_t cluster = { cluster 70 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_int_equal(pcmk_cluster_set_destroy_fn(&cluster, destroy_fn1), cluster 72 lib/cluster/tests/cluster/pcmk_cluster_set_destroy_fn_test.c assert_ptr_equal(cluster.destroy, destroy_fn1); cluster 49 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c pcmk_cluster_t cluster = { cluster 55 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_int_equal(pcmk_cpg_set_confchg_fn(&cluster, NULL), pcmk_rc_ok); cluster 56 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_ptr_equal(cluster.cpg.cpg_confchg_fn, NULL); cluster 58 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c cluster.cpg.cpg_confchg_fn = confchg_fn1; cluster 59 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_int_equal(pcmk_cpg_set_confchg_fn(&cluster, NULL), pcmk_rc_ok); cluster 60 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_ptr_equal(cluster.cpg.cpg_confchg_fn, NULL); cluster 66 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c pcmk_cluster_t cluster = { cluster 72 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_int_equal(pcmk_cpg_set_confchg_fn(&cluster, confchg_fn1), cluster 74 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_ptr_equal(cluster.cpg.cpg_confchg_fn, confchg_fn1); cluster 80 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c pcmk_cluster_t cluster = { cluster 86 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_int_equal(pcmk_cpg_set_confchg_fn(&cluster, confchg_fn1), cluster 88 lib/cluster/tests/cpg/pcmk_cpg_set_confchg_fn_test.c assert_ptr_equal(cluster.cpg.cpg_confchg_fn, confchg_fn1); cluster 45 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c pcmk_cluster_t cluster = { cluster 51 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_int_equal(pcmk_cpg_set_deliver_fn(&cluster, NULL), pcmk_rc_ok); cluster 52 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_ptr_equal(cluster.cpg.cpg_deliver_fn, NULL); cluster 54 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c cluster.cpg.cpg_deliver_fn = deliver_fn1; cluster 55 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_int_equal(pcmk_cpg_set_deliver_fn(&cluster, NULL), pcmk_rc_ok); cluster 56 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_ptr_equal(cluster.cpg.cpg_deliver_fn, NULL); cluster 62 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c pcmk_cluster_t cluster = { cluster 68 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_int_equal(pcmk_cpg_set_deliver_fn(&cluster, deliver_fn1), cluster 70 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_ptr_equal(cluster.cpg.cpg_deliver_fn, deliver_fn1); cluster 76 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c pcmk_cluster_t cluster = { cluster 82 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_int_equal(pcmk_cpg_set_deliver_fn(&cluster, deliver_fn1), cluster 84 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c assert_ptr_equal(cluster.cpg.cpg_deliver_fn, deliver_fn1); cluster 687 lib/pacemaker/libpacemaker_private.h NULL, (flags), (first_rsc)->cluster) cluster 220 lib/pacemaker/pcmk_graph_consumer.c CRM_ASSERT(graph_fns->cluster != NULL); cluster 322 lib/pacemaker/pcmk_graph_consumer.c return graph_fns->cluster(graph, action); cluster 345 lib/pacemaker/pcmk_graph_producer.c action->rsc->cluster); cluster 354 lib/pacemaker/pcmk_graph_producer.c action->rsc->cluster); cluster 985 lib/pacemaker/pcmk_graph_producer.c g_list_foreach(rsc->actions, add_action_to_graph, rsc->cluster); cluster 585 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(rsc->cluster); cluster 594 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(rsc->cluster, pcmk_rsc_detect_loop); cluster 597 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(rsc->cluster, pcmk_rsc_detect_loop); cluster 611 lib/pacemaker/pcmk_output.c pcmk__unpack_constraints(rsc->cluster); cluster 621 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(rsc->cluster, pcmk_rsc_detect_loop); cluster 624 lib/pacemaker/pcmk_output.c pe__clear_resource_flags_on_all(rsc->cluster, pcmk_rsc_detect_loop); cluster 45 lib/pacemaker/pcmk_resource.c history = get_xpath_object(xpath, rsc->cluster->input, LOG_NEVER); cluster 228 lib/pacemaker/pcmk_resource.c overrides, true, rsc->cluster); cluster 1528 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1532 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1575 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1582 lib/pacemaker/pcmk_sched_actions.c FALSE, rsc->cluster); cluster 1588 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1591 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1631 lib/pacemaker/pcmk_sched_actions.c } else if (pcmk_is_set(rsc->cluster->flags, cluster 1649 lib/pacemaker/pcmk_sched_actions.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, rsc->cluster); cluster 1651 lib/pacemaker/pcmk_sched_actions.c if (only_sanitized_changed(xml_op, digest_data, rsc->cluster)) { cluster 1652 lib/pacemaker/pcmk_sched_actions.c if (!pcmk__is_daemon && (rsc->cluster->priv != NULL)) { cluster 1653 lib/pacemaker/pcmk_sched_actions.c pcmk__output_t *out = rsc->cluster->priv; cluster 1688 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1833 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 1839 lib/pacemaker/pcmk_sched_actions.c rsc->cluster); cluster 123 lib/pacemaker/pcmk_sched_bundle.c pe__show_node_scores(!pcmk_is_set(rsc->cluster->flags, cluster 125 lib/pacemaker/pcmk_sched_bundle.c rsc, __func__, rsc->allowed_nodes, rsc->cluster); cluster 811 lib/pacemaker/pcmk_sched_bundle.c NULL, replica->remote->cluster); cluster 891 lib/pacemaker/pcmk_sched_bundle.c replica->container->cluster); cluster 965 lib/pacemaker/pcmk_sched_bundle.c probe_data->bundle->cluster); cluster 77 lib/pacemaker/pcmk_sched_clone.c pe__show_node_scores(!pcmk_is_set(rsc->cluster->flags, cluster 79 lib/pacemaker/pcmk_sched_clone.c rsc, __func__, rsc->allowed_nodes, rsc->cluster); cluster 394 lib/pacemaker/pcmk_sched_colocation.c dependent->cluster->colocation_constraints = g_list_prepend( cluster 395 lib/pacemaker/pcmk_sched_colocation.c dependent->cluster->colocation_constraints, new_con); cluster 1051 lib/pacemaker/pcmk_sched_colocation.c pcmk__update_action_for_orderings(action, rsc->cluster); cluster 1520 lib/pacemaker/pcmk_sched_colocation.c for (GList *loc_iter = rsc->cluster->placement_constraints; cluster 1836 lib/pacemaker/pcmk_sched_colocation.c pe__show_node_scores(true, NULL, log_id, work, source_rsc->cluster); cluster 204 lib/pacemaker/pcmk_sched_fencing.c pcmk__ar_ordered, rsc->cluster); cluster 318 lib/pacemaker/pcmk_sched_fencing.c && pcmk_is_set(rsc->cluster->flags, pcmk_sched_enable_unfencing)) cluster 471 lib/pacemaker/pcmk_sched_fencing.c false, rsc->cluster); cluster 494 lib/pacemaker/pcmk_sched_fencing.c rsc->cluster); cluster 500 lib/pacemaker/pcmk_sched_fencing.c rsc->cluster); cluster 67 lib/pacemaker/pcmk_sched_group.c pe__show_node_scores(!pcmk_is_set(rsc->cluster->flags, cluster 69 lib/pacemaker/pcmk_sched_group.c rsc, __func__, rsc->allowed_nodes, rsc->cluster); cluster 105 lib/pacemaker/pcmk_sched_group.c action, NULL, TRUE, group->cluster); cluster 854 lib/pacemaker/pcmk_sched_instances.c "collective_limit_reached", collective->cluster); cluster 1435 lib/pacemaker/pcmk_sched_instances.c type, then->rsc->cluster); cluster 1537 lib/pacemaker/pcmk_sched_instances.c instance->cluster); cluster 1545 lib/pacemaker/pcmk_sched_instances.c pcmk__update_action_for_orderings(after->action, instance->cluster); cluster 129 lib/pacemaker/pcmk_sched_location.c rule_xml = expand_idref(rule_xml, rsc->cluster->input); cluster 198 lib/pacemaker/pcmk_sched_location.c for (iter = rsc->cluster->nodes; iter != NULL; iter = iter->next) { cluster 202 lib/pacemaker/pcmk_sched_location.c rule_input->rsc_params = pe_rsc_params(rsc, node, rsc->cluster); cluster 253 lib/pacemaker/pcmk_sched_location.c pcmk_node_t *match = pcmk_find_node(rsc->cluster, node); cluster 289 lib/pacemaker/pcmk_sched_location.c .now = rsc->cluster->now, cluster 336 lib/pacemaker/pcmk_sched_location.c pe__update_recheck_time(t, rsc->cluster, cluster 637 lib/pacemaker/pcmk_sched_location.c rsc->cluster->placement_constraints = g_list_prepend( cluster 638 lib/pacemaker/pcmk_sched_location.c rsc->cluster->placement_constraints, new_con); cluster 64 lib/pacemaker/pcmk_sched_migration.c rsc->cluster); cluster 69 lib/pacemaker/pcmk_sched_migration.c TRUE, rsc->cluster); cluster 87 lib/pacemaker/pcmk_sched_migration.c NULL, pcmk__ar_ordered, rsc->cluster); cluster 94 lib/pacemaker/pcmk_sched_migration.c rsc->cluster); cluster 104 lib/pacemaker/pcmk_sched_migration.c NULL, pcmk__ar_ordered, rsc->cluster); cluster 113 lib/pacemaker/pcmk_sched_migration.c rsc->cluster); cluster 121 lib/pacemaker/pcmk_sched_migration.c rsc->cluster); cluster 160 lib/pacemaker/pcmk_sched_migration.c bool cleanup = pcmk_is_set(rsc->cluster->flags, cluster 304 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 322 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 344 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 354 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 371 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 388 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 398 lib/pacemaker/pcmk_sched_migration.c NULL, flags, order->rsc1->cluster); cluster 351 lib/pacemaker/pcmk_sched_ordering.c pcmk_action_t *clone_min_met = get_pseudo_op(task, rsc_first->cluster); cluster 369 lib/pacemaker/pcmk_sched_ordering.c rsc_first->cluster); cluster 376 lib/pacemaker/pcmk_sched_ordering.c rsc_first->cluster); cluster 1369 lib/pacemaker/pcmk_sched_ordering.c first_rsc->cluster); cluster 348 lib/pacemaker/pcmk_sched_primitive.c pcmk_node_t *remote_node = pcmk_find_node(connection->cluster, cluster 430 lib/pacemaker/pcmk_sched_primitive.c rsc->cluster); cluster 454 lib/pacemaker/pcmk_sched_primitive.c rsc->allowed_nodes, rsc->cluster); cluster 482 lib/pacemaker/pcmk_sched_primitive.c PCMK_META_TARGET_ROLE, rsc->cluster); cluster 485 lib/pacemaker/pcmk_sched_primitive.c && !pcmk_is_set(rsc->cluster->flags, pcmk_sched_quorate) cluster 486 lib/pacemaker/pcmk_sched_primitive.c && (rsc->cluster->no_quorum_policy == pcmk_no_quorum_freeze)) { cluster 495 lib/pacemaker/pcmk_sched_primitive.c pe__show_node_scores(!pcmk_is_set(rsc->cluster->flags, cluster 497 lib/pacemaker/pcmk_sched_primitive.c rsc, __func__, rsc->allowed_nodes, rsc->cluster); cluster 500 lib/pacemaker/pcmk_sched_primitive.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled) cluster 501 lib/pacemaker/pcmk_sched_primitive.c && !pcmk_is_set(rsc->cluster->flags, pcmk_sched_have_fencing)) { cluster 526 lib/pacemaker/pcmk_sched_primitive.c } else if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_stop_all)) { cluster 928 lib/pacemaker/pcmk_sched_primitive.c && pcmk_is_set(rsc->cluster->flags, cluster 934 lib/pacemaker/pcmk_sched_primitive.c && !pcmk__str_eq(rsc->cluster->placement_strategy, cluster 943 lib/pacemaker/pcmk_sched_primitive.c rsc->cluster); cluster 954 lib/pacemaker/pcmk_sched_primitive.c pcmk__ar_promoted_then_implies_first, rsc->cluster); cluster 960 lib/pacemaker/pcmk_sched_primitive.c pcmk__ar_unrunnable_first_blocks, rsc->cluster); cluster 969 lib/pacemaker/pcmk_sched_primitive.c rsc->cluster); cluster 1017 lib/pacemaker/pcmk_sched_primitive.c remote_rsc = pe__resource_contains_guest_node(rsc->cluster, cluster 1051 lib/pacemaker/pcmk_sched_primitive.c rsc->cluster); cluster 1059 lib/pacemaker/pcmk_sched_primitive.c NULL, pcmk__ar_then_implies_first, rsc->cluster); cluster 1297 lib/pacemaker/pcmk_sched_primitive.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_remove_after_stop)) { cluster 1303 lib/pacemaker/pcmk_sched_primitive.c NULL, false, rsc->cluster); cluster 1609 lib/pacemaker/pcmk_sched_primitive.c PCMK_OPT_SHUTDOWN_LOCK, rsc->cluster); cluster 1666 lib/pacemaker/pcmk_sched_primitive.c if (rsc->cluster->shutdown_lock > 0) { cluster 1667 lib/pacemaker/pcmk_sched_primitive.c time_t lock_expiration = rsc->lock_time + rsc->cluster->shutdown_lock; cluster 1672 lib/pacemaker/pcmk_sched_primitive.c pe__update_recheck_time(++lock_expiration, rsc->cluster, cluster 1680 lib/pacemaker/pcmk_sched_primitive.c g_list_foreach(rsc->cluster->nodes, ban_if_not_locked, rsc); cluster 86 lib/pacemaker/pcmk_sched_probes.c pcmk__ar_ordered, rsc1->cluster); cluster 137 lib/pacemaker/pcmk_sched_probes.c rsc->cluster); cluster 167 lib/pacemaker/pcmk_sched_probes.c if (!pcmk_is_set(rsc->cluster->flags, pcmk_sched_probe_resources)) { cluster 180 lib/pacemaker/pcmk_sched_probes.c && pe__resource_contains_guest_node(rsc->cluster, rsc)) { cluster 252 lib/pacemaker/pcmk_sched_probes.c NULL, pcmk__ar_ordered, rsc->cluster); cluster 280 lib/pacemaker/pcmk_sched_probes.c flags, rsc->cluster); cluster 282 lib/pacemaker/pcmk_sched_probes.c pcmk__ar_ordered, rsc->cluster); cluster 713 lib/pacemaker/pcmk_sched_probes.c clear_actions_tracking_flag(rsc->cluster); cluster 446 lib/pacemaker/pcmk_sched_promotable.c clone->cluster); cluster 459 lib/pacemaker/pcmk_sched_promotable.c clone->cluster); cluster 864 lib/pacemaker/pcmk_sched_promotable.c if (pcmk_is_set(instance->cluster->flags, pcmk_sched_output_scores) cluster 865 lib/pacemaker/pcmk_sched_promotable.c && !pcmk__is_daemon && (instance->cluster->priv != NULL)) { cluster 867 lib/pacemaker/pcmk_sched_promotable.c pcmk__output_t *out = instance->cluster->priv; cluster 1011 lib/pacemaker/pcmk_sched_promotable.c && !pcmk_is_set(instance->cluster->flags, pcmk_sched_quorate) cluster 1012 lib/pacemaker/pcmk_sched_promotable.c && (instance->cluster->no_quorum_policy == pcmk_no_quorum_freeze)) { cluster 306 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 326 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 354 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 360 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 367 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 374 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 413 lib/pacemaker/pcmk_sched_recurring.c pcmk__ar_unrunnable_first_blocks, rsc->cluster); cluster 482 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 517 lib/pacemaker/pcmk_sched_recurring.c for (GList *iter = rsc->cluster->nodes; iter != NULL; iter = iter->next) { cluster 543 lib/pacemaker/pcmk_sched_recurring.c is_optional, rsc->cluster); cluster 661 lib/pacemaker/pcmk_sched_recurring.c rsc->cluster); cluster 704 lib/pacemaker/pcmk_sched_recurring.c pcmk__ar_ordered, rsc->cluster); cluster 723 lib/pacemaker/pcmk_sched_recurring.c NULL, rsc->cluster); cluster 725 lib/pacemaker/pcmk_sched_recurring.c task, node, TRUE, rsc->cluster); cluster 70 lib/pacemaker/pcmk_sched_remote.c first_rsc->cluster); cluster 81 lib/pacemaker/pcmk_sched_remote.c pcmk__ar_guest_allowed|extra, then_rsc->cluster); cluster 225 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(remote_rsc->cluster, action->node, cluster 276 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(remote_rsc->cluster, action->node, cluster 322 lib/pacemaker/pcmk_sched_remote.c pe_fence_node(action->rsc->cluster, action->node, "container failed", cluster 660 lib/pacemaker/pcmk_sched_remote.c GHashTable *base = pe_rsc_params(rsc, NULL, rsc->cluster); cluster 128 lib/pacemaker/pcmk_sched_resource.c rsc->cluster); cluster 140 lib/pacemaker/pcmk_sched_resource.c rsc->cluster); cluster 325 lib/pacemaker/pcmk_sched_resource.c out = rsc->cluster->priv; cluster 505 lib/pacemaker/pcmk_sched_resource.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_show_utilization)) { cluster 506 lib/pacemaker/pcmk_sched_resource.c pcmk__output_t *out = rsc->cluster->priv; cluster 700 lib/pacemaker/pcmk_sched_resource.c resource1->cluster); cluster 702 lib/pacemaker/pcmk_sched_resource.c resource2->cluster); cluster 92 lib/pacemaker/pcmk_sched_tickets.c "__loss_of_ticket__", rsc->cluster); cluster 99 lib/pacemaker/pcmk_sched_tickets.c "__loss_of_ticket__", rsc->cluster); cluster 109 lib/pacemaker/pcmk_sched_tickets.c "__loss_of_ticket__", rsc->cluster); cluster 112 lib/pacemaker/pcmk_sched_tickets.c pe_fence_node(rsc->cluster, (pcmk_node_t *) iter->data, cluster 133 lib/pacemaker/pcmk_sched_tickets.c "__no_ticket__", rsc->cluster); cluster 141 lib/pacemaker/pcmk_sched_tickets.c "__ticket_standby__", rsc->cluster); cluster 174 lib/pacemaker/pcmk_sched_tickets.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled)) { cluster 227 lib/pacemaker/pcmk_sched_tickets.c rsc->cluster->ticket_constraints = g_list_append( cluster 228 lib/pacemaker/pcmk_sched_tickets.c rsc->cluster->ticket_constraints, new_rsc_ticket); cluster 530 lib/pacemaker/pcmk_sched_tickets.c "__stateful_without_ticket__", rsc->cluster); cluster 310 lib/pacemaker/pcmk_sched_utilization.c if (pcmk__str_eq(rsc->cluster->placement_strategy, PCMK_VALUE_DEFAULT, cluster 359 lib/pacemaker/pcmk_sched_utilization.c "__limit_utilization__", rsc->cluster); cluster 373 lib/pacemaker/pcmk_sched_utilization.c "__limit_utilization__", rsc->cluster); cluster 383 lib/pacemaker/pcmk_sched_utilization.c rsc->cluster); cluster 427 lib/pacemaker/pcmk_sched_utilization.c rsc->id, rsc->cluster->placement_strategy); cluster 433 lib/pacemaker/pcmk_sched_utilization.c pcmk__ar_if_on_same_node_or_target, rsc->cluster); cluster 440 lib/pacemaker/pcmk_sched_utilization.c pcmk__ar_if_on_same_node_or_target, rsc->cluster); cluster 445 lib/pacemaker/pcmk_sched_utilization.c pcmk__ar_if_on_same_node_or_target, rsc->cluster); cluster 60 lib/pacemaker/pcmk_scheduler.c rsc->cluster); cluster 76 lib/pacemaker/pcmk_scheduler.c pe__clear_failcount(rsc, node, reason, rsc->cluster); cluster 138 lib/pacemaker/pcmk_scheduler.c "__fail_limit__", rsc->cluster); cluster 211 lib/pacemaker/pcmk_scheduler.c if (!pcmk_is_set(rsc->cluster->flags, pcmk_sched_symmetric_cluster) cluster 223 lib/pacemaker/pcmk_scheduler.c resource_location(rsc, node, rsc->stickiness, "stickiness", rsc->cluster); cluster 367 lib/pacemaker/pcmk_scheduler.c for (GList *iter = rsc->cluster->nodes; iter != NULL; iter = iter->next) { cluster 379 lib/pacemaker/pcmk_scheduler.c rsc->cluster); cluster 385 lib/pacemaker/pcmk_scheduler.c NULL, pcmk__ar_ordered, rsc->cluster); cluster 399 lib/pengine/bundle.c parent->cluster) != pcmk_rc_ok) { cluster 650 lib/pengine/bundle.c parent->cluster) != pcmk_rc_ok) { cluster 692 lib/pengine/bundle.c if (pe_find_resource(parent->cluster->resources, id) != NULL) { cluster 698 lib/pengine/bundle.c CRM_ASSERT(pe_find_resource(parent->cluster->resources, cluster 735 lib/pengine/bundle.c node = pcmk_find_node(parent->cluster, uname); cluster 738 lib/pengine/bundle.c PCMK_VALUE_MINUS_INFINITY, parent->cluster); cluster 761 lib/pengine/bundle.c g_list_foreach(parent->cluster->resources, (GFunc) disallow_node, cluster 784 lib/pengine/bundle.c parent->cluster) != pcmk_rc_ok) { cluster 930 lib/pengine/bundle.c params = pe_rsc_params(rsc, NULL, rsc->cluster); cluster 538 lib/pengine/complex.c if (!pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled)) { cluster 551 lib/pengine/complex.c } else if (!pcmk_is_set(rsc->cluster->flags, cluster 574 lib/pengine/complex.c } else if (pcmk_is_set(rsc->cluster->flags, cluster 578 lib/pengine/complex.c } else if (pcmk_is_set(rsc->cluster->flags, cluster 582 lib/pengine/complex.c } else if (rsc->cluster->no_quorum_policy == pcmk_no_quorum_ignore) { cluster 682 lib/pengine/complex.c (*rsc)->cluster = scheduler; cluster 1234 lib/pengine/complex.c rsc->cluster->ninstances++; cluster 1236 lib/pengine/complex.c rsc->cluster->disabled_resources++; cluster 1239 lib/pengine/complex.c rsc->cluster->blocked_resources++; cluster 140 lib/pengine/failcounts.c lrm_op_xpathObj = xpath_search(rsc->cluster->input, lrm_op_xpath); cluster 253 lib/pengine/failcounts.c const char *version = crm_element_value(rsc->cluster->input, cluster 397 lib/pengine/failcounts.c time_t now = get_effective_time(rsc->cluster); cluster 729 lib/pengine/pe_actions.c .now = rsc->cluster->now, cluster 738 lib/pengine/pe_actions.c pe__unpack_dataset_nvpairs(rsc->cluster->op_defaults, cluster 740 lib/pengine/pe_actions.c FALSE, rsc->cluster); cluster 766 lib/pengine/pe_actions.c &rule_data, meta, NULL, TRUE, rsc->cluster); cluster 805 lib/pengine/pe_actions.c GHashTable *params = pe_rsc_params(rsc, node, rsc->cluster); cluster 834 lib/pengine/pe_actions.c rsc->cluster->now, &start_delay)) { cluster 908 lib/pengine/pe_actions.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled)) { cluster 969 lib/pengine/pe_actions.c && pcmk__is_remote_node(pcmk_find_node(rsc->cluster, rsc->id)) cluster 987 lib/pengine/pe_actions.c if (pcmk_is_set(rsc->cluster->flags, cluster 1000 lib/pengine/pe_actions.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled)) { cluster 1633 lib/pengine/pe_actions.c PCMK_ACTION_LRM_DELETE, node, FALSE, rsc->cluster); cluster 1810 lib/pengine/pe_actions.c optional, rsc->cluster); cluster 290 lib/pengine/pe_notif.c rsc->cluster); cluster 348 lib/pengine/pe_notif.c rsc->cluster); cluster 754 lib/pengine/pe_notif.c get_node_names(rsc->cluster->nodes, &node_list, &metal_list); cluster 757 lib/pengine/pe_notif.c get_node_names(rsc->cluster->nodes, &node_list, NULL); cluster 2342 lib/pengine/unpack.c } else if (pcmk_is_set(rsc->cluster->flags, cluster 2368 lib/pengine/unpack.c pe_fence_node(rsc->cluster, node, reason, FALSE); cluster 2398 lib/pengine/unpack.c pe_fence_node(rsc->cluster, node, reason, FALSE); cluster 2420 lib/pengine/unpack.c "__action_migration_auto__", rsc->cluster); cluster 2445 lib/pengine/unpack.c rsc->cluster->stop_needed = cluster 2446 lib/pengine/unpack.c g_list_prepend(rsc->cluster->stop_needed, rsc->container); cluster 2457 lib/pengine/unpack.c if (pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled)) { cluster 2460 lib/pengine/unpack.c tmpnode = pcmk_find_node(rsc->cluster, rsc->id); cluster 2467 lib/pengine/unpack.c pe_fence_node(rsc->cluster, tmpnode, cluster 2490 lib/pengine/unpack.c tmpnode = pcmk_find_node(rsc->cluster, rsc->id); cluster 2510 lib/pengine/unpack.c native_add_running(rsc, node, rsc->cluster, cluster 3027 lib/pengine/unpack.c search = xpath_search(rsc->cluster->input, xpath); cluster 3297 lib/pengine/unpack.c true, history->rsc->cluster); cluster 3301 lib/pengine/unpack.c target, source, -1, history->rsc->cluster); cluster 3319 lib/pengine/unpack.c history->rsc->cluster); cluster 3338 lib/pengine/unpack.c target_node = pcmk_find_node(history->rsc->cluster, target); cluster 3344 lib/pengine/unpack.c native_add_running(history->rsc, target_node, history->rsc->cluster, cluster 3367 lib/pengine/unpack.c pcmk_node_t *source_node = pcmk_find_node(history->rsc->cluster, cluster 3370 lib/pengine/unpack.c native_add_running(history->rsc, target_node, history->rsc->cluster, cluster 3418 lib/pengine/unpack.c PCMK_OCF_OK, history->rsc->cluster); cluster 3431 lib/pengine/unpack.c history->rsc->cluster)) { cluster 3436 lib/pengine/unpack.c pcmk_node_t *target_node = pcmk_find_node(history->rsc->cluster, cluster 3440 lib/pengine/unpack.c native_add_running(history->rsc, target_node, history->rsc->cluster, cluster 3445 lib/pengine/unpack.c history->rsc->cluster)) { cluster 3485 lib/pengine/unpack.c history->rsc->cluster); cluster 3498 lib/pengine/unpack.c history->rsc->cluster)) { cluster 3502 lib/pengine/unpack.c pcmk_node_t *source_node = pcmk_find_node(history->rsc->cluster, cluster 3506 lib/pengine/unpack.c native_add_running(history->rsc, source_node, history->rsc->cluster, cluster 3525 lib/pengine/unpack.c for (const xmlNode *xIter = history->rsc->cluster->failed->children; cluster 3544 lib/pengine/unpack.c pcmk__xml_copy(history->rsc->cluster->failed, history->xml); cluster 3691 lib/pengine/unpack.c fail_rsc->allowed_nodes = pe__node_list2table(rsc->cluster->nodes); cluster 3748 lib/pengine/unpack.c if (!pcmk_is_set(history->rsc->cluster->flags, pcmk_sched_symmetric_cluster) cluster 3795 lib/pengine/unpack.c "__stop_fail__", history->rsc->cluster); cluster 4145 lib/pengine/unpack.c rsc->cluster); cluster 4151 lib/pengine/unpack.c rsc->cluster); cluster 4209 lib/pengine/unpack.c && pcmk_is_set(rsc->cluster->flags, pcmk_sched_fencing_enabled) cluster 4213 lib/pengine/unpack.c pcmk_node_t *remote_node = pcmk_find_node(rsc->cluster, rsc->id); cluster 4269 lib/pengine/unpack.c time_t now = get_effective_time(history->rsc->cluster); cluster 4294 lib/pengine/unpack.c pe__update_recheck_time(last_failure, history->rsc->cluster, cluster 4342 lib/pengine/unpack.c clear_reason, history->rsc->cluster); cluster 4344 lib/pengine/unpack.c if (pcmk_is_set(history->rsc->cluster->flags, cluster 4359 lib/pengine/unpack.c history->rsc->cluster); cluster 4680 lib/pengine/unpack.c "masked-probe-failure", history->rsc->cluster); cluster 4772 lib/pengine/unpack.c target = pcmk_find_node(history->rsc->cluster, migrate_target); cluster 4909 lib/pengine/unpack.c "hard-error", rsc->cluster); cluster 4986 lib/pengine/unpack.c "hard-error", rsc->cluster); cluster 4996 lib/pengine/unpack.c "fatal-error", rsc->cluster); cluster 892 lib/pengine/utils.c for (xmlNode *xml_op = pcmk__xe_first_child(rsc->cluster->failed, NULL, cluster 382 maint/gnulib/lib/argp-help.c struct hol_cluster *cluster; cluster 441 maint/gnulib/lib/argp-help.c make_hol (const struct argp *argp, struct hol_cluster *cluster) cluster 491 maint/gnulib/lib/argp-help.c entry->cluster = cluster; cluster 811 maint/gnulib/lib/argp-help.c int group1 = (entry1->cluster cluster 812 maint/gnulib/lib/argp-help.c ? hol_cluster_base (entry1->cluster)->group cluster 814 maint/gnulib/lib/argp-help.c int group2 = (entry2->cluster cluster 815 maint/gnulib/lib/argp-help.c ? hol_cluster_base (entry2->cluster)->group cluster 824 maint/gnulib/lib/argp-help.c cmp = (entry1->cluster != NULL) - (entry2->cluster != NULL); cluster 829 maint/gnulib/lib/argp-help.c if (entry1->cluster != NULL) cluster 831 maint/gnulib/lib/argp-help.c cmp = hol_cluster_cmp (entry1->cluster, entry2->cluster); cluster 1030 maint/gnulib/lib/argp-help.c argp_hol (const struct argp *argp, struct hol_cluster *cluster) cluster 1033 maint/gnulib/lib/argp-help.c struct hol *hol = make_hol (argp, cluster); cluster 1041 maint/gnulib/lib/argp-help.c child - argp->children, cluster, argp) cluster 1043 maint/gnulib/lib/argp-help.c : cluster); cluster 1195 maint/gnulib/lib/argp-help.c const struct hol_cluster *cl = pest->entry->cluster; cluster 1202 maint/gnulib/lib/argp-help.c || (pe->cluster != cl cluster 1203 maint/gnulib/lib/argp-help.c && !hol_cluster_is_child (pe->cluster, cl)))) cluster 570 tools/crm_resource_print.c pcmk__cluster_option(checks->rsc->cluster->config_hash, cluster 357 tools/crm_resource_runtime.c pcmk__output_t *out = rsc->cluster->priv; cluster 509 tools/crm_resource_runtime.c pcmk__output_t *out = rsc->cluster->priv; cluster 521 tools/crm_resource_runtime.c pcmk__unpack_constraints(rsc->cluster); cluster 522 tools/crm_resource_runtime.c pe__clear_resource_flags_on_all(rsc->cluster, pcmk_rsc_detect_loop); cluster 548 tools/crm_resource_runtime.c pcmk__output_t *out = rsc->cluster->priv;