cluster 20 daemons/attrd/attrd_elections.c attrd_election_cb(pcmk_cluster_t *cluster) cluster 667 daemons/controld/controld_cib.c controld_globals.cluster->priv->node_name, cluster 30 daemons/controld/controld_control.c extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster); cluster 45 daemons/controld/controld_control.c if (controld_globals.cluster == NULL) { cluster 46 daemons/controld/controld_control.c controld_globals.cluster = pcmk_cluster_new(); cluster 50 daemons/controld/controld_control.c pcmk_cluster_disconnect(controld_globals.cluster); cluster 62 daemons/controld/controld_control.c registered = crm_connect_corosync(controld_globals.cluster); cluster 230 daemons/controld/controld_control.c election_reset(controld_globals.cluster); // Stop any election timer cluster 315 daemons/controld/controld_control.c pcmk_cluster_free(controld_globals.cluster); cluster 316 daemons/controld/controld_control.c controld_globals.cluster = NULL; cluster 142 daemons/controld/controld_corosync.c extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster); cluster 145 daemons/controld/controld_corosync.c crm_connect_corosync(pcmk_cluster_t *cluster) cluster 150 daemons/controld/controld_corosync.c pcmk_cluster_set_destroy_fn(cluster, crmd_cs_destroy); cluster 151 daemons/controld/controld_corosync.c pcmk_cpg_set_deliver_fn(cluster, crmd_cs_dispatch); cluster 152 daemons/controld/controld_corosync.c pcmk_cpg_set_confchg_fn(cluster, cpg_membership_callback); cluster 154 daemons/controld/controld_corosync.c if (pcmk_cluster_connect(cluster) == pcmk_rc_ok) { cluster 23 daemons/controld/controld_election.c election_win_cb(pcmk_cluster_t *cluster) cluster 31 daemons/controld/controld_election.c election_init(controld_globals.cluster, election_win_cb); cluster 47 daemons/controld/controld_election.c election_timeout_set_period(controld_globals.cluster, interval_ms); cluster 53 daemons/controld/controld_election.c election_remove(controld_globals.cluster, uname); cluster 59 daemons/controld/controld_election.c election_clear_dampening(controld_globals.cluster); cluster 66 daemons/controld/controld_election.c election_timeout_stop(controld_globals.cluster); cluster 112 daemons/controld/controld_election.c election_vote(controld_globals.cluster); cluster 123 daemons/controld/controld_election.c election_check(controld_globals.cluster); cluster 146 daemons/controld/controld_election.c rc = election_count_vote(controld_globals.cluster, vote->msg, cluster 150 daemons/controld/controld_election.c election_reset(controld_globals.cluster); cluster 215 daemons/controld/controld_election.c election_reset(controld_globals.cluster); cluster 279 daemons/controld/controld_execd.c controld_globals.cluster->priv->node_name); cluster 360 daemons/controld/controld_execd.c if (controld_globals.cluster->priv->node_name == NULL) { cluster 1154 daemons/controld/controld_execd.c target = controld_globals.cluster->priv->node_name; cluster 1743 daemons/controld/controld_execd.c controld_globals.cluster->priv->node_name); cluster 310 daemons/controld/controld_execd_state.c if ((node_name == NULL) && (controld_globals.cluster != NULL)) { cluster 311 daemons/controld/controld_execd_state.c node_name = controld_globals.cluster->priv->node_name; cluster 1019 daemons/controld/controld_fencing.c const char *our_nodename = controld_globals.cluster->priv->node_name; cluster 74 daemons/controld/controld_globals.h pcmk_cluster_t *cluster; cluster 305 daemons/controld/controld_join_client.c update_attrd(controld_globals.cluster->priv->node_name, cluster 344 daemons/controld/controld_join_client.c controld_globals.cluster->priv->node_name, cluster 659 daemons/controld/controld_join_dc.c sync_from = pcmk__str_copy(controld_globals.cluster->priv->node_name); cluster 463 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to, controld_globals.cluster->priv->node_name); cluster 500 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to, controld_globals.cluster->priv->node_name); cluster 944 daemons/controld/controld_messages.c value = controld_globals.cluster->priv->node_name; cluster 1279 daemons/controld/controld_messages.c host_from = controld_globals.cluster->priv->node_name; cluster 1379 daemons/controld/controld_messages.c controld_globals.cluster->priv->node_name); cluster 133 daemons/controld/controld_te_actions.c router_node = controld_globals.cluster->priv->node_name; cluster 32 daemons/controld/controld_utils.c CRM_CHECK(controld_globals.cluster != NULL, return false); cluster 33 daemons/controld/controld_utils.c return pcmk__str_eq(name, controld_globals.cluster->priv->node_name, cluster 46 daemons/controld/controld_utils.c CRM_CHECK(controld_globals.cluster != NULL, return NULL); cluster 47 daemons/controld/controld_utils.c return pcmk__get_node(controld_globals.cluster->priv->node_id, cluster 48 daemons/controld/controld_utils.c controld_globals.cluster->priv->node_name, NULL, cluster 527 daemons/fenced/pacemaker-fenced.c pcmk_cluster_t *cluster = NULL; cluster 613 daemons/fenced/pacemaker-fenced.c cluster = pcmk_cluster_new(); cluster 617 daemons/fenced/pacemaker-fenced.c pcmk_cluster_set_destroy_fn(cluster, stonith_peer_cs_destroy); cluster 618 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_deliver_fn(cluster, stonith_peer_ais_callback); cluster 619 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_confchg_fn(cluster, pcmk__cpg_confchg_cb); cluster 625 daemons/fenced/pacemaker-fenced.c if (pcmk_cluster_connect(cluster) != pcmk_rc_ok) { cluster 630 daemons/fenced/pacemaker-fenced.c fenced_set_local_node(cluster->priv->node_name); cluster 653 daemons/fenced/pacemaker-fenced.c pcmk_cluster_free(cluster); cluster 56 include/crm/cluster.h int pcmk_cluster_connect(pcmk_cluster_t *cluster); cluster 57 include/crm/cluster.h int pcmk_cluster_disconnect(pcmk_cluster_t *cluster); cluster 60 include/crm/cluster.h void pcmk_cluster_free(pcmk_cluster_t *cluster); cluster 62 include/crm/cluster.h int pcmk_cluster_set_destroy_fn(pcmk_cluster_t *cluster, void (*fn)(gpointer)); cluster 64 include/crm/cluster.h int pcmk_cpg_set_deliver_fn(pcmk_cluster_t *cluster, cpg_deliver_fn_t fn); cluster 65 include/crm/cluster.h int pcmk_cpg_set_confchg_fn(pcmk_cluster_t *cluster, cpg_confchg_fn_t fn); cluster 34 include/crm/cluster/compat.h gboolean crm_cluster_connect(pcmk_cluster_t *cluster); cluster 73 include/crm/cluster/election_internal.h void election_reset(pcmk_cluster_t *cluster); cluster 74 include/crm/cluster/election_internal.h void election_init(pcmk_cluster_t *cluster, void (*cb)(pcmk_cluster_t *)); cluster 76 include/crm/cluster/election_internal.h void election_timeout_set_period(pcmk_cluster_t *cluster, guint period_ms); cluster 77 include/crm/cluster/election_internal.h void election_timeout_stop(pcmk_cluster_t *cluster); cluster 79 include/crm/cluster/election_internal.h void election_vote(pcmk_cluster_t *cluster); cluster 80 include/crm/cluster/election_internal.h bool election_check(pcmk_cluster_t *cluster); cluster 81 include/crm/cluster/election_internal.h void election_remove(pcmk_cluster_t *cluster, const char *uname); cluster 82 include/crm/cluster/election_internal.h enum election_result election_state(const pcmk_cluster_t *cluster); cluster 83 include/crm/cluster/election_internal.h enum election_result election_count_vote(pcmk_cluster_t *cluster, cluster 85 include/crm/cluster/election_internal.h void election_clear_dampening(pcmk_cluster_t *cluster); cluster 148 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 78 lib/cluster/cluster.c pcmk_cluster_connect(pcmk_cluster_t *cluster) cluster 83 lib/cluster/cluster.c if (cluster == NULL) { cluster 93 lib/cluster/cluster.c return pcmk__corosync_connect(cluster); cluster 113 lib/cluster/cluster.c pcmk_cluster_disconnect(pcmk_cluster_t *cluster) cluster 123 lib/cluster/cluster.c pcmk__corosync_disconnect(cluster); cluster 147 lib/cluster/cluster.c pcmk_cluster_t *cluster = pcmk__assert_alloc(1, sizeof(pcmk_cluster_t)); cluster 149 lib/cluster/cluster.c cluster->priv = pcmk__assert_alloc(1, sizeof(pcmk__cluster_private_t)); cluster 150 lib/cluster/cluster.c cluster->priv->server = pcmk__parse_server(crm_system_name); cluster 151 lib/cluster/cluster.c return cluster; cluster 160 lib/cluster/cluster.c pcmk_cluster_free(pcmk_cluster_t *cluster) cluster 162 lib/cluster/cluster.c if (cluster == NULL) { cluster 165 lib/cluster/cluster.c election_fini(cluster); cluster 166 lib/cluster/cluster.c free(cluster->priv->node_name); cluster 167 lib/cluster/cluster.c free(cluster->priv); cluster 168 lib/cluster/cluster.c free(cluster); cluster 180 lib/cluster/cluster.c pcmk_cluster_set_destroy_fn(pcmk_cluster_t *cluster, void (*fn)(gpointer)) cluster 182 lib/cluster/cluster.c if (cluster == NULL) { cluster 185 lib/cluster/cluster.c cluster->destroy = fn; cluster 382 lib/cluster/cluster.c const char *cluster = NULL; cluster 389 lib/cluster/cluster.c cluster = pcmk__env_option(PCMK__ENV_CLUSTER_TYPE); cluster 391 lib/cluster/cluster.c if (cluster != NULL) { cluster 392 lib/cluster/cluster.c crm_info("Verifying configured cluster layer '%s'", cluster); cluster 396 lib/cluster/cluster.c if (pcmk__str_eq(cluster, PCMK_VALUE_COROSYNC, pcmk__str_casei)) { cluster 404 lib/cluster/cluster.c cluster); cluster 407 lib/cluster/cluster.c crm_info("Assuming an active '%s' cluster", cluster); cluster 435 lib/cluster/cluster.c crm_cluster_connect(pcmk_cluster_t *cluster) cluster 437 lib/cluster/cluster.c if (cluster == NULL) { cluster 440 lib/cluster/cluster.c if (cluster->priv == NULL) { cluster 444 lib/cluster/cluster.c cluster->priv = pcmk__assert_alloc(1, sizeof(pcmk__cluster_private_t)); cluster 446 lib/cluster/cluster.c return pcmk_cluster_connect(cluster) == pcmk_rc_ok; cluster 223 lib/cluster/corosync.c pcmk__corosync_disconnect(pcmk_cluster_t *cluster) cluster 225 lib/cluster/corosync.c pcmk__cpg_disconnect(cluster); cluster 459 lib/cluster/corosync.c pcmk__corosync_connect(pcmk_cluster_t *cluster) cluster 473 lib/cluster/corosync.c rc = pcmk__cpg_connect(cluster); cluster 480 lib/cluster/corosync.c cluster->priv->node_id = pcmk__cpg_local_nodeid(0); cluster 481 lib/cluster/corosync.c if (cluster->priv->node_id == 0) { cluster 486 lib/cluster/corosync.c cluster->priv->node_name = pcmk__cluster_node_name(0); cluster 487 lib/cluster/corosync.c if (cluster->priv->node_name == NULL) { cluster 493 lib/cluster/corosync.c pcmk__get_node(cluster->priv->node_id, cluster->priv->node_name, NULL, cluster 276 lib/cluster/cpg.c pcmk_cluster_t *cluster = (pcmk_cluster_t *) user_data; cluster 278 lib/cluster/cpg.c rc = cpg_dispatch(cluster->priv->cpg_handle, CS_DISPATCH_ONE); cluster 282 lib/cluster/cpg.c cpg_finalize(cluster->priv->cpg_handle); cluster 283 lib/cluster/cpg.c cluster->priv->cpg_handle = 0; cluster 746 lib/cluster/cpg.c pcmk_cpg_set_deliver_fn(pcmk_cluster_t *cluster, cpg_deliver_fn_t fn) cluster 748 lib/cluster/cpg.c if (cluster == NULL) { cluster 751 lib/cluster/cpg.c cluster->cpg.cpg_deliver_fn = fn; cluster 764 lib/cluster/cpg.c pcmk_cpg_set_confchg_fn(pcmk_cluster_t *cluster, cpg_confchg_fn_t fn) cluster 766 lib/cluster/cpg.c if (cluster == NULL) { cluster 769 lib/cluster/cpg.c cluster->cpg.cpg_confchg_fn = fn; cluster 781 lib/cluster/cpg.c pcmk__cpg_connect(pcmk_cluster_t *cluster) cluster 797 lib/cluster/cpg.c .destroy = cluster->destroy, cluster 802 lib/cluster/cpg.c .cpg_deliver_fn = cluster->cpg.cpg_deliver_fn, cluster 803 lib/cluster/cpg.c .cpg_confchg_fn = cluster->cpg.cpg_confchg_fn, cluster 810 lib/cluster/cpg.c cpg_group_name = pcmk__server_message_type(cluster->priv->server); cluster 818 lib/cluster/cpg.c memset(cluster->priv->group.value, 0, 128); cluster 819 lib/cluster/cpg.c strncpy(cluster->priv->group.value, cpg_group_name, 127); cluster 820 lib/cluster/cpg.c cluster->priv->group.length = strlen(cluster->priv->group.value) + 1; cluster 858 lib/cluster/cpg.c cluster->priv->node_id = id; cluster 861 lib/cluster/cpg.c cs_repeat(rc, retries, 30, cpg_join(handle, &cluster->priv->group)); cluster 868 lib/cluster/cpg.c cluster->priv->cpg_handle = handle; cluster 869 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); cluster 890 lib/cluster/cpg.c pcmk__cpg_disconnect(pcmk_cluster_t *cluster) cluster 893 lib/cluster/cpg.c if (cluster->priv->cpg_handle != 0) { cluster 895 lib/cluster/cpg.c cpg_leave(cluster->priv->cpg_handle, &cluster->priv->group); cluster 896 lib/cluster/cpg.c cpg_finalize(cluster->priv->cpg_handle); cluster 897 lib/cluster/cpg.c cluster->priv->cpg_handle = 0; cluster 38 lib/cluster/crmcluster_private.h void election_fini(pcmk_cluster_t *cluster); cluster 56 lib/cluster/crmcluster_private.h int pcmk__corosync_connect(pcmk_cluster_t *cluster); cluster 59 lib/cluster/crmcluster_private.h void pcmk__corosync_disconnect(pcmk_cluster_t *cluster); cluster 65 lib/cluster/crmcluster_private.h int pcmk__cpg_connect(pcmk_cluster_t *cluster); cluster 68 lib/cluster/crmcluster_private.h void pcmk__cpg_disconnect(pcmk_cluster_t *cluster); cluster 38 lib/cluster/election.c election_complete(pcmk_cluster_t *cluster) cluster 40 lib/cluster/election.c pcmk__assert((cluster != NULL) && (cluster->priv->election != NULL)); cluster 41 lib/cluster/election.c cluster->priv->election->state = election_won; cluster 42 lib/cluster/election.c if (cluster->priv->election->cb != NULL) { cluster 43 lib/cluster/election.c cluster->priv->election->cb(cluster); cluster 45 lib/cluster/election.c election_reset(cluster); cluster 51 lib/cluster/election.c pcmk_cluster_t *cluster = user_data; cluster 54 lib/cluster/election.c election_complete(cluster); cluster 67 lib/cluster/election.c election_state(const pcmk_cluster_t *cluster) cluster 69 lib/cluster/election.c if ((cluster == NULL) || (cluster->priv->election == NULL)) { cluster 72 lib/cluster/election.c return cluster->priv->election->state; cluster 92 lib/cluster/election.c election_init(pcmk_cluster_t *cluster, void (*cb)(pcmk_cluster_t *)) cluster 96 lib/cluster/election.c CRM_CHECK(cluster->priv->election == NULL, return); cluster 98 lib/cluster/election.c cluster->priv->election = pcmk__assert_alloc(1, sizeof(pcmk__election_t)); cluster 99 lib/cluster/election.c cluster->priv->election->cb = cb; cluster 100 lib/cluster/election.c cluster->priv->election->timeout = mainloop_timer_add(name, cluster 104 lib/cluster/election.c cluster); cluster 118 lib/cluster/election.c election_remove(pcmk_cluster_t *cluster, const char *uname) cluster 120 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL) cluster 121 lib/cluster/election.c && (uname != NULL) && (cluster->priv->election->voted != NULL)) { cluster 123 lib/cluster/election.c g_hash_table_remove(cluster->priv->election->voted, uname); cluster 134 lib/cluster/election.c election_reset(pcmk_cluster_t *cluster) cluster 136 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL)) { cluster 138 lib/cluster/election.c mainloop_timer_stop(cluster->priv->election->timeout); cluster 139 lib/cluster/election.c if (cluster->priv->election->voted != NULL) { cluster 140 lib/cluster/election.c g_hash_table_destroy(cluster->priv->election->voted); cluster 141 lib/cluster/election.c cluster->priv->election->voted = NULL; cluster 156 lib/cluster/election.c election_fini(pcmk_cluster_t *cluster) cluster 158 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL)) { cluster 159 lib/cluster/election.c election_reset(cluster); cluster 161 lib/cluster/election.c mainloop_timer_del(cluster->priv->election->timeout); cluster 162 lib/cluster/election.c free(cluster->priv->election); cluster 163 lib/cluster/election.c cluster->priv->election = NULL; cluster 168 lib/cluster/election.c election_timeout_start(pcmk_cluster_t *cluster) cluster 170 lib/cluster/election.c mainloop_timer_start(cluster->priv->election->timeout); cluster 180 lib/cluster/election.c election_timeout_stop(pcmk_cluster_t *cluster) cluster 182 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL)) { cluster 183 lib/cluster/election.c mainloop_timer_stop(cluster->priv->election->timeout); cluster 195 lib/cluster/election.c election_timeout_set_period(pcmk_cluster_t *cluster, guint period) cluster 197 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL), return); cluster 198 lib/cluster/election.c mainloop_timer_set_period(cluster->priv->election->timeout, period); cluster 278 lib/cluster/election.c election_vote(pcmk_cluster_t *cluster) cluster 285 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL), return); cluster 287 lib/cluster/election.c if (cluster->priv->node_name == NULL) { cluster 292 lib/cluster/election.c our_node = pcmk__get_node(0, cluster->priv->node_name, NULL, cluster 299 lib/cluster/election.c election_reset(cluster); cluster 300 lib/cluster/election.c cluster->priv->election->state = election_in_progress; cluster 301 lib/cluster/election.c message_type = pcmk__server_message_type(cluster->priv->server); cluster 306 lib/cluster/election.c vote = pcmk__new_request(cluster->priv->server, message_type, cluster 309 lib/cluster/election.c cluster->priv->election->count++; cluster 311 lib/cluster/election.c crm_xml_add_int(vote, PCMK__XA_ELECTION_ID, cluster->priv->election->count); cluster 318 lib/cluster/election.c pcmk__cluster_send_message(NULL, cluster->priv->server, vote); cluster 321 lib/cluster/election.c crm_debug("Started election round %u", cluster->priv->election->count); cluster 322 lib/cluster/election.c election_timeout_start(cluster); cluster 343 lib/cluster/election.c election_check(pcmk_cluster_t *cluster) cluster 348 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL), cluster 351 lib/cluster/election.c if (cluster->priv->election->voted == NULL) { cluster 356 lib/cluster/election.c voted_size = g_hash_table_size(cluster->priv->election->voted); cluster 365 lib/cluster/election.c election_timeout_stop(cluster); cluster 379 lib/cluster/election.c g_hash_table_iter_init(&gIter, cluster->priv->election->voted); cluster 387 lib/cluster/election.c election_complete(cluster); cluster 479 lib/cluster/election.c record_vote(pcmk_cluster_t *cluster, struct vote *vote) cluster 483 lib/cluster/election.c if (cluster->priv->election->voted == NULL) { cluster 484 lib/cluster/election.c cluster->priv->election->voted = pcmk__strkey_table(free, free); cluster 486 lib/cluster/election.c pcmk__insert_dup(cluster->priv->election->voted, vote->from, vote->op); cluster 490 lib/cluster/election.c send_no_vote(pcmk_cluster_t *cluster, pcmk__node_status_t *peer, cluster 496 lib/cluster/election.c message_type = pcmk__server_message_type(cluster->priv->server); cluster 497 lib/cluster/election.c novote = pcmk__new_request(cluster->priv->server, message_type, cluster 502 lib/cluster/election.c pcmk__cluster_send_message(peer, cluster->priv->server, novote); cluster 523 lib/cluster/election.c election_count_vote(pcmk_cluster_t *cluster, const xmlNode *message, cluster 536 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL) cluster 537 lib/cluster/election.c && (message != NULL) && (cluster->priv->node_name != NULL), cluster 546 lib/cluster/election.c our_node = pcmk__get_node(0, cluster->priv->node_name, NULL, cluster 562 lib/cluster/election.c && (vote.election_id != cluster->priv->election->count)) { cluster 574 lib/cluster/election.c || pcmk__str_eq(vote.from, cluster->priv->node_name, cluster 586 lib/cluster/election.c if (cluster->priv->election->state != election_in_progress) { cluster 591 lib/cluster/election.c return cluster->priv->election->state; cluster 593 lib/cluster/election.c record_vote(cluster, &vote); cluster 616 lib/cluster/election.c } else if (strcasecmp(cluster->priv->node_name, vote.from) > 0) { cluster 625 lib/cluster/election.c if (cluster->priv->election->expires < tm_now) { cluster 626 lib/cluster/election.c cluster->priv->election->election_wins = 0; cluster 627 lib/cluster/election.c cluster->priv->election->expires = tm_now + STORM_INTERVAL; cluster 635 lib/cluster/election.c cluster->priv->election->election_wins++; cluster 636 lib/cluster/election.c if (cluster->priv->election->election_wins > (peers * peers)) { cluster 638 lib/cluster/election.c cluster->priv->election->election_wins, STORM_INTERVAL); cluster 639 lib/cluster/election.c cluster->priv->election->election_wins = 0; cluster 640 lib/cluster/election.c cluster->priv->election->expires = tm_now + STORM_INTERVAL; cluster 641 lib/cluster/election.c if (!(cluster->priv->election->wrote_blackbox)) { cluster 653 lib/cluster/election.c cluster->priv->election->wrote_blackbox = true; cluster 662 lib/cluster/election.c vote.election_id, vote.op, cluster->priv->election->count, cluster 664 lib/cluster/election.c return cluster->priv->election->state; cluster 680 lib/cluster/election.c if ((cluster->priv->election->last_election_loss == 0) cluster 681 lib/cluster/election.c || ((tm_now - cluster->priv->election->last_election_loss) cluster 690 lib/cluster/election.c cluster->priv->election->last_election_loss = 0; cluster 691 lib/cluster/election.c election_timeout_stop(cluster); cluster 694 lib/cluster/election.c cluster->priv->election->state = election_start; cluster 695 lib/cluster/election.c return cluster->priv->election->state; cluster 699 lib/cluster/election.c loss_time = ctime(&(cluster->priv->election->last_election_loss)); cluster 712 lib/cluster/election.c cluster->priv->election->last_election_loss = tm_now; cluster 720 lib/cluster/election.c election_reset(cluster); cluster 721 lib/cluster/election.c send_no_vote(cluster, your_node, &vote); cluster 722 lib/cluster/election.c cluster->priv->election->state = election_lost; cluster 723 lib/cluster/election.c return cluster->priv->election->state; cluster 733 lib/cluster/election.c election_clear_dampening(pcmk_cluster_t *cluster) cluster 735 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL)) { cluster 736 lib/cluster/election.c cluster->priv->election->last_election_loss = 0; 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 216 lib/pacemaker/pcmk_graph_consumer.c pcmk__assert((fns != NULL) && (fns->rsc != NULL) && (fns->cluster != NULL) cluster 317 lib/pacemaker/pcmk_graph_consumer.c return graph_fns->cluster(graph, action);