cluster 20 daemons/attrd/attrd_elections.c attrd_election_cb(pcmk_cluster_t *cluster) cluster 668 daemons/controld/controld_cib.c controld_globals.cluster->priv->node_name, cluster 29 daemons/controld/controld_control.c extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster); cluster 44 daemons/controld/controld_control.c if (controld_globals.cluster == NULL) { cluster 45 daemons/controld/controld_control.c controld_globals.cluster = pcmk_cluster_new(); cluster 49 daemons/controld/controld_control.c pcmk_cluster_disconnect(controld_globals.cluster); cluster 61 daemons/controld/controld_control.c registered = crm_connect_corosync(controld_globals.cluster); cluster 229 daemons/controld/controld_control.c election_reset(controld_globals.cluster); // Stop any election timer cluster 314 daemons/controld/controld_control.c pcmk_cluster_free(controld_globals.cluster); cluster 315 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 278 daemons/controld/controld_execd.c controld_globals.cluster->priv->node_name); cluster 359 daemons/controld/controld_execd.c if (controld_globals.cluster->priv->node_name == NULL) { cluster 1155 daemons/controld/controld_execd.c target = controld_globals.cluster->priv->node_name; cluster 1744 daemons/controld/controld_execd.c controld_globals.cluster->priv->node_name); cluster 308 daemons/controld/controld_execd_state.c if ((node_name == NULL) && (controld_globals.cluster != NULL)) { cluster 309 daemons/controld/controld_execd_state.c node_name = controld_globals.cluster->priv->node_name; cluster 1008 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 1281 daemons/controld/controld_messages.c host_from = controld_globals.cluster->priv->node_name; cluster 1381 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 559 daemons/fenced/pacemaker-fenced.c pcmk_cluster_t *cluster = NULL; cluster 645 daemons/fenced/pacemaker-fenced.c cluster = pcmk_cluster_new(); cluster 649 daemons/fenced/pacemaker-fenced.c pcmk_cluster_set_destroy_fn(cluster, stonith_peer_cs_destroy); cluster 650 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_deliver_fn(cluster, handle_cpg_message); cluster 651 daemons/fenced/pacemaker-fenced.c pcmk_cpg_set_confchg_fn(cluster, pcmk__cpg_confchg_cb); cluster 657 daemons/fenced/pacemaker-fenced.c if (pcmk_cluster_connect(cluster) != pcmk_rc_ok) { cluster 662 daemons/fenced/pacemaker-fenced.c fenced_set_local_node(cluster->priv->node_name); cluster 685 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 152 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 81 lib/cluster/cluster.c pcmk_cluster_connect(pcmk_cluster_t *cluster) cluster 86 lib/cluster/cluster.c if (cluster == NULL) { cluster 96 lib/cluster/cluster.c return pcmk__corosync_connect(cluster); cluster 116 lib/cluster/cluster.c pcmk_cluster_disconnect(pcmk_cluster_t *cluster) cluster 126 lib/cluster/cluster.c pcmk__corosync_disconnect(cluster); cluster 150 lib/cluster/cluster.c pcmk_cluster_t *cluster = pcmk__assert_alloc(1, sizeof(pcmk_cluster_t)); cluster 152 lib/cluster/cluster.c cluster->priv = pcmk__assert_alloc(1, sizeof(pcmk__cluster_private_t)); cluster 153 lib/cluster/cluster.c cluster->priv->server = pcmk__parse_server(crm_system_name); cluster 154 lib/cluster/cluster.c return cluster; cluster 163 lib/cluster/cluster.c pcmk_cluster_free(pcmk_cluster_t *cluster) cluster 165 lib/cluster/cluster.c if (cluster == NULL) { cluster 168 lib/cluster/cluster.c election_fini(cluster); cluster 169 lib/cluster/cluster.c free(cluster->priv->node_xml_id); cluster 170 lib/cluster/cluster.c free(cluster->priv->node_name); cluster 171 lib/cluster/cluster.c free(cluster->priv); cluster 172 lib/cluster/cluster.c free(cluster); cluster 184 lib/cluster/cluster.c pcmk_cluster_set_destroy_fn(pcmk_cluster_t *cluster, void (*fn)(gpointer)) cluster 186 lib/cluster/cluster.c if (cluster == NULL) { cluster 189 lib/cluster/cluster.c cluster->destroy = fn; cluster 387 lib/cluster/cluster.c const char *cluster = NULL; cluster 394 lib/cluster/cluster.c cluster = pcmk__env_option(PCMK__ENV_CLUSTER_TYPE); cluster 396 lib/cluster/cluster.c if (cluster != NULL) { cluster 397 lib/cluster/cluster.c crm_info("Verifying configured cluster layer '%s'", cluster); cluster 401 lib/cluster/cluster.c if (pcmk__str_eq(cluster, PCMK_VALUE_COROSYNC, pcmk__str_casei)) { cluster 409 lib/cluster/cluster.c cluster); cluster 412 lib/cluster/cluster.c crm_info("Assuming an active '%s' cluster", cluster); cluster 440 lib/cluster/cluster.c crm_cluster_connect(pcmk_cluster_t *cluster) cluster 442 lib/cluster/cluster.c if (cluster == NULL) { cluster 445 lib/cluster/cluster.c if (cluster->priv == NULL) { cluster 449 lib/cluster/cluster.c cluster->priv = pcmk__assert_alloc(1, sizeof(pcmk__cluster_private_t)); cluster 451 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 474 lib/cluster/corosync.c rc = pcmk__cpg_connect(cluster); cluster 481 lib/cluster/corosync.c cluster->priv->node_id = pcmk__cpg_local_nodeid(0); cluster 482 lib/cluster/corosync.c if (cluster->priv->node_id == 0) { cluster 487 lib/cluster/corosync.c cluster->priv->node_name = pcmk__cluster_node_name(0); cluster 488 lib/cluster/corosync.c if (cluster->priv->node_name == NULL) { cluster 494 lib/cluster/corosync.c local_node = pcmk__get_node(cluster->priv->node_id, cluster 495 lib/cluster/corosync.c cluster->priv->node_name, NULL, cluster 498 lib/cluster/corosync.c cluster->priv->node_xml_id = pcmk__corosync_uuid(local_node); cluster 499 lib/cluster/corosync.c CRM_LOG_ASSERT(cluster->priv->node_xml_id != NULL); cluster 275 lib/cluster/cpg.c pcmk_cluster_t *cluster = (pcmk_cluster_t *) user_data; cluster 277 lib/cluster/cpg.c rc = cpg_dispatch(cluster->priv->cpg_handle, CS_DISPATCH_ONE); cluster 281 lib/cluster/cpg.c cpg_finalize(cluster->priv->cpg_handle); cluster 282 lib/cluster/cpg.c cluster->priv->cpg_handle = 0; cluster 744 lib/cluster/cpg.c pcmk_cpg_set_deliver_fn(pcmk_cluster_t *cluster, cpg_deliver_fn_t fn) cluster 746 lib/cluster/cpg.c if (cluster == NULL) { cluster 749 lib/cluster/cpg.c cluster->cpg.cpg_deliver_fn = fn; cluster 762 lib/cluster/cpg.c pcmk_cpg_set_confchg_fn(pcmk_cluster_t *cluster, cpg_confchg_fn_t fn) cluster 764 lib/cluster/cpg.c if (cluster == NULL) { cluster 767 lib/cluster/cpg.c cluster->cpg.cpg_confchg_fn = fn; cluster 779 lib/cluster/cpg.c pcmk__cpg_connect(pcmk_cluster_t *cluster) cluster 795 lib/cluster/cpg.c .destroy = cluster->destroy, cluster 800 lib/cluster/cpg.c .cpg_deliver_fn = cluster->cpg.cpg_deliver_fn, cluster 801 lib/cluster/cpg.c .cpg_confchg_fn = cluster->cpg.cpg_confchg_fn, cluster 808 lib/cluster/cpg.c if (cluster->priv->server != pcmk_ipc_unknown) { cluster 809 lib/cluster/cpg.c cpg_group_name = pcmk__server_message_type(cluster->priv->server); cluster 819 lib/cluster/cpg.c memset(cluster->priv->group.value, 0, 128); cluster 820 lib/cluster/cpg.c strncpy(cluster->priv->group.value, cpg_group_name, 127); cluster 821 lib/cluster/cpg.c cluster->priv->group.length = strlen(cluster->priv->group.value) + 1; cluster 859 lib/cluster/cpg.c cluster->priv->node_id = id; cluster 862 lib/cluster/cpg.c cs_repeat(rc, retries, 30, cpg_join(handle, &cluster->priv->group)); cluster 869 lib/cluster/cpg.c cluster->priv->cpg_handle = handle; cluster 870 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); cluster 891 lib/cluster/cpg.c pcmk__cpg_disconnect(pcmk_cluster_t *cluster) cluster 894 lib/cluster/cpg.c if (cluster->priv->cpg_handle != 0) { cluster 896 lib/cluster/cpg.c cpg_leave(cluster->priv->cpg_handle, &cluster->priv->group); cluster 897 lib/cluster/cpg.c cpg_finalize(cluster->priv->cpg_handle); cluster 898 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 312 lib/cluster/election.c crm_xml_add_int(vote, PCMK__XA_ELECTION_ID, cluster->priv->election->count); cluster 319 lib/cluster/election.c pcmk__cluster_send_message(NULL, cluster->priv->server, vote); cluster 322 lib/cluster/election.c crm_debug("Started election round %u", cluster->priv->election->count); cluster 323 lib/cluster/election.c election_timeout_start(cluster); cluster 344 lib/cluster/election.c election_check(pcmk_cluster_t *cluster) cluster 349 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL), cluster 352 lib/cluster/election.c if (cluster->priv->election->voted == NULL) { cluster 357 lib/cluster/election.c voted_size = g_hash_table_size(cluster->priv->election->voted); cluster 366 lib/cluster/election.c election_timeout_stop(cluster); cluster 380 lib/cluster/election.c g_hash_table_iter_init(&gIter, cluster->priv->election->voted); cluster 388 lib/cluster/election.c election_complete(cluster); cluster 480 lib/cluster/election.c record_vote(pcmk_cluster_t *cluster, struct vote *vote) cluster 484 lib/cluster/election.c if (cluster->priv->election->voted == NULL) { cluster 485 lib/cluster/election.c cluster->priv->election->voted = pcmk__strkey_table(free, free); cluster 487 lib/cluster/election.c pcmk__insert_dup(cluster->priv->election->voted, vote->from, vote->op); cluster 491 lib/cluster/election.c send_no_vote(pcmk_cluster_t *cluster, pcmk__node_status_t *peer, cluster 497 lib/cluster/election.c message_type = pcmk__server_message_type(cluster->priv->server); cluster 498 lib/cluster/election.c novote = pcmk__new_request(cluster->priv->server, message_type, cluster 503 lib/cluster/election.c pcmk__cluster_send_message(peer, cluster->priv->server, novote); cluster 524 lib/cluster/election.c election_count_vote(pcmk_cluster_t *cluster, const xmlNode *message, cluster 537 lib/cluster/election.c CRM_CHECK((cluster != NULL) && (cluster->priv->election != NULL) cluster 538 lib/cluster/election.c && (message != NULL) && (cluster->priv->node_name != NULL), cluster 547 lib/cluster/election.c our_node = pcmk__get_node(0, cluster->priv->node_name, NULL, cluster 563 lib/cluster/election.c && (vote.election_id != cluster->priv->election->count)) { cluster 575 lib/cluster/election.c || pcmk__str_eq(vote.from, cluster->priv->node_name, cluster 587 lib/cluster/election.c if (cluster->priv->election->state != election_in_progress) { cluster 592 lib/cluster/election.c return cluster->priv->election->state; cluster 594 lib/cluster/election.c record_vote(cluster, &vote); cluster 617 lib/cluster/election.c } else if (strcasecmp(cluster->priv->node_name, vote.from) > 0) { cluster 626 lib/cluster/election.c if (cluster->priv->election->expires < tm_now) { cluster 627 lib/cluster/election.c cluster->priv->election->election_wins = 0; cluster 628 lib/cluster/election.c cluster->priv->election->expires = tm_now + STORM_INTERVAL; cluster 636 lib/cluster/election.c cluster->priv->election->election_wins++; cluster 637 lib/cluster/election.c if (cluster->priv->election->election_wins > (peers * peers)) { cluster 639 lib/cluster/election.c cluster->priv->election->election_wins, STORM_INTERVAL); cluster 640 lib/cluster/election.c cluster->priv->election->election_wins = 0; cluster 641 lib/cluster/election.c cluster->priv->election->expires = tm_now + STORM_INTERVAL; cluster 642 lib/cluster/election.c if (!(cluster->priv->election->wrote_blackbox)) { cluster 654 lib/cluster/election.c cluster->priv->election->wrote_blackbox = true; cluster 663 lib/cluster/election.c vote.election_id, vote.op, cluster->priv->election->count, cluster 665 lib/cluster/election.c return cluster->priv->election->state; cluster 681 lib/cluster/election.c if ((cluster->priv->election->last_election_loss == 0) cluster 682 lib/cluster/election.c || ((tm_now - cluster->priv->election->last_election_loss) cluster 691 lib/cluster/election.c cluster->priv->election->last_election_loss = 0; cluster 692 lib/cluster/election.c election_timeout_stop(cluster); cluster 695 lib/cluster/election.c cluster->priv->election->state = election_start; cluster 696 lib/cluster/election.c return cluster->priv->election->state; cluster 700 lib/cluster/election.c loss_time = ctime(&(cluster->priv->election->last_election_loss)); cluster 713 lib/cluster/election.c cluster->priv->election->last_election_loss = tm_now; cluster 721 lib/cluster/election.c election_reset(cluster); cluster 722 lib/cluster/election.c send_no_vote(cluster, your_node, &vote); cluster 723 lib/cluster/election.c cluster->priv->election->state = election_lost; cluster 724 lib/cluster/election.c return cluster->priv->election->state; cluster 734 lib/cluster/election.c election_clear_dampening(pcmk_cluster_t *cluster) cluster 736 lib/cluster/election.c if ((cluster != NULL) && (cluster->priv->election != NULL)) { cluster 737 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);