peer 251 daemons/attrd/attrd_cib.c const char *peer = NULL; peer 291 daemons/attrd/attrd_cib.c while (g_hash_table_iter_next(&iter, (gpointer *) & peer, (gpointer *) & v)) { peer 294 daemons/attrd/attrd_cib.c a->id, peer, pcmk__s(v->requested, "(unset)")); peer 298 daemons/attrd/attrd_cib.c a->id, peer, pcmk__s(v->requested, "(unset)")); peer 580 daemons/attrd/attrd_cib.c pcmk__node_status_t *peer = pcmk__get_node(0, v->nodename, peer 584 daemons/attrd/attrd_cib.c node_xml_id = pcmk__cluster_get_xml_id(peer); peer 40 daemons/attrd/attrd_corosync.c attrd_peer_message(pcmk__node_status_t *peer, xmlNode *xml) peer 45 daemons/attrd/attrd_corosync.c attrd_handle_election_op(peer, xml); peer 61 daemons/attrd/attrd_corosync.c .peer = peer->name, peer 92 daemons/attrd/attrd_corosync.c crm_debug("Sending %s a confirmation", peer->name); peer 93 daemons/attrd/attrd_corosync.c attrd_send_message(peer, reply, false); peer 163 daemons/attrd/attrd_corosync.c attrd_peer_change_cb(enum pcmk__node_update kind, pcmk__node_status_t *peer, peer 167 daemons/attrd/attrd_corosync.c bool is_remote = pcmk_is_set(peer->flags, pcmk__node_status_remote); peer 173 daemons/attrd/attrd_corosync.c pcmk__s(peer->name, "unknown"), peer->cluster_layer_id, peer 174 daemons/attrd/attrd_corosync.c state_text(peer->state)); peer 178 daemons/attrd/attrd_corosync.c if (!pcmk_is_set(peer->processes, crm_get_cluster_proc())) { peer 182 daemons/attrd/attrd_corosync.c pcmk__s(peer->name, "unknown"), peer->cluster_layer_id, peer 189 daemons/attrd/attrd_corosync.c pcmk__s(peer->name, "unknown"), peer->cluster_layer_id, peer 190 daemons/attrd/attrd_corosync.c state_text(peer->state), state_text(data)); peer 191 daemons/attrd/attrd_corosync.c if (pcmk__str_eq(peer->state, PCMK_VALUE_MEMBER, pcmk__str_none)) { peer 197 daemons/attrd/attrd_corosync.c attrd_peer_sync(peer); peer 201 daemons/attrd/attrd_corosync.c attrd_send_protocol(peer); peer 207 daemons/attrd/attrd_corosync.c if (peer->name != NULL) { peer 208 daemons/attrd/attrd_corosync.c attrd_peer_remove(peer->name, false, "loss"); peer 216 daemons/attrd/attrd_corosync.c if (gone && !is_remote && peer->name != NULL) { peer 217 daemons/attrd/attrd_corosync.c attrd_remove_voter(peer); peer 218 daemons/attrd/attrd_corosync.c attrd_remove_peer_protocol_ver(peer->name); peer 219 daemons/attrd/attrd_corosync.c attrd_do_not_expect_from_peer(peer->name); peer 229 daemons/attrd/attrd_corosync.c update_attr_on_host(attribute_t *a, const pcmk__node_status_t *peer, peer 276 daemons/attrd/attrd_corosync.c attr, host, readable_value(v), value, peer->name); peer 284 daemons/attrd/attrd_corosync.c pcmk__s(value, "(unset)"), peer->name, peer 320 daemons/attrd/attrd_corosync.c attr, host, peer->name, pcmk__s(value, "unset")); peer 324 daemons/attrd/attrd_corosync.c attr, host, peer->name, pcmk__s(value, "unset")); peer 351 daemons/attrd/attrd_corosync.c attrd_peer_update_one(const pcmk__node_status_t *peer, xmlNode *xml, peer 378 daemons/attrd/attrd_corosync.c update_attr_on_host(a, peer, xml, attr, value, host, filter); peer 383 daemons/attrd/attrd_corosync.c update_attr_on_host(a, peer, xml, attr, value, host, filter); peer 390 daemons/attrd/attrd_corosync.c attrd_update_minimum_protocol_ver(peer->name, value); peer 466 daemons/attrd/attrd_corosync.c pcmk__node_status_t *peer = peer 467 daemons/attrd/attrd_corosync.c pcmk__get_node(0, request->peer, NULL, peer 489 daemons/attrd/attrd_corosync.c attrd_peer_update(peer, xml, host, false); peer 504 daemons/attrd/attrd_corosync.c attrd_peer_sync_response(const pcmk__node_status_t *peer, bool peer_won, peer 508 daemons/attrd/attrd_corosync.c peer->name); peer 521 daemons/attrd/attrd_corosync.c attrd_peer_update(peer, child, peer 572 daemons/attrd/attrd_corosync.c attrd_peer_sync(pcmk__node_status_t *peer) peer 589 daemons/attrd/attrd_corosync.c readable_peer(peer)); peer 594 daemons/attrd/attrd_corosync.c crm_debug("Syncing values to %s", readable_peer(peer)); peer 595 daemons/attrd/attrd_corosync.c attrd_send_message(peer, sync, false); peer 600 daemons/attrd/attrd_corosync.c attrd_peer_update(const pcmk__node_status_t *peer, xmlNode *xml, peer 605 daemons/attrd/attrd_corosync.c CRM_CHECK((peer != NULL) && (xml != NULL), return); peer 611 daemons/attrd/attrd_corosync.c attrd_peer_update_one(peer, child, filter); peer 619 daemons/attrd/attrd_corosync.c attrd_peer_update_one(peer, xml, filter); peer 58 daemons/attrd/attrd_elections.c attrd_handle_election_op(const pcmk__node_status_t *peer, xmlNode *xml) peer 63 daemons/attrd/attrd_elections.c crm_xml_add(xml, PCMK__XA_SRC, peer->name); peer 90 daemons/attrd/attrd_elections.c pcmk__str_update(&peer_writer, peer->name); peer 101 daemons/attrd/attrd_elections.c crm_info("Ignoring election op from %s due to error", peer->name); peer 107 daemons/attrd/attrd_elections.c attrd_check_for_new_writer(const pcmk__node_status_t *peer, const xmlNode *xml) peer 114 daemons/attrd/attrd_elections.c && !pcmk__str_eq(peer->name, attrd_cluster->priv->node_name, peer 118 daemons/attrd/attrd_elections.c peer->name); peer 121 daemons/attrd/attrd_elections.c } else if (!pcmk__str_eq(peer->name, peer_writer, pcmk__str_casei)) { peer 123 daemons/attrd/attrd_elections.c peer->name, pcmk__s(peer_writer, "unset")); peer 124 daemons/attrd/attrd_elections.c pcmk__str_update(&peer_writer, peer->name); peer 139 daemons/attrd/attrd_elections.c attrd_remove_voter(const pcmk__node_status_t *peer) peer 141 daemons/attrd/attrd_elections.c election_remove(attrd_cluster, peer->name); peer 143 daemons/attrd/attrd_elections.c && pcmk__str_eq(peer->name, peer_writer, pcmk__str_casei)) { peer 147 daemons/attrd/attrd_elections.c crm_notice("Lost attribute writer %s", peer->name); peer 167 daemons/attrd/attrd_elections.c crm_debug("Checking election status upon loss of voter %s", peer->name); peer 608 daemons/attrd/attrd_ipc.c .peer = NULL, peer 69 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 105 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 108 daemons/attrd/attrd_messages.c crm_debug("Received confirmation from %s", request->peer); peer 115 daemons/attrd/attrd_messages.c attrd_handle_confirmation(callid, request->peer); peer 128 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 138 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 146 daemons/attrd/attrd_messages.c attrd_peer_remove(host, reap, request->peer); peer 157 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 170 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 171 daemons/attrd/attrd_messages.c pcmk__node_status_t *peer = peer 172 daemons/attrd/attrd_messages.c pcmk__get_node(0, request->peer, NULL, peer 174 daemons/attrd/attrd_messages.c bool peer_won = attrd_check_for_new_writer(peer, request->xml); peer 176 daemons/attrd/attrd_messages.c if (!pcmk__str_eq(peer->name, attrd_cluster->priv->node_name, peer 178 daemons/attrd/attrd_messages.c attrd_peer_sync_response(peer, peer_won, request->xml); peer 190 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 192 daemons/attrd/attrd_messages.c pcmk__node_status_t *peer = peer 193 daemons/attrd/attrd_messages.c pcmk__get_node(0, request->peer, NULL, peer 196 daemons/attrd/attrd_messages.c attrd_peer_update(peer, request->xml, host, false); peer 308 daemons/attrd/attrd_messages.c attrd_send_protocol(const pcmk__node_status_t *peer) peer 322 daemons/attrd/attrd_messages.c if (peer == NULL) { peer 335 daemons/attrd/attrd_messages.c pcmk__s(peer->name, "unknown"), peer 336 daemons/attrd/attrd_messages.c peer->cluster_layer_id); peer 339 daemons/attrd/attrd_messages.c attrd_send_message(peer, attrd_op, false); /* ends up at attrd_peer_message() */ peer 109 daemons/attrd/pacemaker-attrd.h void attrd_handle_election_op(const pcmk__node_status_t *peer, xmlNode *xml); peer 110 daemons/attrd/pacemaker-attrd.h bool attrd_check_for_new_writer(const pcmk__node_status_t *peer, peer 113 daemons/attrd/pacemaker-attrd.h void attrd_remove_voter(const pcmk__node_status_t *peer); peer 189 daemons/attrd/pacemaker-attrd.h void attrd_peer_update(const pcmk__node_status_t *peer, xmlNode *xml, peer 191 daemons/attrd/pacemaker-attrd.h void attrd_peer_sync(pcmk__node_status_t *peer); peer 194 daemons/attrd/pacemaker-attrd.h void attrd_peer_sync_response(const pcmk__node_status_t *peer, bool peer_won, peer 197 daemons/attrd/pacemaker-attrd.h void attrd_send_protocol(const pcmk__node_status_t *peer); peer 731 daemons/based/based_callbacks.c pcmk__node_status_t *peer = NULL; peer 751 daemons/based/based_callbacks.c peer = pcmk__get_node(0, host, NULL, pcmk__node_search_cluster_member); peer 753 daemons/based/based_callbacks.c pcmk__cluster_send_message(peer, pcmk_ipc_based, request); peer 121 daemons/based/based_messages.c pcmk__node_status_t *peer = NULL; peer 131 daemons/based/based_messages.c peer = pcmk__get_node(0, host, NULL, pcmk__node_search_cluster_member); peer 133 daemons/based/based_messages.c pcmk__cluster_send_message(peer, pcmk_ipc_based, sync_me); peer 415 daemons/based/based_messages.c pcmk__node_status_t *peer = NULL; peer 448 daemons/based/based_messages.c peer = pcmk__get_node(0, host, NULL, pcmk__node_search_cluster_member); peer 450 daemons/based/based_messages.c if (!pcmk__cluster_send_message(peer, pcmk_ipc_based, replace_request)) { peer 38 daemons/controld/controld_corosync.c pcmk__node_status_t *peer = NULL; peer 54 daemons/controld/controld_corosync.c peer = pcmk__get_node(0, from, NULL, pcmk__node_search_cluster_member); peer 55 daemons/controld/controld_corosync.c if (!pcmk_is_set(peer->processes, crm_proc_cpg)) { peer 61 daemons/controld/controld_corosync.c peer->name, peer->cluster_layer_id); peer 62 daemons/controld/controld_corosync.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, PCMK_VALUE_ONLINE); peer 120 daemons/controld/controld_corosync.c pcmk__node_status_t *peer = NULL; peer 122 daemons/controld/controld_corosync.c peer = pcmk__search_node_caches(0, controld_globals.dc_name, NULL, peer 124 daemons/controld/controld_corosync.c if (peer != NULL) { peer 126 daemons/controld/controld_corosync.c if (left_list[i].nodeid == peer->cluster_layer_id) { peer 579 daemons/controld/controld_execd.c pcmk__node_status_t *peer = NULL; peer 587 daemons/controld/controld_execd.c peer = pcmk__get_node(0, lrm_state->node_name, NULL, pcmk__node_search_any); peer 588 daemons/controld/controld_execd.c CRM_CHECK(peer != NULL, return NULL); peer 590 daemons/controld/controld_execd.c xml_state = create_node_state_update(peer, peer 599 daemons/controld/controld_execd.c crm_xml_add(xml_data, PCMK_XA_ID, peer->xml_id); peer 1720 daemons/controld/controld_execd.c pcmk__node_status_t *peer = NULL; peer 1732 daemons/controld/controld_execd.c peer = controld_get_local_node_status(); peer 1733 daemons/controld/controld_execd.c update = create_node_state_update(peer, controld_node_update_none, NULL, peer 221 daemons/controld/controld_fencing.c pcmk__node_status_t *peer = NULL; peer 234 daemons/controld/controld_fencing.c peer = pcmk__get_node(0, target, target_xml_id, pcmk__node_search_any); peer 235 daemons/controld/controld_fencing.c CRM_CHECK(peer != NULL, return); peer 237 daemons/controld/controld_fencing.c if (peer->state == NULL) { peer 245 daemons/controld/controld_fencing.c if (peer->xml_id == NULL) { peer 247 daemons/controld/controld_fencing.c peer->xml_id = pcmk__str_copy(target_xml_id); peer 250 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 252 daemons/controld/controld_fencing.c node_state = create_node_state_update(peer, flags, NULL, __func__); peer 255 daemons/controld/controld_fencing.c if (pcmk_is_set(peer->flags, pcmk__node_status_remote)) { peer 270 daemons/controld/controld_fencing.c controld_delete_node_state(peer->name, controld_section_all, cib_none); peer 582 daemons/controld/controld_fencing.c pcmk__node_status_t *peer = pcmk__search_node_caches(0, event->target, peer 586 daemons/controld/controld_fencing.c if (peer == NULL) { peer 590 daemons/controld/controld_fencing.c uuid = pcmk__cluster_get_xml_id(peer); peer 616 daemons/controld/controld_fencing.c && !pcmk_is_set(peer->flags, pcmk__node_status_remote)) { peer 641 daemons/controld/controld_fencing.c if (pcmk_is_set(peer->flags, pcmk__node_status_remote)) { peer 645 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 204 daemons/controld/controld_join_dc.c pcmk__node_status_t *peer = NULL; peer 209 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 210 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, controld_join_none); peer 771 daemons/controld/controld_join_dc.c pcmk__node_status_t *peer = NULL; peer 804 daemons/controld/controld_join_dc.c peer = pcmk__get_node(0, join_from, NULL, pcmk__node_search_cluster_member); peer 805 daemons/controld/controld_join_dc.c phase = controld_get_join_phase(peer); peer 818 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, controld_join_nack); peer 822 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, controld_join_confirmed); peer 1074 daemons/controld/controld_join_dc.c pcmk__node_status_t *peer; peer 1078 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 1079 daemons/controld/controld_join_dc.c if (controld_get_join_phase(peer) == phase) { peer 1088 daemons/controld/controld_join_dc.c pcmk__node_status_t *peer; peer 1092 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 1093 daemons/controld/controld_join_dc.c do_crm_log(level, "join-%d: %s=%s", current_join_id, peer->name, peer 1094 daemons/controld/controld_join_dc.c join_phase_text(controld_get_join_phase(peer))); peer 161 daemons/controld/controld_te_actions.c pcmk__node_status_t *peer = peer 165 daemons/controld/controld_te_actions.c pcmk__update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 478 daemons/controld/controld_te_actions.c struct te_peer_s *peer = p; peer 480 daemons/controld/controld_te_actions.c free(peer->name); peer 481 daemons/controld/controld_te_actions.c free(peer); peer 487 daemons/controld/controld_te_actions.c struct te_peer_s *peer = NULL; peer 494 daemons/controld/controld_te_actions.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & peer)) { peer 495 daemons/controld/controld_te_actions.c peer->jobs = 0; peer 496 daemons/controld/controld_te_actions.c peer->migrate_jobs = 0; peer 770 daemons/controld/controld_utils.c void crmd_peer_down(pcmk__node_status_t *peer, bool full) peer 772 daemons/controld/controld_utils.c if(full && peer->state == NULL) { peer 773 daemons/controld/controld_utils.c pcmk__update_peer_state(__func__, peer, PCMK__VALUE_LOST, 0); peer 774 daemons/controld/controld_utils.c crm_update_peer_proc(__func__, peer, crm_proc_none, NULL); peer 776 daemons/controld/controld_utils.c crm_update_peer_join(__func__, peer, controld_join_none); peer 777 daemons/controld/controld_utils.c pcmk__update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 80 daemons/controld/controld_utils.h void crmd_peer_down(pcmk__node_status_t *peer, bool full); peer 2987 daemons/fenced/fenced_commands.c fencing_peer_active(pcmk__node_status_t *peer) peer 2989 daemons/fenced/fenced_commands.c return (peer != NULL) && (peer->name != NULL) peer 2990 daemons/fenced/fenced_commands.c && pcmk_is_set(peer->processes, crm_get_cluster_proc()); peer 3168 daemons/fenced/fenced_commands.c if (request->peer != NULL) { peer 3196 daemons/fenced/fenced_commands.c query->remote_peer = pcmk__str_copy(request->peer); peer 3268 daemons/fenced/fenced_commands.c if (request->peer != NULL) { peer 3313 daemons/fenced/fenced_commands.c request->peer, action, target, peer 3371 daemons/fenced/fenced_commands.c stonith_fence_history(request->xml, &data, request->peer, peer 3544 daemons/fenced/fenced_commands.c request->peer, request->ipc_client); peer 3635 daemons/fenced/fenced_commands.c .peer = remote_peer, peer 86 daemons/fenced/fenced_remote.c peer_device_info_t *peer); peer 102 daemons/fenced/fenced_remote.c peer_device_info_t *peer = data; peer 104 daemons/fenced/fenced_remote.c g_hash_table_destroy(peer->devices); peer 105 daemons/fenced/fenced_remote.c free(peer->host); peer 106 daemons/fenced/fenced_remote.c free(peer); peer 162 daemons/fenced/fenced_remote.c const peer_device_info_t *peer, gboolean verified_only, uint32_t support_on_action_only) peer 170 daemons/fenced/fenced_remote.c if (peer) { peer 171 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, count_peer_device, &data); peer 187 daemons/fenced/fenced_remote.c find_peer_device(const remote_fencing_op_t *op, const peer_device_info_t *peer, peer 190 daemons/fenced/fenced_remote.c device_properties_t *props = g_hash_table_lookup(peer->devices, device); peer 217 daemons/fenced/fenced_remote.c grab_peer_device(const remote_fencing_op_t *op, peer_device_info_t *peer, peer 220 daemons/fenced/fenced_remote.c device_properties_t *props = find_peer_device(op, peer, device, peer 228 daemons/fenced/fenced_remote.c device, peer->host, peer 229 daemons/fenced/fenced_remote.c count_peer_devices(op, peer, FALSE, fenced_df_none)); peer 1163 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer) peer 1176 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1195 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1253 daemons/fenced/fenced_remote.c (peer && dev)? "Recorded" : "Generated", op->id, op->action, peer 1413 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter->data; peer 1416 daemons/fenced/fenced_remote.c peer->host, op->target, peer->ndevices, peer 1417 daemons/fenced/fenced_remote.c pcmk__plural_s(peer->ndevices), peer->tried, options); peer 1418 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_SKIP_TARGET) && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1421 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_TARGET_ONLY) && !pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1427 daemons/fenced/fenced_remote.c if (grab_peer_device(op, peer, device, verified_devices_only)) { peer 1428 daemons/fenced/fenced_remote.c return peer; peer 1431 daemons/fenced/fenced_remote.c } else if (!peer->tried peer 1432 daemons/fenced/fenced_remote.c && count_peer_devices(op, peer, verified_devices_only, peer 1436 daemons/fenced/fenced_remote.c return peer; peer 1447 daemons/fenced/fenced_remote.c peer_device_info_t *peer = NULL; peer 1461 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET|FIND_PEER_VERIFIED_ONLY); peer 1462 daemons/fenced/fenced_remote.c if (peer) { peer 1463 daemons/fenced/fenced_remote.c crm_trace("Found verified peer %s for %s", peer->host, device?device:"<any>"); peer 1464 daemons/fenced/fenced_remote.c return peer; peer 1473 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET); peer 1474 daemons/fenced/fenced_remote.c if (peer) { peer 1475 daemons/fenced/fenced_remote.c crm_trace("Found best unverified peer %s", peer->host); peer 1476 daemons/fenced/fenced_remote.c return peer; peer 1483 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_TARGET_ONLY); peer 1484 daemons/fenced/fenced_remote.c if (peer) { peer 1485 daemons/fenced/fenced_remote.c crm_trace("%s will fence itself", peer->host); peer 1486 daemons/fenced/fenced_remote.c return peer; peer 1546 daemons/fenced/fenced_remote.c const peer_device_info_t *peer, const char *device, peer 1552 daemons/fenced/fenced_remote.c if (!peer || !device) { peer 1556 daemons/fenced/fenced_remote.c props = g_hash_table_lookup(peer->devices, device); peer 1578 daemons/fenced/fenced_remote.c const peer_device_info_t *peer; peer 1599 daemons/fenced/fenced_remote.c timeout->total_timeout += get_device_timeout(timeout->op, timeout->peer, peer 1605 daemons/fenced/fenced_remote.c get_peer_timeout(const remote_fencing_op_t *op, const peer_device_info_t *peer) peer 1610 daemons/fenced/fenced_remote.c timeout.peer = peer; peer 1613 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, add_device_timeout, &timeout); peer 1651 daemons/fenced/fenced_remote.c const peer_device_info_t *peer = iter->data; peer 1661 daemons/fenced/fenced_remote.c if (find_peer_device(op, peer, device_list->data, peer 1663 daemons/fenced/fenced_remote.c total_timeout += get_device_timeout(op, peer, peer 1686 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter2->data; peer 1687 daemons/fenced/fenced_remote.c if (find_peer_device(op, peer, iter->data, peer 1689 daemons/fenced/fenced_remote.c total_timeout += get_device_timeout(op, peer, peer 1870 daemons/fenced/fenced_remote.c request_peer_fencing(remote_fencing_op_t *op, peer_device_info_t *peer) peer 1911 daemons/fenced/fenced_remote.c if ((peer == NULL) && !pcmk_is_set(op->call_options, st_opt_topology)) { peer 1912 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1916 daemons/fenced/fenced_remote.c op->total_timeout = TIMEOUT_MULTIPLY_FACTOR * get_op_total_timeout(op, peer); peer 1933 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1940 daemons/fenced/fenced_remote.c timeout = get_device_timeout(op, peer, device, false); peer 1943 daemons/fenced/fenced_remote.c if (peer) { peer 1947 daemons/fenced/fenced_remote.c pcmk__get_node(0, peer->host, NULL, peer 1969 daemons/fenced/fenced_remote.c get_device_timeout(op, peer, device, true); peer 1972 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, device, peer 1977 daemons/fenced/fenced_remote.c timeout_one += TIMEOUT_MULTIPLY_FACTOR * get_peer_timeout(op, peer); peer 1980 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, op->client_name, peer 2018 daemons/fenced/fenced_remote.c peer->tried = TRUE; peer 2149 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter->data; peer 2151 daemons/fenced/fenced_remote.c if (skip_target && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 2154 daemons/fenced/fenced_remote.c match = find_peer_device(op, peer, device->data, peer 2179 daemons/fenced/fenced_remote.c parse_action_specific(const xmlNode *xml, const char *peer, const char *device, peer 2188 daemons/fenced/fenced_remote.c peer, device, action, props->custom_action_timeout[phase]); peer 2195 daemons/fenced/fenced_remote.c peer, device, props->delay_max[phase], action); peer 2203 daemons/fenced/fenced_remote.c peer, device, props->delay_base[phase], action); peer 2213 daemons/fenced/fenced_remote.c peer, device, action); peer 2224 daemons/fenced/fenced_remote.c peer, action, device); peer 2239 daemons/fenced/fenced_remote.c peer_device_info_t *peer, const char *device) peer 2248 daemons/fenced/fenced_remote.c g_hash_table_insert(peer->devices, pcmk__str_copy(device), props); peer 2254 daemons/fenced/fenced_remote.c peer->host, device); peer 2268 daemons/fenced/fenced_remote.c parse_action_specific(xml, peer->host, device, op_requested_action(op), peer 2277 daemons/fenced/fenced_remote.c parse_action_specific(child, peer->host, device, PCMK_ACTION_OFF, peer 2282 daemons/fenced/fenced_remote.c parse_action_specific(child, peer->host, device, PCMK_ACTION_ON, peer 2303 daemons/fenced/fenced_remote.c peer_device_info_t *peer = pcmk__assert_alloc(1, peer 2307 daemons/fenced/fenced_remote.c peer->host = pcmk__str_copy(host); peer 2308 daemons/fenced/fenced_remote.c peer->devices = pcmk__strkey_table(free, free); peer 2316 daemons/fenced/fenced_remote.c add_device_properties(child, op, peer, device); peer 2320 daemons/fenced/fenced_remote.c peer->ndevices = g_hash_table_size(peer->devices); peer 2321 daemons/fenced/fenced_remote.c CRM_CHECK(ndevices == peer->ndevices, peer 2323 daemons/fenced/fenced_remote.c ndevices, pcmk__plural_s(ndevices), peer->ndevices)); peer 2325 daemons/fenced/fenced_remote.c op->query_results = g_list_insert_sorted(op->query_results, peer, sort_peers); peer 2326 daemons/fenced/fenced_remote.c return peer; peer 2352 daemons/fenced/fenced_remote.c peer_device_info_t *peer = NULL; peer 2390 daemons/fenced/fenced_remote.c peer = add_result(op, host, ndevices, dev); peer 2402 daemons/fenced/fenced_remote.c request_peer_fencing(op, peer); peer 2411 daemons/fenced/fenced_remote.c int nverified = count_peer_devices(op, peer, TRUE, peer 2416 daemons/fenced/fenced_remote.c if ((peer != NULL) && !host_is_target && nverified) { peer 2420 daemons/fenced/fenced_remote.c request_peer_fencing(op, peer); peer 2431 daemons/fenced/fenced_remote.c } else if ((peer != NULL) && (op->state == st_done)) { peer 2433 daemons/fenced/fenced_remote.c "Operation is %s", peer->host, peer 2434 daemons/fenced/fenced_remote.c peer->ndevices, pcmk__plural_s(peer->ndevices), peer 349 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); peer 356 daemons/fenced/pacemaker-fenced.h bool fencing_peer_active(pcmk__node_status_t *peer); peer 263 daemons/pacemakerd/pcmkd_messages.c .peer = NULL, peer 295 daemons/schedulerd/schedulerd_messages.c .peer = NULL, peer 268 include/crm/cluster/internal.h pcmk__node_status_t *peer, peer 46 include/crm/common/messages_internal.h const char *peer; // Peer name (NULL if not via cluster) peer 192 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { peer 213 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { peer 214 include/crm/common/messages_internal.h return request->peer; peer 342 lib/cib/cib_ops.c const char *peer = crm_element_value(req, PCMK__XA_SRC); peer 349 lib/cib/cib_ops.c crm_err("Digest mis-match on replace from %s: %s vs. %s (expected)", peer, peer 354 lib/cib/cib_ops.c crm_info("Digest matched on replace from %s: %s", peer, digest); peer 385 lib/cib/cib_ops.c replace_updates, peer, admin_epoch, epoch, updates, reason); peer 390 lib/cib/cib_ops.c replace_admin_epoch, replace_epoch, replace_updates, peer); peer 437 lib/cluster/cpg.c const pcmk__node_status_t *peer = peer 441 lib/cluster/cpg.c if (peer->name == NULL) { peer 446 lib/cluster/cpg.c " to %s", sender_id, peer->name); peer 447 lib/cluster/cpg.c msg->sender.size = strlen(peer->name); peer 449 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->name, msg->sender.size); peer 554 lib/cluster/cpg.c peer_name(const pcmk__node_status_t *peer) peer 556 lib/cluster/cpg.c return (peer != NULL)? pcmk__s(peer->name, "peer node") : "unknown node"; peer 576 lib/cluster/cpg.c pcmk__node_status_t *peer = peer 593 lib/cluster/cpg.c if (peer != NULL) { peer 601 lib/cluster/cpg.c cpg_group_name, event_counter, peer_name(peer), peer 604 lib/cluster/cpg.c if (peer != NULL) { peer 605 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 615 lib/cluster/cpg.c cpg_group_name, event_counter, peer_name(peer), peer 678 lib/cluster/cpg.c pcmk__node_status_t *peer = peer 690 lib/cluster/cpg.c group_name->value, counter, peer_name(peer), peer 696 lib/cluster/cpg.c peer = crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 699 lib/cluster/cpg.c if (peer && peer->state && strcmp(peer->state, PCMK_VALUE_MEMBER)) { peer 709 lib/cluster/cpg.c if (peer->when_lost == 0) { peer 711 lib/cluster/cpg.c peer->when_lost = now; peer 713 lib/cluster/cpg.c } else if (now > (peer->when_lost + 60)) { peer 718 lib/cluster/cpg.c pcmk__update_peer_state(__func__, peer, PCMK_VALUE_MEMBER, 0); peer 785 lib/cluster/cpg.c pcmk__node_status_t *peer = NULL; peer 879 lib/cluster/cpg.c peer = pcmk__get_node(id, NULL, NULL, pcmk__node_search_cluster_member); peer 880 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, PCMK_VALUE_ONLINE); peer 49 lib/cluster/crmcluster_private.h char *pcmk__corosync_uuid(const pcmk__node_status_t *peer); peer 491 lib/cluster/election.c send_no_vote(pcmk_cluster_t *cluster, pcmk__node_status_t *peer, peer 503 lib/cluster/election.c pcmk__cluster_send_message(peer, cluster->priv->server, novote); peer 70 lib/cluster/membership.c #define set_peer_flags(peer, flags_to_set) do { \ peer 71 lib/cluster/membership.c (peer)->flags = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \ peer 72 lib/cluster/membership.c "Peer", (peer)->name, \ peer 73 lib/cluster/membership.c (peer)->flags, (flags_to_set), \ peer 77 lib/cluster/membership.c #define clear_peer_flags(peer, flags_to_clear) do { \ peer 78 lib/cluster/membership.c (peer)->flags = pcmk__clear_flags_as(__func__, __LINE__, \ peer 80 lib/cluster/membership.c "Peer", (peer)->name, \ peer 81 lib/cluster/membership.c (peer)->flags, (flags_to_clear), \