peer 54 daemons/attrd/attrd_commands.c void attrd_current_only_attribute_update(crm_node_t *peer, xmlNode *xml); peer 55 daemons/attrd/attrd_commands.c void attrd_peer_update(crm_node_t *peer, xmlNode *xml, const char *host, bool filter); peer 56 daemons/attrd/attrd_commands.c void attrd_peer_sync(crm_node_t *peer, xmlNode *xml); peer 108 daemons/attrd/attrd_commands.c gboolean is_private, const char *peer, uint32_t peerid, const char *value, gboolean is_force_write) peer 116 daemons/attrd/attrd_commands.c crm_xml_add(xml, PCMK__XA_ATTR_NODE_NAME, peer); peer 516 daemons/attrd/attrd_commands.c attrd_peer_clear_failure(crm_node_t *peer, xmlNode *xml) peer 546 daemons/attrd/attrd_commands.c attrd_peer_update(peer, xml, host, FALSE); peer 572 daemons/attrd/attrd_commands.c attrd_peer_message(crm_node_t *peer, xmlNode *xml) peer 580 daemons/attrd/attrd_commands.c attrd_handle_election_op(peer, xml); peer 592 daemons/attrd/attrd_commands.c peer_won = attrd_check_for_new_writer(peer, xml); peer 596 daemons/attrd/attrd_commands.c attrd_peer_update(peer, xml, host, FALSE); peer 599 daemons/attrd/attrd_commands.c attrd_peer_sync(peer, xml); peer 602 daemons/attrd/attrd_commands.c attrd_peer_remove(host, TRUE, peer->uname); peer 608 daemons/attrd/attrd_commands.c attrd_peer_clear_failure(peer, xml); peer 611 daemons/attrd/attrd_commands.c && !pcmk__str_eq(peer->uname, attrd_cluster->uname, pcmk__str_casei)) { peer 614 daemons/attrd/attrd_commands.c crm_info("Processing %s from %s", op, peer->uname); peer 624 daemons/attrd/attrd_commands.c attrd_peer_update(peer, child, host, TRUE); peer 629 daemons/attrd/attrd_commands.c attrd_current_only_attribute_update(peer, xml); peer 635 daemons/attrd/attrd_commands.c attrd_peer_sync(crm_node_t *peer, xmlNode *xml) peer 650 daemons/attrd/attrd_commands.c crm_debug("Syncing %s[%s] = %s to %s", a->id, v->nodename, v->current, peer?peer->uname:"everyone"); peer 656 daemons/attrd/attrd_commands.c crm_debug("Syncing values to %s", peer?peer->uname:"everyone"); peer 657 daemons/attrd/attrd_commands.c send_attrd_message(peer, sync); peer 736 daemons/attrd/attrd_commands.c attrd_current_only_attribute_update(crm_node_t *peer, xmlNode *xml) peer 772 daemons/attrd/attrd_commands.c attrd_peer_update(crm_node_t *peer, xmlNode *xml, const char *host, bool filter) peer 854 daemons/attrd/attrd_commands.c attrd_peer_update(peer, xml, host, filter); peer 869 daemons/attrd/attrd_commands.c attr, host, v->current, value, peer->uname); peer 884 daemons/attrd/attrd_commands.c attr, host, v->current? v->current : "(unset)", value? value : "(unset)", peer->uname); peer 901 daemons/attrd/attrd_commands.c crm_trace("Unchanged %s[%s] from %s is %s(Set the forced write flag)", attr, host, peer->uname, value); peer 904 daemons/attrd/attrd_commands.c crm_trace("Unchanged %s[%s] from %s is %s", attr, host, peer->uname, value); peer 951 daemons/attrd/attrd_commands.c attrd_peer_change_cb(enum crm_status_type kind, crm_node_t *peer, const void *data) peer 960 daemons/attrd/attrd_commands.c if (!pcmk_is_set(peer->processes, crm_get_cluster_proc())) { peer 966 daemons/attrd/attrd_commands.c if (pcmk__str_eq(peer->state, CRM_NODE_MEMBER, pcmk__str_casei)) { peer 971 daemons/attrd/attrd_commands.c && !pcmk_is_set(peer->flags, crm_remote_node)) { peer 972 daemons/attrd/attrd_commands.c attrd_peer_sync(peer, NULL); peer 976 daemons/attrd/attrd_commands.c attrd_peer_remove(peer->uname, FALSE, "loss"); peer 984 daemons/attrd/attrd_commands.c attrd_remove_voter(peer); peer 993 daemons/attrd/attrd_commands.c const char *peer = NULL; peer 1033 daemons/attrd/attrd_commands.c while (g_hash_table_iter_next(&iter, (gpointer *) & peer, (gpointer *) & v)) { peer 1034 daemons/attrd/attrd_commands.c do_crm_log(level, "* %s[%s]=%s", a->id, peer, v->requested); peer 1235 daemons/attrd/attrd_commands.c crm_node_t *peer = crm_get_peer_full(v->nodeid, v->nodename, CRM_GET_PEER_ANY); peer 1238 daemons/attrd/attrd_commands.c if (peer == NULL) { peer 1245 daemons/attrd/attrd_commands.c if (peer->id && (v->nodeid == 0)) { peer 1246 daemons/attrd/attrd_commands.c crm_trace("Learned ID %u for node %s", peer->id, v->nodename); peer 1247 daemons/attrd/attrd_commands.c v->nodeid = peer->id; peer 1257 daemons/attrd/attrd_commands.c if (peer->uuid == NULL) { peer 1268 daemons/attrd/attrd_commands.c peer->uname, peer->uuid, peer->id, v->nodeid); peer 1269 daemons/attrd/attrd_commands.c build_update_element(xml_top, a, peer->uuid, v->current); peer 50 daemons/attrd/attrd_elections.c attrd_handle_election_op(const crm_node_t *peer, xmlNode *xml) peer 55 daemons/attrd/attrd_elections.c crm_xml_add(xml, F_CRM_HOST_FROM, peer->uname); peer 83 daemons/attrd/attrd_elections.c peer_writer = strdup(peer->uname); peer 94 daemons/attrd/attrd_elections.c crm_info("Ignoring election op from %s due to error", peer->uname); peer 100 daemons/attrd/attrd_elections.c attrd_check_for_new_writer(const crm_node_t *peer, const xmlNode *xml) peer 107 daemons/attrd/attrd_elections.c && !pcmk__str_eq(peer->uname, attrd_cluster->uname, pcmk__str_casei)) { peer 109 daemons/attrd/attrd_elections.c peer->uname); peer 112 daemons/attrd/attrd_elections.c } else if (!pcmk__str_eq(peer->uname, peer_writer, pcmk__str_casei)) { peer 114 daemons/attrd/attrd_elections.c peer->uname, (peer_writer? peer_writer : "unset")); peer 116 daemons/attrd/attrd_elections.c peer_writer = strdup(peer->uname); peer 132 daemons/attrd/attrd_elections.c attrd_remove_voter(const crm_node_t *peer) peer 134 daemons/attrd/attrd_elections.c election_remove(writer, peer->uname); peer 135 daemons/attrd/attrd_elections.c if (peer_writer && pcmk__str_eq(peer->uname, peer_writer, pcmk__str_casei)) { peer 138 daemons/attrd/attrd_elections.c crm_notice("Lost attribute writer %s", peer->uname); peer 61 daemons/attrd/pacemaker-attrd.c crm_node_t *peer = crm_get_peer(nodeid, from); peer 63 daemons/attrd/pacemaker-attrd.c attrd_peer_message(peer, xml); peer 76 daemons/attrd/pacemaker-attrd.h void attrd_handle_election_op(const crm_node_t *peer, xmlNode *xml); peer 77 daemons/attrd/pacemaker-attrd.h bool attrd_check_for_new_writer(const crm_node_t *peer, const xmlNode *xml); peer 79 daemons/attrd/pacemaker-attrd.h void attrd_remove_voter(const crm_node_t *peer); peer 133 daemons/attrd/pacemaker-attrd.h void attrd_peer_change_cb(enum crm_status_type type, crm_node_t *peer, const void *data); peer 40 daemons/controld/controld_corosync.c crm_node_t *peer = NULL; peer 52 daemons/controld/controld_corosync.c peer = crm_get_peer(0, from); peer 53 daemons/controld/controld_corosync.c if (!pcmk_is_set(peer->processes, crm_proc_cpg)) { peer 58 daemons/controld/controld_corosync.c peer->uname, peer->id); peer 59 daemons/controld/controld_corosync.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 818 daemons/controld/controld_execd.c crm_node_t *peer = NULL; peer 820 daemons/controld/controld_execd.c peer = crm_get_peer_full(0, lrm_state->node_name, CRM_GET_PEER_ANY); peer 821 daemons/controld/controld_execd.c CRM_CHECK(peer != NULL, return NULL); peer 823 daemons/controld/controld_execd.c xml_state = create_node_state_update(peer, update_flags, NULL, peer 830 daemons/controld/controld_execd.c crm_xml_add(xml_data, XML_ATTR_ID, peer->uuid); peer 2084 daemons/controld/controld_execd.c crm_node_t *peer = NULL; peer 2095 daemons/controld/controld_execd.c peer = crm_get_peer(0, fsa_our_uname); peer 2096 daemons/controld/controld_execd.c update = create_node_state_update(peer, node_update_none, NULL, peer 176 daemons/controld/controld_fencing.c crm_node_t *peer = NULL; peer 191 daemons/controld/controld_fencing.c peer = crm_get_peer_full(0, target, CRM_GET_PEER_ANY); peer 193 daemons/controld/controld_fencing.c CRM_CHECK(peer != NULL, return); peer 195 daemons/controld/controld_fencing.c if (peer->state == NULL) { peer 203 daemons/controld/controld_fencing.c if (peer->uuid == NULL) { peer 205 daemons/controld/controld_fencing.c peer->uuid = strdup(uuid); peer 208 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 211 daemons/controld/controld_fencing.c node_state = create_node_state_update(peer, flags, NULL, __func__); peer 214 daemons/controld/controld_fencing.c if (peer->flags & crm_remote_node) { peer 234 daemons/controld/controld_fencing.c controld_delete_node_state(peer->uname, controld_section_all, peer 514 daemons/controld/controld_fencing.c crm_node_t *peer = crm_find_known_peer_full(0, st_event->target, CRM_GET_PEER_ANY); peer 520 daemons/controld/controld_fencing.c if (peer == NULL) { peer 524 daemons/controld/controld_fencing.c uuid = crm_peer_uuid(peer); peer 551 daemons/controld/controld_fencing.c && !pcmk_is_set(peer->flags, crm_remote_node)) { peer 571 daemons/controld/controld_fencing.c if (pcmk_is_set(peer->flags, crm_remote_node)) { peer 575 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 74 daemons/controld/controld_join_dc.c crm_node_t *peer = NULL; peer 79 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 80 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_none); peer 541 daemons/controld/controld_join_dc.c crm_node_t *peer = NULL; peer 565 daemons/controld/controld_join_dc.c peer = crm_get_peer(0, join_from); peer 566 daemons/controld/controld_join_dc.c if (peer->join != crm_join_finalized) { peer 569 daemons/controld/controld_join_dc.c join_id, join_from, crm_join_phase_str(peer->join), peer 578 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_nack); peer 582 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_confirmed); peer 751 daemons/controld/controld_join_dc.c crm_node_t *peer; peer 755 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 756 daemons/controld/controld_join_dc.c if(peer->join == phase) { peer 765 daemons/controld/controld_join_dc.c crm_node_t *peer; peer 769 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 770 daemons/controld/controld_join_dc.c do_crm_log(level, "join-%d: %s=%s", current_join_id, peer->uname, peer 771 daemons/controld/controld_join_dc.c crm_join_phase_str(peer->join)); peer 145 daemons/controld/controld_te_actions.c crm_node_t *peer = crm_get_peer(0, router_node); peer 146 daemons/controld/controld_te_actions.c crm_update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 392 daemons/controld/controld_te_actions.c struct te_peer_s *peer = p; peer 394 daemons/controld/controld_te_actions.c free(peer->name); peer 395 daemons/controld/controld_te_actions.c free(peer); peer 401 daemons/controld/controld_te_actions.c struct te_peer_s *peer = NULL; peer 408 daemons/controld/controld_te_actions.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & peer)) { peer 409 daemons/controld/controld_te_actions.c peer->jobs = 0; peer 410 daemons/controld/controld_te_actions.c peer->migrate_jobs = 0; peer 756 daemons/controld/controld_utils.c void crmd_peer_down(crm_node_t *peer, bool full) peer 758 daemons/controld/controld_utils.c if(full && peer->state == NULL) { peer 759 daemons/controld/controld_utils.c crm_update_peer_state(__func__, peer, CRM_NODE_LOST, 0); peer 760 daemons/controld/controld_utils.c crm_update_peer_proc(__func__, peer, crm_proc_none, NULL); peer 762 daemons/controld/controld_utils.c crm_update_peer_join(__func__, peer, crm_join_none); peer 763 daemons/controld/controld_utils.c crm_update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 95 daemons/controld/controld_utils.h void crmd_peer_down(crm_node_t *peer, bool full); peer 2423 daemons/fenced/fenced_commands.c bool fencing_peer_active(crm_node_t *peer) peer 2425 daemons/fenced/fenced_commands.c if (peer == NULL) { peer 2427 daemons/fenced/fenced_commands.c } else if (peer->uname == NULL) { peer 2429 daemons/fenced/fenced_commands.c } else if (pcmk_is_set(peer->processes, crm_get_cluster_proc())) { peer 79 daemons/fenced/fenced_remote.c void call_remote_stonith(remote_fencing_op_t * op, st_query_result_t * peer, int rc); peer 153 daemons/fenced/fenced_remote.c count_peer_devices(const remote_fencing_op_t *op, const st_query_result_t *peer, peer 161 daemons/fenced/fenced_remote.c if (peer) { peer 162 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, count_peer_device, &data); peer 178 daemons/fenced/fenced_remote.c find_peer_device(const remote_fencing_op_t *op, const st_query_result_t *peer, peer 181 daemons/fenced/fenced_remote.c device_properties_t *props = g_hash_table_lookup(peer->devices, device); peer 199 daemons/fenced/fenced_remote.c grab_peer_device(const remote_fencing_op_t *op, st_query_result_t *peer, peer 202 daemons/fenced/fenced_remote.c device_properties_t *props = find_peer_device(op, peer, device); peer 209 daemons/fenced/fenced_remote.c device, peer->host, count_peer_devices(op, peer, FALSE)); peer 885 daemons/fenced/fenced_remote.c crm_node_t *peer = NULL; peer 906 daemons/fenced/fenced_remote.c peer = crm_get_peer(0, other->originator); peer 907 daemons/fenced/fenced_remote.c if(fencing_peer_active(peer) == FALSE) { peer 986 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer) peer 997 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1015 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1061 daemons/fenced/fenced_remote.c (peer && dev)? "Recorded" : "Generated", op->id, op->action, peer 1193 daemons/fenced/fenced_remote.c st_query_result_t *peer = iter->data; peer 1196 daemons/fenced/fenced_remote.c peer->host, op->target, peer->ndevices, peer->tried, options); peer 1197 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_SKIP_TARGET) && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1200 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_TARGET_ONLY) && !pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1206 daemons/fenced/fenced_remote.c if (grab_peer_device(op, peer, device, verified_devices_only)) { peer 1207 daemons/fenced/fenced_remote.c return peer; peer 1210 daemons/fenced/fenced_remote.c } else if ((peer->tried == FALSE) peer 1211 daemons/fenced/fenced_remote.c && count_peer_devices(op, peer, verified_devices_only)) { peer 1215 daemons/fenced/fenced_remote.c return peer; peer 1226 daemons/fenced/fenced_remote.c st_query_result_t *peer = NULL; peer 1240 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET|FIND_PEER_VERIFIED_ONLY); peer 1241 daemons/fenced/fenced_remote.c if (peer) { peer 1242 daemons/fenced/fenced_remote.c crm_trace("Found verified peer %s for %s", peer->host, device?device:"<any>"); peer 1243 daemons/fenced/fenced_remote.c return peer; peer 1252 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET); peer 1253 daemons/fenced/fenced_remote.c if (peer) { peer 1254 daemons/fenced/fenced_remote.c crm_trace("Found best unverified peer %s", peer->host); peer 1255 daemons/fenced/fenced_remote.c return peer; peer 1262 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_TARGET_ONLY); peer 1263 daemons/fenced/fenced_remote.c if (peer) { peer 1264 daemons/fenced/fenced_remote.c crm_trace("%s will fence itself", peer->host); peer 1265 daemons/fenced/fenced_remote.c return peer; peer 1282 daemons/fenced/fenced_remote.c get_device_timeout(const remote_fencing_op_t *op, const st_query_result_t *peer, peer 1287 daemons/fenced/fenced_remote.c if (!peer || !device) { peer 1291 daemons/fenced/fenced_remote.c props = g_hash_table_lookup(peer->devices, device); peer 1303 daemons/fenced/fenced_remote.c const st_query_result_t *peer; peer 1325 daemons/fenced/fenced_remote.c timeout->peer, device_id); peer 1330 daemons/fenced/fenced_remote.c get_peer_timeout(const remote_fencing_op_t *op, const st_query_result_t *peer) peer 1335 daemons/fenced/fenced_remote.c timeout.peer = peer; peer 1338 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, add_device_timeout, &timeout); peer 1368 daemons/fenced/fenced_remote.c const st_query_result_t *peer = iter->data; peer 1370 daemons/fenced/fenced_remote.c if (find_peer_device(op, peer, device_list->data)) { peer 1371 daemons/fenced/fenced_remote.c total_timeout += get_device_timeout(op, peer, peer 1500 daemons/fenced/fenced_remote.c call_remote_stonith(remote_fencing_op_t * op, st_query_result_t * peer, int rc) peer 1506 daemons/fenced/fenced_remote.c if ((peer == NULL) && !pcmk_is_set(op->call_options, st_opt_topology)) { peer 1507 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1511 daemons/fenced/fenced_remote.c int total_timeout = get_op_total_timeout(op, peer); peer 1525 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1528 daemons/fenced/fenced_remote.c timeout = get_device_timeout(op, peer, device); peer 1531 daemons/fenced/fenced_remote.c if (peer) { peer 1547 daemons/fenced/fenced_remote.c get_device_timeout(op, peer, device); peer 1550 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, device, peer 1556 daemons/fenced/fenced_remote.c timeout_one = TIMEOUT_MULTIPLY_FACTOR * get_peer_timeout(op, peer); peer 1559 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, op->client_name, peer 1577 daemons/fenced/fenced_remote.c && pcmk__str_eq(peer->host, op->target, pcmk__str_casei) peer 1589 daemons/fenced/fenced_remote.c send_cluster_message(crm_get_peer(0, peer->host), crm_msg_stonith_ng, remote_op, FALSE); peer 1590 daemons/fenced/fenced_remote.c peer->tried = TRUE; peer 1708 daemons/fenced/fenced_remote.c st_query_result_t *peer = iter->data; peer 1710 daemons/fenced/fenced_remote.c if (skip_target && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1713 daemons/fenced/fenced_remote.c match = find_peer_device(op, peer, device->data); peer 1736 daemons/fenced/fenced_remote.c parse_action_specific(xmlNode *xml, const char *peer, const char *device, peer 1745 daemons/fenced/fenced_remote.c peer, device, action, props->custom_action_timeout[phase]); peer 1752 daemons/fenced/fenced_remote.c peer, device, props->delay_max[phase], action); peer 1759 daemons/fenced/fenced_remote.c peer, device, props->delay_base[phase], action); peer 1769 daemons/fenced/fenced_remote.c peer, device, action); peer 1780 daemons/fenced/fenced_remote.c peer, action, device); peer 250 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); peer 257 daemons/fenced/pacemaker-fenced.h bool fencing_peer_active(crm_node_t *peer); peer 15 include/crm/cluster/internal.h #define pcmk__set_peer_flags(peer, flags_to_set) do { \ peer 16 include/crm/cluster/internal.h (peer)->flags = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \ peer 17 include/crm/cluster/internal.h "Peer", (peer)->uname, \ peer 18 include/crm/cluster/internal.h (peer)->flags, (flags_to_set), \ peer 22 include/crm/cluster/internal.h #define pcmk__clear_peer_flags(peer, flags_to_clear) do { \ peer 23 include/crm/cluster/internal.h (peer)->flags = pcmk__clear_flags_as(__func__, __LINE__, \ peer 25 include/crm/cluster/internal.h "Peer", (peer)->uname, \ peer 26 include/crm/cluster/internal.h (peer)->flags, (flags_to_clear), \ peer 327 include/crm/cluster/internal.h char *get_corosync_uuid(crm_node_t *peer); peer 344 include/crm/cluster/internal.h crm_node_t *crm_update_peer_proc(const char *source, crm_node_t * peer, peer 207 lib/cib/cib_ops.c const char *peer = crm_element_value(req, F_ORIG); peer 217 lib/cib/cib_ops.c crm_err("Digest mis-match on replace from %s: %s vs. %s (expected)", peer, peer 222 lib/cib/cib_ops.c crm_info("Digest matched on replace from %s: %s", peer, digest); peer 253 lib/cib/cib_ops.c replace_updates, peer, admin_epoch, epoch, updates, reason); peer 258 lib/cib/cib_ops.c replace_admin_epoch, replace_epoch, replace_updates, peer); peer 30 lib/cluster/cluster.c crm_peer_uuid(crm_node_t *peer) peer 36 lib/cluster/cluster.c if(peer == NULL) { peer 39 lib/cluster/cluster.c } else if (peer->uuid) { peer 40 lib/cluster/cluster.c return peer->uuid; peer 46 lib/cluster/cluster.c uuid = get_corosync_uuid(peer); peer 56 lib/cluster/cluster.c peer->uuid = uuid; peer 57 lib/cluster/cluster.c return peer->uuid; peer 385 lib/cluster/corosync.c crm_node_t *peer = NULL; peer 414 lib/cluster/corosync.c peer = crm_get_peer(cluster->nodeid, cluster->uname); peer 415 lib/cluster/corosync.c cluster->uuid = get_corosync_uuid(peer); peer 279 lib/cluster/cpg.c crm_node_t *peer = crm_get_peer(nodeid, NULL); peer 281 lib/cluster/cpg.c if (peer == NULL) { peer 284 lib/cluster/cpg.c } else if (peer->uname == NULL) { peer 289 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); peer 291 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); peer 393 lib/cluster/cpg.c peer_name(crm_node_t *peer) peer 395 lib/cluster/cpg.c if (peer == NULL) { peer 397 lib/cluster/cpg.c } else if (peer->uname == NULL) { peer 400 lib/cluster/cpg.c return peer->uname; peer 428 lib/cluster/cpg.c crm_node_t *peer = crm_find_peer(left_list[i].nodeid, NULL); peer 446 lib/cluster/cpg.c if (peer) { peer 455 lib/cluster/cpg.c groupName->value, counter, peer_name(peer), peer 458 lib/cluster/cpg.c if (peer) { peer 459 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 469 lib/cluster/cpg.c groupName->value, counter, peer_name(peer), peer 484 lib/cluster/cpg.c crm_node_t *peer = crm_get_peer(member_list[i].nodeid, NULL); peer 494 lib/cluster/cpg.c groupName->value, counter, peer_name(peer), peer 500 lib/cluster/cpg.c peer = crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 503 lib/cluster/cpg.c if (peer && peer->state && strcmp(peer->state, CRM_NODE_MEMBER)) { peer 513 lib/cluster/cpg.c if (peer->when_lost == 0) { peer 515 lib/cluster/cpg.c peer->when_lost = now; peer 517 lib/cluster/cpg.c } else if (now > (peer->when_lost + 60)) { peer 521 lib/cluster/cpg.c crm_update_peer_state(__func__, peer, CRM_NODE_MEMBER, 0); peer 545 lib/cluster/cpg.c crm_node_t *peer = NULL; peer 629 lib/cluster/cpg.c peer = crm_get_peer(id, NULL); peer 630 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, ONLINESTATUS); peer 496 lib/cluster/election.c send_no_vote(crm_node_t *peer, struct vote *vote) peer 506 lib/cluster/election.c send_cluster_message(peer, crm_msg_crmd, novote, TRUE); peer 227 tools/crm_resource_print.c pe_resource_t *peer = cons->rsc_rh; peer 230 tools/crm_resource_print.c peer = cons->rsc_lh; peer 233 tools/crm_resource_print.c if (pcmk_is_set(peer->flags, pe_rsc_allocating)) { peer 235 tools/crm_resource_print.c fprintf(stdout, "%s%-*s (id=%s - loop)\n", prefix, 80 - (4 * offset), peer->id, peer 242 tools/crm_resource_print.c cli_resource_print_colocation(peer, dependents, recursive, offset + 1); peer 248 tools/crm_resource_print.c peer->id, score, dependents ? "needs" : "with", role2text(cons->role_rh), peer 252 tools/crm_resource_print.c peer->id, score, cons->id); peer 254 tools/crm_resource_print.c cli_resource_print_location(peer, prefix); peer 258 tools/crm_resource_print.c cli_resource_print_colocation(peer, dependents, recursive, offset + 1); peer 384 tools/crm_resource_runtime.c pe_resource_t *peer = cons->rsc_lh; peer 387 tools/crm_resource_runtime.c if (cons->score > 0 && !pcmk_is_set(peer->flags, pe_rsc_allocating)) { peer 389 tools/crm_resource_runtime.c crm_debug("Setting %s=%s for dependent resource %s", attr_name, attr_value, peer->id); peer 390 tools/crm_resource_runtime.c cli_resource_update_attribute(peer, peer->id, NULL, attr_set_type,