peer 224 daemons/attrd/attrd_cib.c const char *peer = NULL; peer 264 daemons/attrd/attrd_cib.c while (g_hash_table_iter_next(&iter, (gpointer *) & peer, (gpointer *) & v)) { peer 265 daemons/attrd/attrd_cib.c do_crm_log(level, "* %s[%s]=%s", a->id, peer, v->requested); peer 546 daemons/attrd/attrd_cib.c crm_node_t *peer = crm_get_peer_full(v->nodeid, v->nodename, peer 550 daemons/attrd/attrd_cib.c if (peer == NULL) { peer 557 daemons/attrd/attrd_cib.c if (peer->id && (v->nodeid == 0)) { peer 558 daemons/attrd/attrd_cib.c crm_trace("Learned ID %u for node %s", peer->id, v->nodename); peer 559 daemons/attrd/attrd_cib.c v->nodeid = peer->id; peer 569 daemons/attrd/attrd_cib.c if (peer->uuid == NULL) { peer 578 daemons/attrd/attrd_cib.c rc = add_attr_update(a, v->current, peer->uuid); peer 582 daemons/attrd/attrd_cib.c a->id, v->nodename, v->current, peer->uname, peer->uuid, peer 583 daemons/attrd/attrd_cib.c peer->id, v->nodeid, pcmk_rc_str(rc)); peer 590 daemons/attrd/attrd_cib.c peer->uname, peer->uuid, peer->id, v->nodeid); peer 40 daemons/attrd/attrd_corosync.c attrd_peer_message(crm_node_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->uname, peer 92 daemons/attrd/attrd_corosync.c crm_debug("Sending %s a confirmation", peer->uname); peer 93 daemons/attrd/attrd_corosync.c attrd_send_message(peer, reply, false); peer 122 daemons/attrd/attrd_corosync.c crm_node_t *peer = crm_get_peer(nodeid, from); peer 124 daemons/attrd/attrd_corosync.c attrd_peer_message(peer, xml); peer 227 daemons/attrd/attrd_corosync.c attrd_peer_change_cb(enum crm_status_type kind, crm_node_t *peer, const void *data) peer 230 daemons/attrd/attrd_corosync.c bool is_remote = pcmk_is_set(peer->flags, crm_remote_node); peer 236 daemons/attrd/attrd_corosync.c peer->uname, state_text(peer->state)); peer 240 daemons/attrd/attrd_corosync.c if (!pcmk_is_set(peer->processes, crm_get_cluster_proc())) { peer 244 daemons/attrd/attrd_corosync.c peer->uname, (gone? "no longer" : "now")); peer 250 daemons/attrd/attrd_corosync.c peer->uname, state_text(peer->state), state_text(data)); peer 251 daemons/attrd/attrd_corosync.c if (pcmk__str_eq(peer->state, CRM_NODE_MEMBER, pcmk__str_casei)) { peer 256 daemons/attrd/attrd_corosync.c && !pcmk_is_set(peer->flags, crm_remote_node)) { peer 257 daemons/attrd/attrd_corosync.c attrd_peer_sync(peer, NULL); peer 261 daemons/attrd/attrd_corosync.c attrd_peer_remove(peer->uname, false, "loss"); peer 269 daemons/attrd/attrd_corosync.c attrd_remove_voter(peer); peer 270 daemons/attrd/attrd_corosync.c attrd_remove_peer_protocol_ver(peer->uname); peer 271 daemons/attrd/attrd_corosync.c attrd_do_not_expect_from_peer(peer->uname); peer 275 daemons/attrd/attrd_corosync.c cache_remote_node(peer->uname); peer 291 daemons/attrd/attrd_corosync.c update_attr_on_host(attribute_t *a, const crm_node_t *peer, const xmlNode *xml, peer 303 daemons/attrd/attrd_corosync.c attr, host, v->current, value, peer->uname); peer 311 daemons/attrd/attrd_corosync.c pcmk__s(value, "(unset)"), peer->uname, peer 340 daemons/attrd/attrd_corosync.c attr, host, peer->uname, value); peer 343 daemons/attrd/attrd_corosync.c crm_trace("Unchanged %s[%s] from %s is %s", attr, host, peer->uname, value); peer 359 daemons/attrd/attrd_corosync.c attrd_peer_update_one(const crm_node_t *peer, xmlNode *xml, bool filter) peer 388 daemons/attrd/attrd_corosync.c update_attr_on_host(a, peer, xml, attr, value, host, filter, is_force_write); peer 393 daemons/attrd/attrd_corosync.c update_attr_on_host(a, peer, xml, attr, value, host, filter, is_force_write); peer 400 daemons/attrd/attrd_corosync.c attrd_update_minimum_protocol_ver(peer->uname, value); peer 466 daemons/attrd/attrd_corosync.c crm_node_t *peer = crm_get_peer(0, request->peer); peer 485 daemons/attrd/attrd_corosync.c attrd_peer_update(peer, xml, host, false); peer 500 daemons/attrd/attrd_corosync.c attrd_peer_sync_response(const crm_node_t *peer, bool peer_won, xmlNode *xml) peer 503 daemons/attrd/attrd_corosync.c peer->uname); peer 515 daemons/attrd/attrd_corosync.c attrd_peer_update(peer, child, peer 559 daemons/attrd/attrd_corosync.c attrd_peer_sync(crm_node_t *peer, xmlNode *xml) peer 574 daemons/attrd/attrd_corosync.c crm_debug("Syncing %s[%s] = %s to %s", a->id, v->nodename, v->current, peer?peer->uname:"everyone"); peer 579 daemons/attrd/attrd_corosync.c crm_debug("Syncing values to %s", peer?peer->uname:"everyone"); peer 580 daemons/attrd/attrd_corosync.c attrd_send_message(peer, sync, false); peer 585 daemons/attrd/attrd_corosync.c attrd_peer_update(const crm_node_t *peer, xmlNode *xml, const char *host, peer 590 daemons/attrd/attrd_corosync.c CRM_CHECK((peer != NULL) && (xml != NULL), return); peer 595 daemons/attrd/attrd_corosync.c attrd_peer_update_one(peer, child, filter); peer 603 daemons/attrd/attrd_corosync.c attrd_peer_update_one(peer, xml, filter); peer 67 daemons/attrd/attrd_elections.c attrd_handle_election_op(const crm_node_t *peer, xmlNode *xml) peer 72 daemons/attrd/attrd_elections.c crm_xml_add(xml, F_CRM_HOST_FROM, peer->uname); peer 99 daemons/attrd/attrd_elections.c pcmk__str_update(&peer_writer, peer->uname); peer 110 daemons/attrd/attrd_elections.c crm_info("Ignoring election op from %s due to error", peer->uname); peer 116 daemons/attrd/attrd_elections.c attrd_check_for_new_writer(const crm_node_t *peer, const xmlNode *xml) peer 123 daemons/attrd/attrd_elections.c && !pcmk__str_eq(peer->uname, attrd_cluster->uname, pcmk__str_casei)) { peer 125 daemons/attrd/attrd_elections.c peer->uname); peer 128 daemons/attrd/attrd_elections.c } else if (!pcmk__str_eq(peer->uname, peer_writer, pcmk__str_casei)) { peer 130 daemons/attrd/attrd_elections.c peer->uname, (peer_writer? peer_writer : "unset")); peer 131 daemons/attrd/attrd_elections.c pcmk__str_update(&peer_writer, peer->uname); peer 146 daemons/attrd/attrd_elections.c attrd_remove_voter(const crm_node_t *peer) peer 148 daemons/attrd/attrd_elections.c election_remove(writer, peer->uname); peer 149 daemons/attrd/attrd_elections.c if (peer_writer && pcmk__str_eq(peer->uname, peer_writer, pcmk__str_casei)) { peer 152 daemons/attrd/attrd_elections.c crm_notice("Lost attribute writer %s", peer->uname); peer 172 daemons/attrd/attrd_elections.c crm_debug("Checking election status upon loss of voter %s", peer->uname); peer 583 daemons/attrd/attrd_ipc.c .peer = NULL, peer 67 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 103 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 106 daemons/attrd/attrd_messages.c crm_debug("Received confirmation from %s", request->peer); peer 112 daemons/attrd/attrd_messages.c attrd_handle_confirmation(callid, request->peer); peer 125 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 139 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 149 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 151 daemons/attrd/attrd_messages.c attrd_peer_remove(host, true, request->peer); peer 162 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 172 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 173 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); peer 175 daemons/attrd/attrd_messages.c attrd_peer_sync(peer, request->xml); peer 189 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 190 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); peer 191 daemons/attrd/attrd_messages.c bool peer_won = attrd_check_for_new_writer(peer, request->xml); peer 193 daemons/attrd/attrd_messages.c if (!pcmk__str_eq(peer->uname, attrd_cluster->uname, pcmk__str_casei)) { peer 194 daemons/attrd/attrd_messages.c attrd_peer_sync_response(peer, peer_won, request->xml); peer 206 daemons/attrd/attrd_messages.c if (request->peer != NULL) { peer 208 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); peer 210 daemons/attrd/attrd_messages.c attrd_peer_update(peer, request->xml, host, false); peer 113 daemons/attrd/pacemaker-attrd.h void attrd_handle_election_op(const crm_node_t *peer, xmlNode *xml); peer 114 daemons/attrd/pacemaker-attrd.h bool attrd_check_for_new_writer(const crm_node_t *peer, const xmlNode *xml); peer 116 daemons/attrd/pacemaker-attrd.h void attrd_remove_voter(const crm_node_t *peer); peer 157 daemons/attrd/pacemaker-attrd.h void attrd_peer_update(const crm_node_t *peer, xmlNode *xml, const char *host, peer 159 daemons/attrd/pacemaker-attrd.h void attrd_peer_sync(crm_node_t *peer, xmlNode *xml); peer 162 daemons/attrd/pacemaker-attrd.h void attrd_peer_sync_response(const crm_node_t *peer, bool peer_won, 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 120 daemons/controld/controld_corosync.c crm_node_t *peer = NULL; peer 122 daemons/controld/controld_corosync.c peer = pcmk__search_cluster_node_cache(0, controld_globals.dc_name, peer 124 daemons/controld/controld_corosync.c if (peer != NULL) { peer 126 daemons/controld/controld_corosync.c if (left_list[i].nodeid == peer->id) { peer 575 daemons/controld/controld_execd.c crm_node_t *peer = NULL; peer 584 daemons/controld/controld_execd.c peer = crm_get_peer_full(0, lrm_state->node_name, CRM_GET_PEER_ANY); peer 585 daemons/controld/controld_execd.c CRM_CHECK(peer != NULL, return NULL); peer 587 daemons/controld/controld_execd.c xml_state = create_node_state_update(peer, peer 595 daemons/controld/controld_execd.c crm_xml_add(xml_data, XML_ATTR_ID, peer->uuid); peer 1744 daemons/controld/controld_execd.c crm_node_t *peer = NULL; peer 1755 daemons/controld/controld_execd.c peer = crm_get_peer(0, controld_globals.our_nodename); peer 1756 daemons/controld/controld_execd.c update = create_node_state_update(peer, node_update_none, NULL, peer 207 daemons/controld/controld_fencing.c crm_node_t *peer = NULL; peer 225 daemons/controld/controld_fencing.c peer = pcmk__get_peer_full(0, target, uuid, CRM_GET_PEER_ANY); peer 227 daemons/controld/controld_fencing.c CRM_CHECK(peer != NULL, return); peer 229 daemons/controld/controld_fencing.c if (peer->state == NULL) { peer 237 daemons/controld/controld_fencing.c if (peer->uuid == NULL) { peer 239 daemons/controld/controld_fencing.c peer->uuid = strdup(uuid); peer 242 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 245 daemons/controld/controld_fencing.c node_state = create_node_state_update(peer, flags, NULL, __func__); peer 248 daemons/controld/controld_fencing.c if (peer->flags & crm_remote_node) { peer 272 daemons/controld/controld_fencing.c controld_delete_node_state(peer->uname, controld_section_all, peer 583 daemons/controld/controld_fencing.c crm_node_t *peer = pcmk__search_known_node_cache(0, event->target, peer 587 daemons/controld/controld_fencing.c if (peer == NULL) { peer 591 daemons/controld/controld_fencing.c uuid = crm_peer_uuid(peer); peer 617 daemons/controld/controld_fencing.c && !pcmk_is_set(peer->flags, crm_remote_node)) { peer 643 daemons/controld/controld_fencing.c if (pcmk_is_set(peer->flags, crm_remote_node)) { peer 647 daemons/controld/controld_fencing.c crmd_peer_down(peer, TRUE); peer 158 daemons/controld/controld_join_dc.c crm_node_t *peer = NULL; peer 163 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 164 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_none); peer 703 daemons/controld/controld_join_dc.c crm_node_t *peer = NULL; peer 735 daemons/controld/controld_join_dc.c peer = crm_get_peer(0, join_from); peer 736 daemons/controld/controld_join_dc.c if (peer->join != crm_join_finalized) { peer 739 daemons/controld/controld_join_dc.c join_id, join_from, crm_join_phase_str(peer->join), peer 748 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_nack); peer 752 daemons/controld/controld_join_dc.c crm_update_peer_join(__func__, peer, crm_join_confirmed); peer 1012 daemons/controld/controld_join_dc.c crm_node_t *peer; peer 1016 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 1017 daemons/controld/controld_join_dc.c if(peer->join == phase) { peer 1026 daemons/controld/controld_join_dc.c crm_node_t *peer; peer 1030 daemons/controld/controld_join_dc.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &peer)) { peer 1031 daemons/controld/controld_join_dc.c do_crm_log(level, "join-%d: %s=%s", current_join_id, peer->uname, peer 1032 daemons/controld/controld_join_dc.c crm_join_phase_str(peer->join)); peer 161 daemons/controld/controld_te_actions.c crm_node_t *peer = crm_get_peer(0, router_node); peer 163 daemons/controld/controld_te_actions.c pcmk__update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 470 daemons/controld/controld_te_actions.c struct te_peer_s *peer = p; peer 472 daemons/controld/controld_te_actions.c free(peer->name); peer 473 daemons/controld/controld_te_actions.c free(peer); peer 479 daemons/controld/controld_te_actions.c struct te_peer_s *peer = NULL; peer 486 daemons/controld/controld_te_actions.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & peer)) { peer 487 daemons/controld/controld_te_actions.c peer->jobs = 0; peer 488 daemons/controld/controld_te_actions.c peer->migrate_jobs = 0; peer 752 daemons/controld/controld_utils.c void crmd_peer_down(crm_node_t *peer, bool full) peer 754 daemons/controld/controld_utils.c if(full && peer->state == NULL) { peer 755 daemons/controld/controld_utils.c pcmk__update_peer_state(__func__, peer, CRM_NODE_LOST, 0); peer 756 daemons/controld/controld_utils.c crm_update_peer_proc(__func__, peer, crm_proc_none, NULL); peer 758 daemons/controld/controld_utils.c crm_update_peer_join(__func__, peer, crm_join_none); peer 759 daemons/controld/controld_utils.c pcmk__update_peer_expected(__func__, peer, CRMD_JOINSTATE_DOWN); peer 55 daemons/controld/controld_utils.h void crmd_peer_down(crm_node_t *peer, bool full); peer 3029 daemons/fenced/fenced_commands.c bool fencing_peer_active(crm_node_t *peer) peer 3031 daemons/fenced/fenced_commands.c if (peer == NULL) { peer 3033 daemons/fenced/fenced_commands.c } else if (peer->uname == NULL) { peer 3035 daemons/fenced/fenced_commands.c } else if (pcmk_is_set(peer->processes, crm_get_cluster_proc())) { peer 3211 daemons/fenced/fenced_commands.c if (request->peer != NULL) { peer 3238 daemons/fenced/fenced_commands.c pcmk__str_update(&query->remote_peer, request->peer); peer 3306 daemons/fenced/fenced_commands.c if ((request->peer != NULL) || stand_alone) { peer 3350 daemons/fenced/fenced_commands.c request->peer, action, target, peer 3402 daemons/fenced/fenced_commands.c stonith_fence_history(request->xml, &data, request->peer, peer 3580 daemons/fenced/fenced_commands.c request->peer, request->ipc_client); peer 3660 daemons/fenced/fenced_commands.c .peer = remote_peer, peer 85 daemons/fenced/fenced_remote.c peer_device_info_t *peer); peer 101 daemons/fenced/fenced_remote.c peer_device_info_t *peer = data; peer 103 daemons/fenced/fenced_remote.c g_hash_table_destroy(peer->devices); peer 104 daemons/fenced/fenced_remote.c free(peer->host); peer 105 daemons/fenced/fenced_remote.c free(peer); peer 159 daemons/fenced/fenced_remote.c const peer_device_info_t *peer, gboolean verified_only, uint32_t support_on_action_only) peer 167 daemons/fenced/fenced_remote.c if (peer) { peer 168 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, count_peer_device, &data); peer 184 daemons/fenced/fenced_remote.c find_peer_device(const remote_fencing_op_t *op, const peer_device_info_t *peer, peer 187 daemons/fenced/fenced_remote.c device_properties_t *props = g_hash_table_lookup(peer->devices, device); peer 208 daemons/fenced/fenced_remote.c grab_peer_device(const remote_fencing_op_t *op, peer_device_info_t *peer, peer 211 daemons/fenced/fenced_remote.c device_properties_t *props = find_peer_device(op, peer, device, peer 219 daemons/fenced/fenced_remote.c device, peer->host, count_peer_devices(op, peer, FALSE, st_device_supports_none)); peer 1137 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer) peer 1148 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1168 daemons/fenced/fenced_remote.c if (peer && dev) { peer 1213 daemons/fenced/fenced_remote.c (peer && dev)? "Recorded" : "Generated", op->id, op->action, peer 1362 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter->data; peer 1365 daemons/fenced/fenced_remote.c peer->host, op->target, peer->ndevices, peer 1366 daemons/fenced/fenced_remote.c pcmk__plural_s(peer->ndevices), peer->tried, options); peer 1367 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_SKIP_TARGET) && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1370 daemons/fenced/fenced_remote.c if ((options & FIND_PEER_TARGET_ONLY) && !pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 1376 daemons/fenced/fenced_remote.c if (grab_peer_device(op, peer, device, verified_devices_only)) { peer 1377 daemons/fenced/fenced_remote.c return peer; peer 1380 daemons/fenced/fenced_remote.c } else if (!peer->tried peer 1381 daemons/fenced/fenced_remote.c && count_peer_devices(op, peer, verified_devices_only, peer 1385 daemons/fenced/fenced_remote.c return peer; peer 1396 daemons/fenced/fenced_remote.c peer_device_info_t *peer = NULL; peer 1410 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET|FIND_PEER_VERIFIED_ONLY); peer 1411 daemons/fenced/fenced_remote.c if (peer) { peer 1412 daemons/fenced/fenced_remote.c crm_trace("Found verified peer %s for %s", peer->host, device?device:"<any>"); peer 1413 daemons/fenced/fenced_remote.c return peer; peer 1422 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_SKIP_TARGET); peer 1423 daemons/fenced/fenced_remote.c if (peer) { peer 1424 daemons/fenced/fenced_remote.c crm_trace("Found best unverified peer %s", peer->host); peer 1425 daemons/fenced/fenced_remote.c return peer; peer 1432 daemons/fenced/fenced_remote.c peer = find_best_peer(device, op, FIND_PEER_TARGET_ONLY); peer 1433 daemons/fenced/fenced_remote.c if (peer) { peer 1434 daemons/fenced/fenced_remote.c crm_trace("%s will fence itself", peer->host); peer 1435 daemons/fenced/fenced_remote.c return peer; peer 1462 daemons/fenced/fenced_remote.c const peer_device_info_t *peer, const char *device, peer 1468 daemons/fenced/fenced_remote.c if (!peer || !device) { peer 1472 daemons/fenced/fenced_remote.c props = g_hash_table_lookup(peer->devices, device); peer 1491 daemons/fenced/fenced_remote.c const peer_device_info_t *peer; peer 1512 daemons/fenced/fenced_remote.c timeout->total_timeout += get_device_timeout(timeout->op, timeout->peer, peer 1518 daemons/fenced/fenced_remote.c get_peer_timeout(const remote_fencing_op_t *op, const peer_device_info_t *peer) peer 1523 daemons/fenced/fenced_remote.c timeout.peer = peer; peer 1526 daemons/fenced/fenced_remote.c g_hash_table_foreach(peer->devices, add_device_timeout, &timeout); peer 1574 daemons/fenced/fenced_remote.c const peer_device_info_t *peer = iter->data; peer 1584 daemons/fenced/fenced_remote.c if (find_peer_device(op, peer, device_list->data, peer 1586 daemons/fenced/fenced_remote.c total_timeout += get_device_timeout(op, peer, peer 1601 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter2->data; peer 1602 daemons/fenced/fenced_remote.c if (find_peer_device(op, peer, iter->data, st_device_supports_on)) { peer 1603 daemons/fenced/fenced_remote.c total_timeout += get_device_timeout(op, peer, peer 1773 daemons/fenced/fenced_remote.c request_peer_fencing(remote_fencing_op_t *op, peer_device_info_t *peer) peer 1814 daemons/fenced/fenced_remote.c if ((peer == NULL) && !pcmk_is_set(op->call_options, st_opt_topology)) { peer 1815 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1819 daemons/fenced/fenced_remote.c op->total_timeout = TIMEOUT_MULTIPLY_FACTOR * get_op_total_timeout(op, peer); peer 1836 daemons/fenced/fenced_remote.c peer = stonith_choose_peer(op); peer 1843 daemons/fenced/fenced_remote.c timeout = get_device_timeout(op, peer, device, false); peer 1846 daemons/fenced/fenced_remote.c if (peer) { peer 1869 daemons/fenced/fenced_remote.c get_device_timeout(op, peer, device, true); peer 1872 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, device, peer 1877 daemons/fenced/fenced_remote.c timeout_one += TIMEOUT_MULTIPLY_FACTOR * get_peer_timeout(op, peer); peer 1880 daemons/fenced/fenced_remote.c peer->host, op->action, op->target, op->client_name, peer 1892 daemons/fenced/fenced_remote.c || (pcmk__str_eq(peer->host, op->target, pcmk__str_casei) peer 1919 daemons/fenced/fenced_remote.c send_cluster_message(crm_get_peer(0, peer->host), crm_msg_stonith_ng, remote_op, FALSE); peer 1920 daemons/fenced/fenced_remote.c peer->tried = TRUE; peer 2047 daemons/fenced/fenced_remote.c peer_device_info_t *peer = iter->data; peer 2049 daemons/fenced/fenced_remote.c if (skip_target && pcmk__str_eq(peer->host, op->target, pcmk__str_casei)) { peer 2052 daemons/fenced/fenced_remote.c match = find_peer_device(op, peer, device->data, st_device_supports_none); peer 2076 daemons/fenced/fenced_remote.c parse_action_specific(const xmlNode *xml, const char *peer, const char *device, peer 2085 daemons/fenced/fenced_remote.c peer, device, action, props->custom_action_timeout[phase]); peer 2092 daemons/fenced/fenced_remote.c peer, device, props->delay_max[phase], action); peer 2099 daemons/fenced/fenced_remote.c peer, device, props->delay_base[phase], action); peer 2109 daemons/fenced/fenced_remote.c peer, device, action); peer 2120 daemons/fenced/fenced_remote.c peer, action, device); peer 2135 daemons/fenced/fenced_remote.c peer_device_info_t *peer, const char *device) peer 2144 daemons/fenced/fenced_remote.c g_hash_table_insert(peer->devices, strdup(device), props); peer 2150 daemons/fenced/fenced_remote.c peer->host, device); peer 2158 daemons/fenced/fenced_remote.c parse_action_specific(xml, peer->host, device, op_requested_action(op), peer 2167 daemons/fenced/fenced_remote.c parse_action_specific(child, peer->host, device, PCMK_ACTION_OFF, peer 2170 daemons/fenced/fenced_remote.c parse_action_specific(child, peer->host, device, PCMK_ACTION_ON, peer 2191 daemons/fenced/fenced_remote.c peer_device_info_t *peer = calloc(1, sizeof(peer_device_info_t)); peer 2196 daemons/fenced/fenced_remote.c CRM_CHECK(peer != NULL, return NULL); peer 2197 daemons/fenced/fenced_remote.c peer->host = strdup(host); peer 2198 daemons/fenced/fenced_remote.c peer->devices = pcmk__strkey_table(free, free); peer 2206 daemons/fenced/fenced_remote.c add_device_properties(child, op, peer, device); peer 2210 daemons/fenced/fenced_remote.c peer->ndevices = g_hash_table_size(peer->devices); peer 2211 daemons/fenced/fenced_remote.c CRM_CHECK(ndevices == peer->ndevices, peer 2213 daemons/fenced/fenced_remote.c ndevices, pcmk__plural_s(ndevices), peer->ndevices)); peer 2215 daemons/fenced/fenced_remote.c op->query_results = g_list_insert_sorted(op->query_results, peer, sort_peers); peer 2216 daemons/fenced/fenced_remote.c return peer; peer 2242 daemons/fenced/fenced_remote.c peer_device_info_t *peer = NULL; peer 2276 daemons/fenced/fenced_remote.c peer = add_result(op, host, ndevices, dev); peer 2288 daemons/fenced/fenced_remote.c request_peer_fencing(op, peer); peer 2297 daemons/fenced/fenced_remote.c int nverified = count_peer_devices(op, peer, TRUE, peer 2302 daemons/fenced/fenced_remote.c if ((peer != NULL) && !host_is_target && nverified) { peer 2306 daemons/fenced/fenced_remote.c request_peer_fencing(op, peer); peer 2317 daemons/fenced/fenced_remote.c } else if ((peer != NULL) && (op->state == st_done)) { peer 2319 daemons/fenced/fenced_remote.c "Operation is %s", peer->host, peer 2320 daemons/fenced/fenced_remote.c peer->ndevices, pcmk__plural_s(peer->ndevices), peer 271 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); peer 278 daemons/fenced/pacemaker-fenced.h bool fencing_peer_active(crm_node_t *peer); peer 232 daemons/pacemakerd/pcmkd_messages.c .peer = NULL, peer 268 daemons/schedulerd/schedulerd_messages.c .peer = NULL, peer 113 include/crm/cluster/internal.h crm_node_t *crm_update_peer_proc(const char *source, crm_node_t * peer, peer 41 include/crm/common/messages_internal.h const char *peer; // Peer name (NULL if not via cluster) peer 94 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { peer 115 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { peer 116 include/crm/common/messages_internal.h return request->peer; peer 346 lib/cib/cib_ops.c const char *peer = crm_element_value(req, F_ORIG); peer 356 lib/cib/cib_ops.c crm_err("Digest mis-match on replace from %s: %s vs. %s (expected)", peer, peer 361 lib/cib/cib_ops.c crm_info("Digest matched on replace from %s: %s", peer, digest); peer 392 lib/cib/cib_ops.c replace_updates, peer, admin_epoch, epoch, updates, reason); peer 397 lib/cib/cib_ops.c replace_admin_epoch, replace_epoch, replace_updates, peer); peer 38 lib/cluster/cluster.c crm_peer_uuid(crm_node_t *peer) peer 43 lib/cluster/cluster.c if (peer == NULL) { peer 46 lib/cluster/cluster.c if (peer->uuid != NULL) { peer 47 lib/cluster/cluster.c return peer->uuid; peer 53 lib/cluster/cluster.c uuid = pcmk__corosync_uuid(peer); peer 63 lib/cluster/cluster.c peer->uuid = uuid; peer 64 lib/cluster/cluster.c return peer->uuid; peer 453 lib/cluster/corosync.c crm_node_t *peer = NULL; peer 483 lib/cluster/corosync.c peer = crm_get_peer(cluster->nodeid, cluster->uname); peer 484 lib/cluster/corosync.c cluster->uuid = pcmk__corosync_uuid(peer); peer 468 lib/cluster/cpg.c crm_node_t *peer = crm_get_peer(nodeid, NULL); peer 470 lib/cluster/cpg.c if (peer == NULL) { peer 473 lib/cluster/cpg.c } else if (peer->uname == NULL) { peer 478 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); peer 480 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); peer 602 lib/cluster/cpg.c peer_name(const crm_node_t *peer) peer 604 lib/cluster/cpg.c if (peer == NULL) { peer 606 lib/cluster/cpg.c } else if (peer->uname == NULL) { peer 609 lib/cluster/cpg.c return peer->uname; peer 630 lib/cluster/cpg.c crm_node_t *peer = pcmk__search_cluster_node_cache(cpg_peer->nodeid, peer 646 lib/cluster/cpg.c if (peer != NULL) { peer 654 lib/cluster/cpg.c cpg_group_name, event_counter, peer_name(peer), peer 657 lib/cluster/cpg.c if (peer != NULL) { peer 658 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 668 lib/cluster/cpg.c cpg_group_name, event_counter, peer_name(peer), peer 723 lib/cluster/cpg.c crm_node_t *peer = crm_get_peer(member_list[i].nodeid, NULL); peer 733 lib/cluster/cpg.c groupName->value, counter, peer_name(peer), peer 739 lib/cluster/cpg.c peer = crm_update_peer_proc(__func__, peer, crm_proc_cpg, peer 742 lib/cluster/cpg.c if (peer && peer->state && strcmp(peer->state, CRM_NODE_MEMBER)) { peer 752 lib/cluster/cpg.c if (peer->when_lost == 0) { peer 754 lib/cluster/cpg.c peer->when_lost = now; peer 756 lib/cluster/cpg.c } else if (now > (peer->when_lost + 60)) { peer 760 lib/cluster/cpg.c pcmk__update_peer_state(__func__, peer, CRM_NODE_MEMBER, 0); peer 791 lib/cluster/cpg.c crm_node_t *peer = NULL; peer 876 lib/cluster/cpg.c peer = crm_get_peer(id, NULL); peer 877 lib/cluster/cpg.c crm_update_peer_proc(__func__, peer, crm_proc_cpg, ONLINESTATUS); peer 31 lib/cluster/crmcluster_private.h char *pcmk__corosync_uuid(const crm_node_t *peer); peer 504 lib/cluster/election.c send_no_vote(crm_node_t *peer, struct vote *vote) peer 514 lib/cluster/election.c send_cluster_message(peer, crm_msg_crmd, novote, TRUE); peer 69 lib/cluster/membership.c #define set_peer_flags(peer, flags_to_set) do { \ peer 70 lib/cluster/membership.c (peer)->flags = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \ peer 71 lib/cluster/membership.c "Peer", (peer)->uname, \ peer 72 lib/cluster/membership.c (peer)->flags, (flags_to_set), \ peer 76 lib/cluster/membership.c #define clear_peer_flags(peer, flags_to_clear) do { \ peer 77 lib/cluster/membership.c (peer)->flags = pcmk__clear_flags_as(__func__, __LINE__, \ peer 79 lib/cluster/membership.c "Peer", (peer)->uname, \ peer 80 lib/cluster/membership.c (peer)->flags, (flags_to_clear), \