cluster 635 attrd/legacy.c crm_cluster_t cluster; cluster 673 attrd/legacy.c cluster.destroy = attrd_cs_destroy; cluster 674 attrd/legacy.c cluster.cpg.cpg_deliver_fn = attrd_cs_dispatch; cluster 675 attrd/legacy.c cluster.cpg.cpg_confchg_fn = pcmk_cpg_membership; cluster 681 attrd/legacy.c cluster.hb_conn = NULL; cluster 682 attrd/legacy.c cluster.hb_dispatch = attrd_ha_callback; cluster 683 attrd/legacy.c cluster.destroy = attrd_ha_connection_destroy; cluster 687 attrd/legacy.c if (FALSE == crm_cluster_connect(&cluster)) { cluster 692 attrd/legacy.c attrd_uname = cluster.uname; cluster 693 attrd/legacy.c attrd_uuid = cluster.uuid; cluster 694 attrd/legacy.c attrd_nodeid = cluster.nodeid; cluster 696 attrd/legacy.c attrd_cluster_conn = cluster.hb_conn; cluster 53 crmd/control.c extern gboolean crm_connect_corosync(crm_cluster_t * cluster); cluster 81 crmd/control.c static crm_cluster_t *cluster = NULL; cluster 83 crmd/control.c if (cluster == NULL) { cluster 84 crmd/control.c cluster = calloc(1, sizeof(crm_cluster_t)); cluster 88 crmd/control.c crm_cluster_disconnect(cluster); cluster 100 crmd/control.c registered = crm_connect_corosync(cluster); cluster 104 crmd/control.c cluster->destroy = crmd_ha_connection_destroy; cluster 105 crmd/control.c cluster->hb_dispatch = crmd_ha_msg_callback; cluster 107 crmd/control.c registered = crm_cluster_connect(cluster); cluster 108 crmd/control.c fsa_cluster_conn = cluster->hb_conn; cluster 139 crmd/control.c fsa_election = election_init(NULL, cluster->uname, 60000/*60s*/, election_timeout_popped); cluster 140 crmd/control.c fsa_our_uname = cluster->uname; cluster 141 crmd/control.c fsa_our_uuid = cluster->uuid; cluster 142 crmd/control.c if(cluster->uuid == NULL) { cluster 186 crmd/corosync.c extern gboolean crm_connect_corosync(crm_cluster_t * cluster); cluster 189 crmd/corosync.c crm_connect_corosync(crm_cluster_t * cluster) cluster 195 crmd/corosync.c cluster->cpg.cpg_deliver_fn = crmd_cs_dispatch; cluster 196 crmd/corosync.c cluster->cpg.cpg_confchg_fn = pcmk_cpg_membership; cluster 197 crmd/corosync.c cluster->destroy = crmd_cs_destroy; cluster 199 crmd/corosync.c rc = crm_cluster_connect(cluster); cluster 1292 fencing/main.c crm_cluster_t cluster; cluster 1466 fencing/main.c cluster.hb_conn = NULL; cluster 1467 fencing/main.c cluster.hb_dispatch = stonith_peer_hb_callback; cluster 1468 fencing/main.c cluster.destroy = stonith_peer_hb_destroy; cluster 1473 fencing/main.c cluster.destroy = stonith_peer_cs_destroy; cluster 1474 fencing/main.c cluster.cpg.cpg_deliver_fn = stonith_peer_ais_callback; cluster 1475 fencing/main.c cluster.cpg.cpg_confchg_fn = pcmk_cpg_membership; cluster 1481 fencing/main.c if (crm_cluster_connect(&cluster) == FALSE) { cluster 1485 fencing/main.c stonith_our_uname = cluster.uname; cluster 1486 fencing/main.c stonith_our_uuid = cluster.uuid; cluster 1495 fencing/main.c cluster.hb_conn->llc_ops->set_msg_callback(cluster.hb_conn, T_STONITH_NOTIFY, cluster 1496 fencing/main.c cluster.hb_dispatch, cluster.hb_conn)) { cluster 1497 fencing/main.c crm_crit("Cannot set msg callback %s: %s", T_STONITH_NOTIFY, cluster.hb_conn->llc_ops->errmsg(cluster.hb_conn)); cluster 1501 fencing/main.c cluster.hb_conn->llc_ops->set_msg_callback(cluster.hb_conn, T_STONITH_TIMEOUT_VALUE, cluster 1502 fencing/main.c cluster.hb_dispatch, cluster.hb_conn)) { cluster 1503 fencing/main.c crm_crit("Cannot set msg callback %s: %s", T_STONITH_TIMEOUT_VALUE, cluster.hb_conn->llc_ops->errmsg(cluster.hb_conn)); cluster 1551 fencing/main.c if (cluster.hb_conn) { cluster 1552 fencing/main.c cluster.hb_conn->llc_ops->delete(cluster.hb_conn); cluster 114 include/crm/cluster.h gboolean crm_cluster_connect(crm_cluster_t * cluster); cluster 115 include/crm/cluster.h void crm_cluster_disconnect(crm_cluster_t * cluster); cluster 181 include/crm/cluster.h gboolean cluster_connect_cpg(crm_cluster_t *cluster); cluster 182 include/crm/cluster.h void cluster_disconnect_cpg(crm_cluster_t * cluster); cluster 399 include/crm/cluster/internal.h gboolean register_heartbeat_conn(crm_cluster_t * cluster); cluster 406 include/crm/cluster/internal.h gboolean heartbeat_initialize_nodelist(void *cluster, gboolean force_member, xmlNode * xml_parent); cluster 423 include/crm/cluster/internal.h gboolean corosync_initialize_nodelist(void *cluster, gboolean force_member, xmlNode * xml_parent); cluster 430 include/crm/cluster/internal.h void terminate_cs_connection(crm_cluster_t * cluster); cluster 431 include/crm/cluster/internal.h gboolean init_cs_connection(crm_cluster_t * cluster); cluster 432 include/crm/cluster/internal.h gboolean init_cs_connection_once(crm_cluster_t * cluster); cluster 264 include/crm/compatibility.h attrd_update(crm_ipc_t * cluster, char command, const char *host, const char *name, cluster 267 include/crm/compatibility.h return attrd_update_delegate(cluster, command, host, name, value, section, set, dampen, cluster 316 include/crm/pengine/status.h pe_working_set_t *cluster; cluster 37 lib/cluster/cluster.c CRM_TRACE_INIT_DATA(cluster); cluster 175 lib/cluster/cluster.c crm_cluster_connect(crm_cluster_t * cluster) cluster 183 lib/cluster/cluster.c return init_cs_connection(cluster); cluster 192 lib/cluster/cluster.c if (cluster->hb_conn == NULL) { cluster 197 lib/cluster/cluster.c cluster->hb_conn = (*new_cluster) ("heartbeat"); cluster 202 lib/cluster/cluster.c cluster->hb_conn->llc_ops->signoff(cluster->hb_conn, FALSE); cluster 206 lib/cluster/cluster.c if (heartbeat_cluster && heartbeat_cluster != cluster->hb_conn) { cluster 210 lib/cluster/cluster.c CRM_ASSERT(cluster->hb_conn != NULL); cluster 211 lib/cluster/cluster.c heartbeat_cluster = cluster->hb_conn; cluster 213 lib/cluster/cluster.c rv = register_heartbeat_conn(cluster); cluster 234 lib/cluster/cluster.c crm_cluster_disconnect(crm_cluster_t * cluster) cluster 243 lib/cluster/cluster.c terminate_cs_connection(cluster); cluster 251 lib/cluster/cluster.c if (cluster == NULL) { cluster 255 lib/cluster/cluster.c } else if (cluster->hb_conn) { cluster 256 lib/cluster/cluster.c cluster->hb_conn->llc_ops->signoff(cluster->hb_conn, TRUE); cluster 257 lib/cluster/cluster.c cluster->hb_conn = NULL; cluster 516 lib/cluster/cluster.c const char *cluster = NULL; cluster 523 lib/cluster/cluster.c cluster = getenv("HA_cluster_type"); cluster 527 lib/cluster/cluster.c if(cluster == NULL) { cluster 557 lib/cluster/cluster.c if(cluster == NULL) { cluster 568 lib/cluster/cluster.c crm_info("Verifying cluster type: '%s'", cluster?cluster:"-unspecified-"); cluster 569 lib/cluster/cluster.c if (cluster == NULL) { cluster 572 lib/cluster/cluster.c } else if (safe_str_eq(cluster, "heartbeat")) { cluster 577 lib/cluster/cluster.c } else if (safe_str_eq(cluster, "openais") cluster 578 lib/cluster/cluster.c || safe_str_eq(cluster, "classic openais (with plugin)")) { cluster 581 lib/cluster/cluster.c } else if (safe_str_eq(cluster, "corosync")) { cluster 586 lib/cluster/cluster.c } else if (safe_str_eq(cluster, "cman")) { cluster 601 lib/cluster/cluster.c cluster); cluster 140 lib/cluster/corosync.c terminate_cs_connection(crm_cluster_t *cluster) cluster 144 lib/cluster/corosync.c cluster_disconnect_cpg(cluster); cluster 312 lib/cluster/corosync.c init_cs_connection(crm_cluster_t * cluster) cluster 317 lib/cluster/corosync.c int rc = init_cs_connection_once(cluster); cluster 339 lib/cluster/corosync.c init_cs_connection_once(crm_cluster_t * cluster) cluster 352 lib/cluster/corosync.c if (cluster_connect_cpg(cluster) == FALSE) { cluster 357 lib/cluster/corosync.c cluster->nodeid = get_local_nodeid(0); cluster 358 lib/cluster/corosync.c if(cluster->nodeid == 0) { cluster 363 lib/cluster/corosync.c cluster->uname = get_node_name(0); cluster 364 lib/cluster/corosync.c if(cluster->uname == NULL) { cluster 370 lib/cluster/corosync.c peer = crm_get_peer(cluster->nodeid, cluster->uname); cluster 371 lib/cluster/corosync.c cluster->uuid = get_corosync_uuid(peer); cluster 486 lib/cluster/corosync.c corosync_initialize_nodelist(void *cluster, gboolean force_member, xmlNode * xml_parent) cluster 58 lib/cluster/cpg.c cluster_disconnect_cpg(crm_cluster_t *cluster) cluster 61 lib/cluster/cpg.c if (cluster->cpg_handle) { cluster 63 lib/cluster/cpg.c cpg_leave(cluster->cpg_handle, &cluster->group); cluster 64 lib/cluster/cpg.c cpg_finalize(cluster->cpg_handle); cluster 65 lib/cluster/cpg.c cluster->cpg_handle = 0; cluster 217 lib/cluster/cpg.c crm_cluster_t *cluster = (crm_cluster_t*) user_data; cluster 219 lib/cluster/cpg.c rc = cpg_dispatch(cluster->cpg_handle, CS_DISPATCH_ONE); cluster 222 lib/cluster/cpg.c cluster->cpg_handle = 0; cluster 436 lib/cluster/cpg.c cluster_connect_cpg(crm_cluster_t *cluster) cluster 447 lib/cluster/cpg.c .destroy = cluster->destroy, cluster 451 lib/cluster/cpg.c .cpg_deliver_fn = cluster->cpg.cpg_deliver_fn, cluster 452 lib/cluster/cpg.c .cpg_confchg_fn = cluster->cpg.cpg_confchg_fn, cluster 458 lib/cluster/cpg.c cluster->group.length = 0; cluster 459 lib/cluster/cpg.c cluster->group.value[0] = 0; cluster 462 lib/cluster/cpg.c strncpy(cluster->group.value, crm_system_name?crm_system_name:"unknown", 127); cluster 463 lib/cluster/cpg.c cluster->group.value[127] = 0; cluster 464 lib/cluster/cpg.c cluster->group.length = 1 + QB_MIN(127, strlen(cluster->group.value)); cluster 478 lib/cluster/cpg.c cluster->nodeid = id; cluster 481 lib/cluster/cpg.c cs_repeat(retries, 30, rc = cpg_join(handle, &cluster->group)); cluster 494 lib/cluster/cpg.c cluster->cpg_handle = handle; cluster 495 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); cluster 524 lib/cluster/heartbeat.c register_heartbeat_conn(crm_cluster_t * cluster) cluster 531 lib/cluster/heartbeat.c if (cluster->hb_conn->llc_ops->signon(cluster->hb_conn, crm_system_name) != HA_OK) { cluster 533 lib/cluster/heartbeat.c cluster->hb_conn->llc_ops->errmsg(cluster->hb_conn)); cluster 538 lib/cluster/heartbeat.c cluster->hb_conn->llc_ops->set_msg_callback(cluster->hb_conn, crm_system_name, cluster 539 lib/cluster/heartbeat.c cluster->hb_dispatch, cluster->hb_conn)) { cluster 541 lib/cluster/heartbeat.c crm_err("Cannot set msg callback: %s", cluster->hb_conn->llc_ops->errmsg(cluster->hb_conn)); cluster 553 lib/cluster/heartbeat.c (*g_main_add_cluster) (G_PRIORITY_HIGH, cluster->hb_conn, cluster 554 lib/cluster/heartbeat.c FALSE, ha_msg_dispatch, cluster->hb_conn, cluster->destroy); cluster 558 lib/cluster/heartbeat.c const_uname = cluster->hb_conn->llc_ops->get_mynodeid(cluster->hb_conn); cluster 569 lib/cluster/heartbeat.c cluster->uname = strdup(const_uname); cluster 570 lib/cluster/heartbeat.c cluster->uuid = strdup(const_uuid); cluster 609 lib/cluster/heartbeat.c heartbeat_initialize_nodelist(void *cluster, gboolean force_member, xmlNode * xml_parent) cluster 612 lib/cluster/heartbeat.c ll_cluster_t *conn = cluster; cluster 186 lib/cluster/legacy.c terminate_cs_connection(crm_cluster_t *cluster) cluster 199 lib/cluster/legacy.c cluster_disconnect_cpg(cluster); cluster 293 lib/cluster/legacy.c crm_cluster_t *cluster = (crm_cluster_t *) user_data; cluster 314 lib/cluster/legacy.c if (cluster && cluster->cpg.cpg_deliver_fn) { cluster 315 lib/cluster/legacy.c cluster->cpg.cpg_deliver_fn(0, NULL, 0, 0, buffer, 0); cluster 358 lib/cluster/legacy.c cman_cluster_t cluster; cluster 366 lib/cluster/legacy.c memset(&cluster, 0, sizeof(cluster)); cluster 367 lib/cluster/legacy.c rc = cman_get_cluster(pcmk_cman_handle, &cluster); cluster 373 lib/cluster/legacy.c crm_peer_seq = cluster.ci_generation; cluster 439 lib/cluster/legacy.c cman_cluster_t cluster; cluster 448 lib/cluster/legacy.c memset(&cluster, 0, sizeof(cluster)); cluster 494 lib/cluster/legacy.c init_cs_connection_classic(crm_cluster_t * cluster) cluster 505 lib/cluster/legacy.c .destroy = cluster->destroy, cluster 536 lib/cluster/legacy.c mainloop_add_fd("corosync-plugin", G_PRIORITY_MEDIUM, ais_fd_async, cluster, &ais_fd_callbacks); cluster 544 lib/cluster/legacy.c cluster->nodeid = get_local_nodeid(0); cluster 547 lib/cluster/legacy.c plugin_get_details(NULL, &(cluster->uname)); cluster 548 lib/cluster/legacy.c if (safe_str_neq(name, cluster->uname)) { cluster 550 lib/cluster/legacy.c cluster->uname, name); cluster 557 lib/cluster/legacy.c peer = crm_get_peer(cluster->nodeid, cluster->uname); cluster 603 lib/cluster/legacy.c init_cs_connection(crm_cluster_t * cluster) cluster 613 lib/cluster/legacy.c int rc = init_cs_connection_once(cluster); cluster 622 lib/cluster/legacy.c cluster->destroy, &mcp_callbacks); cluster 679 lib/cluster/legacy.c init_cs_connection_once(crm_cluster_t * cluster) cluster 689 lib/cluster/legacy.c if (init_cs_connection_classic(cluster) == FALSE) { cluster 694 lib/cluster/legacy.c if (cluster_connect_cpg(cluster) == FALSE) { cluster 710 lib/cluster/legacy.c cluster->nodeid = get_local_nodeid(0); cluster 711 lib/cluster/legacy.c if(cluster->nodeid == 0) { cluster 716 lib/cluster/legacy.c cluster->uname = get_node_name(0); cluster 717 lib/cluster/legacy.c if(cluster->uname == NULL) { cluster 723 lib/cluster/legacy.c peer = crm_get_peer(cluster->nodeid, cluster->uname); cluster 724 lib/cluster/legacy.c cluster->uuid = get_corosync_uuid(peer); cluster 496 lib/pengine/complex.c (*rsc)->cluster = data_set; cluster 588 lib/pengine/native.c rsc->cluster->disabled_resources++; cluster 594 lib/pengine/native.c rsc->cluster->disabled_resources++; cluster 601 lib/pengine/native.c rsc->cluster->blocked_resources++; cluster 921 mcp/pacemaker.c static crm_cluster_t cluster; cluster 1105 mcp/pacemaker.c cluster.destroy = mcp_cpg_destroy; cluster 1106 mcp/pacemaker.c cluster.cpg.cpg_deliver_fn = mcp_cpg_deliver; cluster 1107 mcp/pacemaker.c cluster.cpg.cpg_confchg_fn = mcp_cpg_membership; cluster 1111 mcp/pacemaker.c if(cluster_connect_cpg(&cluster) == FALSE) { cluster 1151 mcp/pacemaker.c cluster_disconnect_cpg(&cluster); cluster 587 tools/crm_node.c cman_cluster_t cluster; cluster 591 tools/crm_node.c memset(&cluster, 0, sizeof(cluster)); cluster 819 tools/crm_node.c static crm_cluster_t cluster; cluster 821 tools/crm_node.c cluster.destroy = ais_membership_destroy; cluster 822 tools/crm_node.c cluster.cpg.cpg_deliver_fn = ais_membership_dispatch; cluster 823 tools/crm_node.c cluster.cpg.cpg_confchg_fn = NULL; cluster 825 tools/crm_node.c if (init_cs_connection_once(&cluster)) { cluster 851 tools/crm_node.c printf("%u\n", cluster.nodeid);