node 137 daemons/attrd/attrd_alerts.c attrd_send_attribute_alert(const char *node, int nodeid, node 144 daemons/attrd/attrd_alerts.c node, nodeid, attr, value); node 60 daemons/attrd/attrd_commands.c send_attrd_message(crm_node_t * node, xmlNode * data) node 65 daemons/attrd/attrd_commands.c return send_cluster_message(node, crm_msg_attrd, data, TRUE); node 202 daemons/attrd/attrd_commands.c crm_node_t *node = crm_find_peer(nodeid, NULL); node 205 daemons/attrd/attrd_commands.c if (node && node->uname) { node 207 daemons/attrd/attrd_commands.c host = node->uname; node 68 daemons/attrd/pacemaker-attrd.h int attrd_send_attribute_alert(const char *node, int nodeid, node 278 daemons/based/pacemaker-based.c cib_peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 283 daemons/based/pacemaker-based.c && !pcmk_is_set(node->processes, crm_get_cluster_proc())) { node 287 daemons/based/pacemaker-based.c if ((node->processes ^ old) & crm_proc_cpg) { node 289 daemons/based/pacemaker-based.c node->uname); node 16 daemons/controld/controld_alerts.h void crmd_alert_node_event(crm_node_t *node); node 18 daemons/controld/controld_alerts.h void crmd_alert_resource_op(const char *node, lrmd_event_data_t *op); node 286 daemons/controld/controld_based.c controld_delete_resource_history(const char *rsc_id, const char *node, node 293 daemons/controld/controld_based.c CRM_CHECK((rsc_id != NULL) && (node != NULL), return EINVAL); node 295 daemons/controld/controld_based.c desc = crm_strdup_printf("resource history for %s on %s", rsc_id, node); node 303 daemons/controld/controld_based.c xpath = crm_strdup_printf(XPATH_RESOURCE_HISTORY, node, rsc_id); node 310 daemons/controld/controld_based.c CRM_XS " rc=%d", rsc_id, node, node 80 daemons/controld/controld_callbacks.c node_alive(const crm_node_t *node) node 82 daemons/controld/controld_callbacks.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 84 daemons/controld/controld_callbacks.c return pcmk__str_eq(node->state, CRM_NODE_MEMBER, pcmk__str_casei) ? 1: -1; node 86 daemons/controld/controld_callbacks.c } else if (crm_is_peer_active(node)) { node 90 daemons/controld/controld_callbacks.c } else if (!pcmk_is_set(node->processes, crm_get_cluster_proc()) node 91 daemons/controld/controld_callbacks.c && !pcmk__str_eq(node->state, CRM_NODE_MEMBER, pcmk__str_casei)) { node 103 daemons/controld/controld_callbacks.c peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 107 daemons/controld/controld_callbacks.c bool is_remote = pcmk_is_set(node->flags, crm_remote_node); node 117 daemons/controld/controld_callbacks.c if (node->uname == NULL) { node 126 daemons/controld/controld_callbacks.c node->uname, state_text(node->state)); node 133 daemons/controld/controld_callbacks.c CRM_CHECK(!pcmk__str_eq(data, node->state, pcmk__str_casei), node 138 daemons/controld/controld_callbacks.c node->uname, state_text(node->state), state_text(data)); node 140 daemons/controld/controld_callbacks.c if (pcmk__str_eq(CRM_NODE_MEMBER, node->state, pcmk__str_casei)) { node 143 daemons/controld/controld_callbacks.c remove_stonith_cleanup(node->uname); node 146 daemons/controld/controld_callbacks.c controld_remove_voter(node->uname); node 149 daemons/controld/controld_callbacks.c crmd_alert_node_event(node); node 155 daemons/controld/controld_callbacks.c appeared = pcmk_is_set(node->processes, crm_get_cluster_proc()); node 158 daemons/controld/controld_callbacks.c node->uname, (appeared? "now" : "no longer"), node 160 daemons/controld/controld_callbacks.c old, node->processes); node 162 daemons/controld/controld_callbacks.c if (!pcmk_is_set((node->processes ^ old), crm_get_cluster_proc())) { node 167 daemons/controld/controld_callbacks.c crm_get_cluster_proc(), old, node->processes); node 173 daemons/controld/controld_callbacks.c controld_remove_voter(node->uname); node 185 daemons/controld/controld_callbacks.c if (pcmk__str_eq(node->uname, fsa_our_uname, pcmk__str_casei) && !appeared) { node 190 daemons/controld/controld_callbacks.c } else if (pcmk__str_eq(node->uname, fsa_our_dc, pcmk__str_casei) && crm_is_peer_active(node) == FALSE) { node 204 daemons/controld/controld_callbacks.c controld_delete_node_state(node->uname, node 217 daemons/controld/controld_callbacks.c controld_delete_node_state(node->uname, node 228 daemons/controld/controld_callbacks.c int alive = node_alive(node); node 229 daemons/controld/controld_callbacks.c crm_action_t *down = match_down_event(node->uuid); node 245 daemons/controld/controld_callbacks.c (down->confirmed? "after" : "before"), node->uname); node 252 daemons/controld/controld_callbacks.c crmd_peer_down(node, FALSE); node 257 daemons/controld/controld_callbacks.c task, node->uname, down->id); node 260 daemons/controld/controld_callbacks.c task, node->uname, down->id); node 267 daemons/controld/controld_callbacks.c node->uname, node 275 daemons/controld/controld_callbacks.c node->uname); node 277 daemons/controld/controld_callbacks.c crm_update_peer_join(__func__, node, crm_join_none); node 281 daemons/controld/controld_callbacks.c fail_incompletable_actions(transition_graph, node->uuid); node 285 daemons/controld/controld_callbacks.c node->uname); node 302 daemons/controld/controld_callbacks.c update = create_node_state_update(node, flags, NULL, __func__); node 304 daemons/controld/controld_callbacks.c crm_debug("Node state update not yet possible for %s", node->uname); node 19 daemons/controld/controld_callbacks.h extern void peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data); node 258 daemons/controld/controld_election.c crm_node_t *node = crm_get_peer(0, fsa_our_uname); node 260 daemons/controld/controld_election.c crm_update_peer_expected(__func__, node, CRMD_JOINSTATE_DOWN); node 261 daemons/controld/controld_election.c update = create_node_state_update(node, node_update_expected, NULL, node 767 daemons/controld/controld_execd_state.c crmd_alert_node_event(crm_node_t *node) node 781 daemons/controld/controld_execd_state.c node->uname, node->id, node->state); node 811 daemons/controld/controld_execd_state.c crmd_alert_resource_op(const char *node, lrmd_event_data_t * op) node 824 daemons/controld/controld_execd_state.c lrmd_send_resource_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, node, node 36 daemons/controld/controld_join_dc.c crm_update_peer_join(const char *source, crm_node_t * node, enum crm_join_phase phase) node 40 daemons/controld/controld_join_dc.c CRM_CHECK(node != NULL, return); node 43 daemons/controld/controld_join_dc.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 47 daemons/controld/controld_join_dc.c last = node->join; node 52 daemons/controld/controld_join_dc.c node->uname, current_join_id, crm_join_phase_str(last), node 53 daemons/controld/controld_join_dc.c node->id, source); node 56 daemons/controld/controld_join_dc.c node->join = phase; node 59 daemons/controld/controld_join_dc.c node->uname, current_join_id, crm_join_phase_str(phase), node 60 daemons/controld/controld_join_dc.c crm_join_phase_str(last), node->id, source); node 65 daemons/controld/controld_join_dc.c current_join_id, node->uname, crm_join_phase_str(last), node 66 daemons/controld/controld_join_dc.c crm_join_phase_str(phase), node->id, source); node 34 daemons/controld/controld_membership.c crm_node_t *node = value; node 36 daemons/controld/controld_membership.c if (crm_is_peer_active(node) == FALSE) { node 37 daemons/controld/controld_membership.c crm_update_peer_join(__func__, node, crm_join_none); node 39 daemons/controld/controld_membership.c if(node && node->uname) { node 40 daemons/controld/controld_membership.c if (pcmk__str_eq(fsa_our_uname, node->uname, pcmk__str_casei)) { node 44 daemons/controld/controld_membership.c } else if (AM_I_DC == FALSE && pcmk__str_eq(node->uname, fsa_our_dc, pcmk__str_casei)) { node 45 daemons/controld/controld_membership.c crm_warn("Our DC node (%s) left the cluster", node->uname); node 53 daemons/controld/controld_membership.c if(node && node->uuid) { node 54 daemons/controld/controld_membership.c fail_incompletable_actions(transition_graph, node->uuid); node 127 daemons/controld/controld_membership.c create_node_state_update(crm_node_t *node, int flags, xmlNode *parent, node 133 daemons/controld/controld_membership.c if (!node->state) { node 134 daemons/controld/controld_membership.c crm_info("Node update for %s cancelled: no state, not seen yet", node->uname); node 140 daemons/controld/controld_membership.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 144 daemons/controld/controld_membership.c set_uuid(node_state, XML_ATTR_UUID, node); node 147 daemons/controld/controld_membership.c crm_info("Node update for %s cancelled: no id", node->uname); node 152 daemons/controld/controld_membership.c crm_xml_add(node_state, XML_ATTR_UNAME, node->uname); node 154 daemons/controld/controld_membership.c if ((flags & node_update_cluster) && node->state) { node 156 daemons/controld/controld_membership.c pcmk__str_eq(node->state, CRM_NODE_MEMBER, pcmk__str_casei)); node 159 daemons/controld/controld_membership.c if (!pcmk_is_set(node->flags, crm_remote_node)) { node 162 daemons/controld/controld_membership.c if (pcmk_is_set(node->processes, crm_get_cluster_proc())) { node 169 daemons/controld/controld_membership.c if (node->join <= crm_join_none) { node 178 daemons/controld/controld_membership.c crm_xml_add(node_state, XML_NODE_EXPECTED, node->expected); node 227 daemons/controld/controld_membership.c crm_node_t *node = NULL; node 242 daemons/controld/controld_membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 243 daemons/controld/controld_membership.c if (node->uuid node 244 daemons/controld/controld_membership.c && pcmk__str_eq(node->uuid, node_uuid, pcmk__str_casei) node 245 daemons/controld/controld_membership.c && node->uname node 246 daemons/controld/controld_membership.c && pcmk__str_eq(node->uname, node_uname, pcmk__str_casei)) { node 313 daemons/controld/controld_membership.c crm_node_t *node = NULL; node 316 daemons/controld/controld_membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 319 daemons/controld/controld_membership.c crm_trace("Creating node entry for %s/%s", node->uname, node->uuid); node 320 daemons/controld/controld_membership.c if(node->uuid && node->uname) { node 325 daemons/controld/controld_membership.c crm_xml_add(new_node, XML_ATTR_ID, node->uuid); node 326 daemons/controld/controld_membership.c crm_xml_add(new_node, XML_ATTR_UNAME, node->uname); node 332 daemons/controld/controld_membership.c node->uname, node->uuid); node 336 daemons/controld/controld_membership.c fsa_register_cib_callback(call_id, FALSE, strdup(node->uuid), node 355 daemons/controld/controld_membership.c crm_node_t *node = NULL; node 360 daemons/controld/controld_membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 361 daemons/controld/controld_membership.c create_node_state_update(node, flags, node_list, source); node 366 daemons/controld/controld_membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 367 daemons/controld/controld_membership.c create_node_state_update(node, flags, node_list, source); node 665 daemons/controld/controld_messages.c const char *node = NULL; node 674 daemons/controld/controld_messages.c node = crm_element_value(msg_data, XML_LRM_ATTR_TARGET); node 679 daemons/controld/controld_messages.c "(clearing CIB resource history only)", rsc_id, node, node 682 daemons/controld/controld_messages.c rc = controld_delete_resource_history(rsc_id, node, user_name, node 686 daemons/controld/controld_messages.c rc = controld_delete_resource_history(rsc_id, node, user_name, node 797 daemons/controld/controld_messages.c crm_node_t *node = NULL; node 804 daemons/controld/controld_messages.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 807 daemons/controld/controld_messages.c crm_xml_add_ll(xml, XML_ATTR_ID, (long long) node->id); // uint32_t node 808 daemons/controld/controld_messages.c crm_xml_add(xml, XML_ATTR_UNAME, node->uname); node 809 daemons/controld/controld_messages.c crm_xml_add(xml, XML_NODE_IN_CLUSTER, node->state); node 835 daemons/controld/controld_messages.c crm_node_t *node = NULL; node 859 daemons/controld/controld_messages.c node = crm_find_peer_full(node_id, value, CRM_GET_PEER_ANY); node 860 daemons/controld/controld_messages.c if (node) { node 861 daemons/controld/controld_messages.c crm_xml_add_int(reply, XML_ATTR_ID, node->id); node 862 daemons/controld/controld_messages.c crm_xml_add(reply, XML_ATTR_UUID, node->uuid); node 863 daemons/controld/controld_messages.c crm_xml_add(reply, XML_ATTR_UNAME, node->uname); node 864 daemons/controld/controld_messages.c crm_xml_add(reply, XML_NODE_IS_PEER, node->state); node 866 daemons/controld/controld_messages.c node->flags & crm_remote_node); node 983 daemons/controld/controld_messages.c crm_node_t *node = crm_find_peer(0, from); node 985 daemons/controld/controld_messages.c crm_update_peer_expected(__func__, node, CRMD_JOINSTATE_DOWN); node 180 daemons/controld/controld_remote_ra.c crm_node_t *node; node 201 daemons/controld/controld_remote_ra.c node = crm_remote_peer_get(node_name); node 202 daemons/controld/controld_remote_ra.c CRM_CHECK(node != NULL, return); node 203 daemons/controld/controld_remote_ra.c crm_update_peer_state(__func__, node, CRM_NODE_MEMBER, 0); node 214 daemons/controld/controld_remote_ra.c state = create_node_state_update(node, node_update_cluster, update, node 255 daemons/controld/controld_remote_ra.c crm_node_t *node; node 272 daemons/controld/controld_remote_ra.c node = crm_remote_peer_get(node_name); node 273 daemons/controld/controld_remote_ra.c CRM_CHECK(node != NULL, return); node 274 daemons/controld/controld_remote_ra.c crm_update_peer_state(__func__, node, CRM_NODE_LOST, 0); node 281 daemons/controld/controld_remote_ra.c create_node_state_update(node, node_update_cluster, update, __func__); node 314 daemons/controld/controld_remote_ra.c crm_node_t *node = crm_remote_peer_get(cmd->rsc_id); node 316 daemons/controld/controld_remote_ra.c CRM_CHECK(node != NULL, return); node 317 daemons/controld/controld_remote_ra.c crm_update_peer_state(__func__, node, CRM_NODE_MEMBER, 0); node 1225 daemons/controld/controld_remote_ra.c crm_node_t *node; node 1228 daemons/controld/controld_remote_ra.c node = crm_remote_peer_get(lrm_state->node_name); node 1229 daemons/controld/controld_remote_ra.c CRM_CHECK(node != NULL, return); node 1231 daemons/controld/controld_remote_ra.c state = create_node_state_update(node, node_update_none, update, node 1261 daemons/controld/controld_remote_ra.c xmlNode *node; node 1264 daemons/controld/controld_remote_ra.c for (node = node 1266 daemons/controld/controld_remote_ra.c node != NULL; node = pcmk__xml_next(node)) { node 1267 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(ID(node)); node 1274 daemons/controld/controld_remote_ra.c crm_atoi(crm_element_value(node, node 48 daemons/controld/controld_te_actions.c crm_node_t *node = NULL; node 51 daemons/controld/controld_te_actions.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 54 daemons/controld/controld_te_actions.c if (pcmk__str_eq(fsa_our_uname, node->uname, pcmk__str_casei)) { node 58 daemons/controld/controld_te_actions.c cmd = create_request(task, pseudo->xml, node->uname, node 60 daemons/controld/controld_te_actions.c send_cluster_message(node, crm_msg_crmd, cmd, FALSE); node 168 daemons/controld/controld_te_callbacks.c const char *node = get_node_id(rsc_op); node 170 daemons/controld/controld_te_callbacks.c process_graph_event(rsc_op, node); node 197 daemons/controld/controld_te_callbacks.c const char *node = get_node_id(match); node 198 daemons/controld/controld_te_callbacks.c crm_action_t *cancelled = get_cancel_action(op_id, node); node 202 daemons/controld/controld_te_callbacks.c node); node 210 daemons/controld/controld_te_callbacks.c op_id, node, cancelled->id); node 223 daemons/controld/controld_te_callbacks.c process_lrm_resource_diff(xmlNode *lrm_resource, const char *node) node 227 daemons/controld/controld_te_callbacks.c process_graph_event(rsc_op, node); node 237 daemons/controld/controld_te_callbacks.c process_resource_updates(const char *node, xmlNode *xml, xmlNode *change, node 275 daemons/controld/controld_te_callbacks.c process_lrm_resource_diff(rsc, node); node 636 daemons/controld/controld_te_callbacks.c const char *node = get_node_id(rsc_op); node 638 daemons/controld/controld_te_callbacks.c process_graph_event(rsc_op, node); node 64 daemons/controld/controld_te_events.c crm_node_t *node = crm_get_peer(0, router); node 65 daemons/controld/controld_te_events.c if (node) { node 66 daemons/controld/controld_te_events.c router_uuid = node->uuid; node 217 daemons/controld/controld_te_events.c get_cancel_action(const char *id, const char *node) node 239 daemons/controld/controld_te_events.c crm_trace("Wrong key %s for %s on %s", task, id, node); node 244 daemons/controld/controld_te_events.c if (node && !pcmk__str_eq(target, node, pcmk__str_casei)) { node 245 daemons/controld/controld_te_events.c crm_trace("Wrong node %s for %s on %s", target, id, node); node 249 daemons/controld/controld_te_events.c crm_trace("Found %s on %s", id, node); node 39 daemons/controld/controld_throttle.c char *node; node 389 daemons/controld/controld_throttle.c free(r->node); node 493 daemons/controld/controld_throttle.c throttle_get_job_limit(const char *node) node 498 daemons/controld/controld_throttle.c r = g_hash_table_lookup(throttle_records, node); node 501 daemons/controld/controld_throttle.c r->node = strdup(node); node 504 daemons/controld/controld_throttle.c crm_trace("Defaulting to local values for unknown node %s", node); node 506 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); node 524 daemons/controld/controld_throttle.c crm_err("Unknown throttle mode %.4x on %s", r->mode, node); node 545 daemons/controld/controld_throttle.c r->node = strdup(from); node 546 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); node 26 daemons/controld/controld_throttle.h int throttle_get_job_limit(const char *node); node 18 daemons/controld/controld_transition.h extern crm_action_t *get_cancel_action(const char *id, const char *node); node 867 daemons/controld/controld_utils.c xmlNode *node = lrm_rsc_op; node 869 daemons/controld/controld_utils.c while (node != NULL && !pcmk__str_eq(XML_CIB_TAG_STATE, TYPE(node), pcmk__str_casei)) { node 870 daemons/controld/controld_utils.c node = node->parent; node 873 daemons/controld/controld_utils.c CRM_CHECK(node != NULL, return NULL); node 874 daemons/controld/controld_utils.c return ID(node); node 80 daemons/controld/controld_utils.h void crm_update_peer_join(const char *source, crm_node_t * node, enum crm_join_phase phase); node 81 daemons/controld/controld_utils.h xmlNode *create_node_state_update(crm_node_t *node, int flags, node 112 daemons/controld/controld_utils.h int controld_delete_resource_history(const char *rsc_id, const char *node, node 489 daemons/fenced/fenced_commands.c crm_node_t *node = crm_get_peer(0, cmd->victim); node 491 daemons/fenced/fenced_commands.c cmd->victim_nodeid = node->id; node 2326 daemons/fenced/fenced_commands.c crm_node_t *node = crm_find_known_peer_full(nodeid, NULL, CRM_GET_PEER_ANY); node 2328 daemons/fenced/fenced_commands.c if (node) { node 2329 daemons/fenced/fenced_commands.c host = node->uname; node 412 daemons/fenced/fenced_history.c crm_node_t *node = crm_find_known_peer_full(nodeid, NULL, CRM_GET_PEER_ANY); node 414 daemons/fenced/fenced_history.c if (node) { node 415 daemons/fenced/fenced_history.c target = node->uname; node 741 daemons/fenced/fenced_remote.c topology_matches(const stonith_topology_t *tp, const char *node) node 745 daemons/fenced/fenced_remote.c CRM_CHECK(node && tp && tp->target, return FALSE); node 754 daemons/fenced/fenced_remote.c if (node_has_attr(node, tp->target_attribute, tp->target_value)) { node 755 daemons/fenced/fenced_remote.c crm_notice("Matched %s with %s by attribute", node, tp->target); node 767 daemons/fenced/fenced_remote.c int status = regexec(&r_patt, node, 0, NULL, 0); node 771 daemons/fenced/fenced_remote.c crm_notice("Matched %s with %s by name", node, tp->target); node 777 daemons/fenced/fenced_remote.c crm_trace("Testing %s against %s", node, tp->target); node 778 daemons/fenced/fenced_remote.c return pcmk__str_eq(tp->target, node, pcmk__str_casei); node 780 daemons/fenced/fenced_remote.c crm_trace("No match for %s with %s", node, tp->target); node 1066 daemons/fenced/fenced_remote.c crm_node_t *node = crm_find_known_peer_full(nodeid, NULL, CRM_GET_PEER_ANY); node 1071 daemons/fenced/fenced_remote.c if (node && node->uname) { node 1073 daemons/fenced/fenced_remote.c op->target = strdup(node->uname); node 400 daemons/fenced/pacemaker-fenced.c topology_remove_helper(const char *node, int level) node 408 daemons/fenced/pacemaker-fenced.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 557 daemons/fenced/pacemaker-fenced.c pe_node_t *node = NULL; node 561 daemons/fenced/pacemaker-fenced.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 562 daemons/fenced/pacemaker-fenced.c if (node && strcmp(node->details->uname, stonith_our_uname) == 0) { node 565 daemons/fenced/pacemaker-fenced.c node = NULL; node 568 daemons/fenced/pacemaker-fenced.c return node; node 581 daemons/fenced/pacemaker-fenced.c pe_node_t *node = NULL; node 615 daemons/fenced/pacemaker-fenced.c node = our_node_allowed_for(rsc); node 620 daemons/fenced/pacemaker-fenced.c if(node == NULL) { node 626 daemons/fenced/pacemaker-fenced.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 627 daemons/fenced/pacemaker-fenced.c crm_trace("Available: %s = %d", node->details->uname, node->weight); node 632 daemons/fenced/pacemaker-fenced.c } else if(node->weight < 0 || (parent && parent->weight < 0)) { node 634 daemons/fenced/pacemaker-fenced.c char *score = score2char((node->weight < 0) ? node->weight : parent->weight); node 652 daemons/fenced/pacemaker-fenced.c crm_debug("Device %s is allowed on %s: score=%d", rsc->id, stonith_our_uname, node->weight); node 653 daemons/fenced/pacemaker-fenced.c get_rsc_attributes(rsc->parameters, rsc, node, data_set); node 654 daemons/fenced/pacemaker-fenced.c get_meta_attributes(rsc->meta, rsc, node, data_set); node 871 daemons/fenced/pacemaker-fenced.c node_has_attr(const char *node, const char *name, const char *value) node 887 daemons/fenced/pacemaker-fenced.c node, name, value); node 1249 daemons/fenced/pacemaker-fenced.c st_peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 1252 daemons/fenced/pacemaker-fenced.c && !pcmk_is_set(node->flags, crm_remote_node)) { node 1263 daemons/fenced/pacemaker-fenced.c crm_debug("Broadcasting our uname because of node %u", node->id); node 263 daemons/fenced/pacemaker-fenced.h gboolean node_has_attr(const char *node, const char *name, const char *value); node 120 include/crm/cluster.h gboolean send_cluster_message(crm_node_t * node, enum crm_ais_msg_types service, node 138 include/crm/cluster.h gboolean crm_is_peer_active(const crm_node_t * node); node 154 include/crm/cluster.h gboolean crm_is_corosync_peer_active(const crm_node_t * node); node 156 include/crm/cluster.h gboolean local, crm_node_t * node, node 162 include/crm/cluster.h const char *crm_peer_uuid(crm_node_t *node); node 164 include/crm/cluster.h void set_uuid(xmlNode *xml, const char *attr, crm_node_t *node); node 335 include/crm/cluster/internal.h crm_node_t * node, enum crm_ais_msg_types dest); node 346 include/crm/cluster/internal.h crm_node_t *crm_update_peer_state(const char *source, crm_node_t * node, node 349 include/crm/cluster/internal.h void crm_update_peer_uname(crm_node_t *node, const char *uname); node 350 include/crm/cluster/internal.h void crm_update_peer_expected(const char *source, crm_node_t * node, const char *expected); node 210 include/crm/common/internal.h const char *node); node 47 include/crm/common/nvpair.h const char *crm_xml_add(xmlNode *node, const char *name, const char *value); node 48 include/crm/common/nvpair.h const char *crm_xml_replace(xmlNode *node, const char *name, const char *value); node 49 include/crm/common/nvpair.h const char *crm_xml_add_int(xmlNode *node, const char *name, int value); node 50 include/crm/common/nvpair.h const char *crm_xml_add_ll(xmlNode *node, const char *name, long long value); node 51 include/crm/common/nvpair.h const char *crm_xml_add_ms(xmlNode *node, const char *name, guint ms); node 96 include/crm/common/nvpair.h crm_xml_add_boolean(xmlNode *node, const char *name, gboolean value) node 98 include/crm/common/nvpair.h return crm_xml_add(node, name, (value? "true" : "false")); node 634 include/crm/common/output_internal.h pcmk__output_xml_add_node(pcmk__output_t *out, xmlNodePtr node); node 674 include/crm/common/output_internal.h pcmk__output_xml_push_parent(pcmk__output_t *out, xmlNodePtr node); node 56 include/crm/common/xml.h xmlDoc *getDocPtr(xmlNode * node); node 73 include/crm/fencing/internal.h xmlNode *create_level_registration_xml(const char *node, const char *pattern, node 22 include/crm/lrmd_internal.h const char *node, uint32_t nodeid, node 25 include/crm/lrmd_internal.h const char *node, uint32_t nodeid, const char *state); node 30 include/crm/lrmd_internal.h const char *node, lrmd_event_data_t *op); node 23 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); node 25 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); node 29 include/crm/pengine/complex.h pe_node_t *node, pe_working_set_t *data_set); node 212 include/crm/pengine/internal.h bool pe_can_fence(pe_working_set_t *data_set, pe_node_t *node); node 217 include/crm/pengine/internal.h char *native_parameter(pe_resource_t * rsc, pe_node_t * node, gboolean create, const char *name, node 225 include/crm/pengine/internal.h void native_add_running(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set); node 232 include/crm/pengine/internal.h pe_resource_t *native_find_rsc(pe_resource_t *rsc, const char *id, const pe_node_t *node, node 248 include/crm/pengine/internal.h char *pe__node_display_name(pe_node_t *node, bool print_detail); node 341 include/crm/pengine/internal.h int pe_get_failcount(pe_node_t *node, pe_resource_t *rsc, time_t *last_failure, node 345 include/crm/pengine/internal.h pe_action_t *pe__clear_failcount(pe_resource_t *rsc, pe_node_t *node, node 382 include/crm/pengine/internal.h extern void print_node(const char *pre_text, pe_node_t * node, gboolean details); node 384 include/crm/pengine/internal.h extern void pe__output_node(pe_node_t * node, gboolean details, pcmk__output_t *out); node 386 include/crm/pengine/internal.h extern void dump_node_capacity(int level, const char *comment, pe_node_t * node); node 387 include/crm/pengine/internal.h extern void dump_rsc_utilization(int level, const char *comment, pe_resource_t * rsc, pe_node_t * node); node 407 include/crm/pengine/internal.h # define delete_action(rsc, node, optional) custom_action( \ node 408 include/crm/pengine/internal.h rsc, delete_key(rsc), CRMD_ACTION_DELETE, node, \ node 412 include/crm/pengine/internal.h # define stopped_action(rsc, node, optional) custom_action( \ node 413 include/crm/pengine/internal.h rsc, stopped_key(rsc), CRMD_ACTION_STOPPED, node, \ node 417 include/crm/pengine/internal.h # define stop_action(rsc, node, optional) custom_action( \ node 418 include/crm/pengine/internal.h rsc, stop_key(rsc), CRMD_ACTION_STOP, node, \ node 423 include/crm/pengine/internal.h # define start_action(rsc, node, optional) custom_action( \ node 424 include/crm/pengine/internal.h rsc, start_key(rsc), CRMD_ACTION_START, node, \ node 428 include/crm/pengine/internal.h # define started_action(rsc, node, optional) custom_action( \ node 429 include/crm/pengine/internal.h rsc, started_key(rsc), CRMD_ACTION_STARTED, node, \ node 433 include/crm/pengine/internal.h # define promote_action(rsc, node, optional) custom_action( \ node 434 include/crm/pengine/internal.h rsc, promote_key(rsc), CRMD_ACTION_PROMOTE, node, \ node 438 include/crm/pengine/internal.h # define promoted_action(rsc, node, optional) custom_action( \ node 439 include/crm/pengine/internal.h rsc, promoted_key(rsc), CRMD_ACTION_PROMOTED, node, \ node 443 include/crm/pengine/internal.h # define demote_action(rsc, node, optional) custom_action( \ node 444 include/crm/pengine/internal.h rsc, demote_key(rsc), CRMD_ACTION_DEMOTE, node, \ node 448 include/crm/pengine/internal.h # define demoted_action(rsc, node, optional) custom_action( \ node 449 include/crm/pengine/internal.h rsc, demoted_key(rsc), CRMD_ACTION_DEMOTED, node, \ node 464 include/crm/pengine/internal.h GList *pe__resource_actions(const pe_resource_t *rsc, const pe_node_t *node, node 469 include/crm/pengine/internal.h extern void resource_location(pe_resource_t * rsc, pe_node_t * node, int score, const char *tag, node 525 include/crm/pengine/internal.h op_digest_cache_t *rsc_action_digest_cmp(pe_resource_t * rsc, xmlNode * xml_op, pe_node_t * node, node 528 include/crm/pengine/internal.h pe_action_t *pe_fence_op(pe_node_t * node, const char *op, bool optional, const char *reason, bool priority_delay, pe_working_set_t * data_set); node 530 include/crm/pengine/internal.h pe_resource_t * rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t * data_set); node 550 include/crm/pengine/internal.h void pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, const char *reason, bool priority_delay); node 554 include/crm/pengine/internal.h void common_print(pe_resource_t * rsc, const char *pre_text, const char *name, pe_node_t *node, long options, void *print_data); node 555 include/crm/pengine/internal.h int pe__common_output_text(pcmk__output_t *out, pe_resource_t * rsc, const char *name, pe_node_t *node, long options); node 556 include/crm/pengine/internal.h int pe__common_output_html(pcmk__output_t *out, pe_resource_t * rsc, const char *name, pe_node_t *node, long options); node 558 include/crm/pengine/internal.h const pe_node_t *node); node 562 include/crm/pengine/internal.h const char *pe_node_attribute_calculated(const pe_node_t *node, node 565 include/crm/pengine/internal.h const char *pe_node_attribute_raw(pe_node_t *node, const char *name); node 568 include/crm/pengine/internal.h void pe__add_param_check(xmlNode *rsc_op, pe_resource_t *rsc, pe_node_t *node, node 576 include/crm/pengine/internal.h bool pe__shutdown_requested(pe_node_t *node); node 591 include/crm/pengine/internal.h pe_action_t *pe__clear_resource_history(pe_resource_t *rsc, pe_node_t *node, node 597 include/crm/pengine/internal.h bool pe__uname_has_tag(pe_working_set_t *data_set, const char *node, const char *tag); node 46 include/crm/pengine/pe_types.h const pe_node_t *node, int flags); node 392 include/crm/pengine/pe_types.h pe_node_t *node; node 22 include/crm/pengine/remote_internal.h bool pe__is_remote_node(const pe_node_t *node); node 23 include/crm/pengine/remote_internal.h bool pe__is_guest_node(const pe_node_t *node); node 24 include/crm/pengine/remote_internal.h bool pe__is_guest_or_remote_node(const pe_node_t *node); node 25 include/crm/pengine/remote_internal.h bool pe__is_bundle_node(const pe_node_t *node); node 43 include/crm/pengine/status.h GListPtr find_operations(const char *rsc, const char *node, gboolean active_filter, node 191 include/crm/stonith-ng.h stonith_t *st, int options, const char *node, int level); node 201 include/crm/stonith-ng.h stonith_t *st, int options, const char *node, int level, stonith_key_value_t *device_list); node 260 include/crm/stonith-ng.h int (*query)(stonith_t *st, int options, const char *node, node 278 include/crm/stonith-ng.h int (*fence)(stonith_t *st, int options, const char *node, const char *action, node 287 include/crm/stonith-ng.h int (*confirm)(stonith_t *st, int options, const char *node); node 295 include/crm/stonith-ng.h int (*history)(stonith_t *st, int options, const char *node, stonith_history_t **output, int timeout); node 348 include/crm/stonith-ng.h const char *node, const char *pattern, node 368 include/crm/stonith-ng.h const char *node, const char *pattern, node 412 include/crm/stonith-ng.h int (*fence_with_delay)(stonith_t *st, int options, const char *node, const char *action, node 66 include/pcmki/pcmki_sched_allocate.h extern enum pe_action_flags native_action_flags(pe_action_t * action, pe_node_t * node); node 70 include/pcmki/pcmki_sched_allocate.h extern gboolean native_create_probe(pe_resource_t * rsc, pe_node_t * node, pe_action_t * complete, node 84 include/pcmki/pcmki_sched_allocate.h extern enum pe_action_flags group_action_flags(pe_action_t * action, pe_node_t * node); node 93 include/pcmki/pcmki_sched_allocate.h gboolean pcmk__bundle_create_probe(pe_resource_t *rsc, pe_node_t *node, node 108 include/pcmki/pcmki_sched_allocate.h pe_node_t *node); node 123 include/pcmki/pcmki_sched_allocate.h extern enum pe_action_flags clone_action_flags(pe_action_t * action, pe_node_t * node); node 125 include/pcmki/pcmki_sched_allocate.h extern gboolean clone_create_probe(pe_resource_t * rsc, pe_node_t * node, pe_action_t * complete, node 159 include/pcmki/pcmki_sched_allocate.h pe_node_t *node, node 165 include/pcmki/pcmki_sched_allocate.h pe_node_t *node, node 172 include/pcmki/pcmki_sched_allocate.h pe_node_t *node, node 28 include/pcmki/pcmki_sched_utils.h const char *discovery_mode, pe_node_t *node, node 45 include/pcmki/pcmki_sched_utils.h extern gboolean can_run_resources(const pe_node_t * node); node 61 include/pcmki/pcmki_sched_utils.h bool assign_node(pe_resource_t * rsc, pe_node_t * node, gboolean force); node 62 include/pcmki/pcmki_sched_utils.h enum pe_action_flags summary_action_flags(pe_action_t * action, GListPtr children, pe_node_t * node); node 83 include/pcmki/pcmki_sched_utils.h guint interval_ms, pe_node_t *node, node 85 include/pcmki/pcmki_sched_utils.h pe_action_t *sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set); node 89 include/pcmki/pcmki_sched_utils.h const char *node, const char *origin, node 82 include/pcmki/pcmki_scheduler.h extern gboolean shutdown_constraints(pe_node_t * node, pe_action_t * shutdown_op, node 104 lib/cluster/cluster.c send_cluster_message(crm_node_t * node, enum crm_ais_msg_types service, xmlNode * data, node 110 lib/cluster/cluster.c return send_cluster_message_cs(data, FALSE, node, service); node 181 lib/cluster/cluster.c crm_node_t *node = NULL; node 192 lib/cluster/cluster.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 193 lib/cluster/cluster.c if(node->uuid && strcasecmp(node->uuid, uuid) == 0) { node 194 lib/cluster/cluster.c if(node->uname) { node 195 lib/cluster/cluster.c return node->uname; node 200 lib/cluster/cluster.c node = NULL; node 207 lib/cluster/cluster.c node = crm_find_peer(id, NULL); node 212 lib/cluster/cluster.c if (node) { node 213 lib/cluster/cluster.c crm_info("Setting uuid for node %s[%u] to '%s'", node->uname, node->id, uuid); node 214 lib/cluster/cluster.c node->uuid = strdup(uuid); node 215 lib/cluster/cluster.c if(node->uname) { node 216 lib/cluster/cluster.c return node->uname; node 227 lib/cluster/cluster.c set_uuid(xmlNode *xml, const char *attr, crm_node_t *node) node 229 lib/cluster/cluster.c const char *uuid_calc = crm_peer_uuid(node); node 44 lib/cluster/corosync.c get_corosync_uuid(crm_node_t *node) node 46 lib/cluster/corosync.c if (node && is_corosync_cluster()) { node 47 lib/cluster/corosync.c if (node->id > 0) { node 48 lib/cluster/corosync.c return crm_strdup_printf("%u", node->id); node 50 lib/cluster/corosync.c crm_info("Node %s is not yet known by corosync", node->uname); node 206 lib/cluster/corosync.c crm_node_t *node = NULL; node 235 lib/cluster/corosync.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 236 lib/cluster/corosync.c node->last_seen = 0; node 246 lib/cluster/corosync.c node = crm_get_peer(id, NULL); node 247 lib/cluster/corosync.c if (node->uname == NULL) { node 251 lib/cluster/corosync.c node = crm_get_peer(id, name); node 256 lib/cluster/corosync.c crm_update_peer_state(__func__, node, CRM_NODE_MEMBER, ring_id); node 512 lib/cluster/corosync.c crm_is_corosync_peer_active(const crm_node_t * node) node 514 lib/cluster/corosync.c if (node == NULL) { node 518 lib/cluster/corosync.c } else if (!pcmk__str_eq(node->state, CRM_NODE_MEMBER, pcmk__str_casei)) { node 519 lib/cluster/corosync.c crm_trace("%s: state=%s", node->uname, node->state); node 522 lib/cluster/corosync.c } else if ((node->processes & crm_proc_cpg) == 0) { node 523 lib/cluster/corosync.c crm_trace("%s: processes=%.16x", node->uname, node->processes); node 598 lib/cluster/corosync.c crm_node_t *node = NULL; node 601 lib/cluster/corosync.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 602 lib/cluster/corosync.c if(node && node->uname && strcasecmp(node->uname, name) == 0) { node 603 lib/cluster/corosync.c if (node->id && node->id != nodeid) { node 604 lib/cluster/corosync.c crm_crit("Nodes %u and %u share the same name '%s': shutting down", node->id, node 621 lib/cluster/corosync.c xmlNode *node = create_xml_node(xml_parent, XML_CIB_TAG_NODE); node 623 lib/cluster/corosync.c crm_xml_set_id(node, "%u", nodeid); node 624 lib/cluster/corosync.c crm_xml_add(node, XML_ATTR_UNAME, name); node 626 lib/cluster/corosync.c crm_xml_add(node, XML_ATTR_TYPE, CRM_NODE_MEMBER); node 635 lib/cluster/cpg.c send_cluster_message_cs(xmlNode * msg, gboolean local, crm_node_t * node, enum crm_ais_msg_types dest) node 641 lib/cluster/cpg.c rc = send_cluster_text(crm_class_cluster, data, local, node, dest); node 648 lib/cluster/cpg.c gboolean local, crm_node_t *node, enum crm_ais_msg_types dest) node 699 lib/cluster/cpg.c if (node) { node 700 lib/cluster/cpg.c if (node->uname) { node 701 lib/cluster/cpg.c target = strdup(node->uname); node 702 lib/cluster/cpg.c msg->host.size = strlen(node->uname); node 704 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); node 706 lib/cluster/cpg.c target = crm_strdup_printf("%u", node->id); node 708 lib/cluster/cpg.c msg->host.id = node->id; node 362 lib/cluster/election.c const crm_node_t *node; node 367 lib/cluster/election.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) & node)) { node 368 lib/cluster/election.c if (crm_is_peer_active(node)) { node 369 lib/cluster/election.c crm_warn("* expected vote: %s", node->uname); node 82 lib/cluster/membership.c crm_node_t *node; node 90 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, node_name); node 91 lib/cluster/membership.c if (node) { node 92 lib/cluster/membership.c return node; node 96 lib/cluster/membership.c node = calloc(1, sizeof(crm_node_t)); node 97 lib/cluster/membership.c if (node == NULL) { node 102 lib/cluster/membership.c pcmk__set_peer_flags(node, crm_remote_node); node 103 lib/cluster/membership.c node->uuid = strdup(node_name); node 104 lib/cluster/membership.c if (node->uuid == NULL) { node 105 lib/cluster/membership.c free(node); node 111 lib/cluster/membership.c g_hash_table_replace(crm_remote_peer_cache, node->uuid, node); node 115 lib/cluster/membership.c crm_update_peer_uname(node, node_name); node 116 lib/cluster/membership.c return node; node 171 lib/cluster/membership.c crm_node_t *node; node 181 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, remote); node 183 lib/cluster/membership.c if (node == NULL) { node 185 lib/cluster/membership.c node = crm_remote_peer_get(remote); node 186 lib/cluster/membership.c CRM_ASSERT(node); node 188 lib/cluster/membership.c crm_update_peer_state(__func__, node, state, 0); node 191 lib/cluster/membership.c } else if (pcmk_is_set(node->flags, crm_node_dirty)) { node 193 lib/cluster/membership.c pcmk__clear_peer_flags(node, crm_node_dirty); node 195 lib/cluster/membership.c crm_update_peer_state(__func__, node, state, 0); node 272 lib/cluster/membership.c crm_is_peer_active(const crm_node_t * node) node 274 lib/cluster/membership.c if(node == NULL) { node 278 lib/cluster/membership.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 285 lib/cluster/membership.c return crm_is_corosync_peer_active(node); node 295 lib/cluster/membership.c crm_node_t *node = value; node 301 lib/cluster/membership.c } else if (search->id && node->id != search->id) { node 304 lib/cluster/membership.c } else if (search->id == 0 && !pcmk__str_eq(node->uname, search->uname, pcmk__str_casei)) { node 309 lib/cluster/membership.c (node->uname? node->uname : "unknown"), node->id); node 357 lib/cluster/membership.c crm_node_t *node = value; node 359 lib/cluster/membership.c if (crm_is_peer_active(node)) { node 378 lib/cluster/membership.c crm_node_t *node = data; node 380 lib/cluster/membership.c crm_trace("Destroying entry for node %u: %s", node->id, node->uname); node 382 lib/cluster/membership.c free(node->uname); node 383 lib/cluster/membership.c free(node->state); node 384 lib/cluster/membership.c free(node->uuid); node 385 lib/cluster/membership.c free(node->expected); node 386 lib/cluster/membership.c free(node); node 467 lib/cluster/membership.c crm_node_t *node = NULL; node 470 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, (gpointer *) &id, (gpointer *) &node)) { node 471 lib/cluster/membership.c do_crm_log(level, "%s: Node %u/%s = %p - %s", caller, node->id, node->uname, node, id); node 486 lib/cluster/membership.c crm_node_t *node = NULL; node 493 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, uname); node 496 lib/cluster/membership.c if (node == NULL && (flags & CRM_GET_PEER_CLUSTER)) { node 497 lib/cluster/membership.c node = crm_find_peer(id, uname); node 499 lib/cluster/membership.c return node; node 505 lib/cluster/membership.c crm_node_t *node = NULL; node 512 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, uname); node 515 lib/cluster/membership.c if (node == NULL && (flags & CRM_GET_PEER_CLUSTER)) { node 516 lib/cluster/membership.c node = crm_get_peer(id, uname); node 518 lib/cluster/membership.c return node; node 525 lib/cluster/membership.c crm_node_t *node = NULL; node 535 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 536 lib/cluster/membership.c if(node->uname && strcasecmp(node->uname, uname) == 0) { node 537 lib/cluster/membership.c crm_trace("Name match: %s = %p", node->uname, node); node 538 lib/cluster/membership.c by_name = node; node 546 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 547 lib/cluster/membership.c if(node->id == id) { node 548 lib/cluster/membership.c crm_trace("ID match: %u = %p", node->id, node); node 549 lib/cluster/membership.c by_id = node; node 555 lib/cluster/membership.c node = by_id; /* Good default */ node 567 lib/cluster/membership.c node = NULL; /* Create a new one */ node 570 lib/cluster/membership.c node = by_name; node 610 lib/cluster/membership.c return node; node 615 lib/cluster/membership.c crm_remove_conflicting_peer(crm_node_t *node) node 621 lib/cluster/membership.c if (node->id == 0 || node->uname == NULL) { node 632 lib/cluster/membership.c && existing_node->id != node->id node 634 lib/cluster/membership.c && strcasecmp(existing_node->uname, node->uname) == 0) { node 641 lib/cluster/membership.c existing_node->id, existing_node->uname, node->id); node 656 lib/cluster/membership.c crm_node_t *node = NULL; node 663 lib/cluster/membership.c node = crm_find_peer(id, uname); node 667 lib/cluster/membership.c if ((node == NULL || node->uname == NULL) && (uname == NULL)) { node 676 lib/cluster/membership.c if (node == NULL) { node 677 lib/cluster/membership.c node = crm_find_peer(id, uname); node 682 lib/cluster/membership.c if (node == NULL) { node 685 lib/cluster/membership.c node = calloc(1, sizeof(crm_node_t)); node 686 lib/cluster/membership.c CRM_ASSERT(node); node 689 lib/cluster/membership.c uniqueid, node, uname, id, 1 + g_hash_table_size(crm_peer_cache)); node 690 lib/cluster/membership.c g_hash_table_replace(crm_peer_cache, uniqueid, node); node 693 lib/cluster/membership.c if(id > 0 && uname && (node->id == 0 || node->uname == NULL)) { node 697 lib/cluster/membership.c if(id > 0 && node->id == 0) { node 698 lib/cluster/membership.c node->id = id; node 701 lib/cluster/membership.c if (uname && (node->uname == NULL)) { node 702 lib/cluster/membership.c crm_update_peer_uname(node, uname); node 705 lib/cluster/membership.c if(node->uuid == NULL) { node 706 lib/cluster/membership.c const char *uuid = crm_peer_uuid(node); node 712 lib/cluster/membership.c crm_info("Cannot obtain a UUID for node %u/%s", id, node->uname); node 718 lib/cluster/membership.c return node; node 733 lib/cluster/membership.c crm_update_peer_uname(crm_node_t *node, const char *uname) node 737 lib/cluster/membership.c CRM_CHECK(node != NULL, node 741 lib/cluster/membership.c if (pcmk__str_eq(uname, node->uname, pcmk__str_casei)) { node 754 lib/cluster/membership.c free(node->uname); node 755 lib/cluster/membership.c node->uname = strdup(uname); node 756 lib/cluster/membership.c CRM_ASSERT(node->uname != NULL); node 759 lib/cluster/membership.c crm_status_callback(crm_status_uname, node, NULL); node 763 lib/cluster/membership.c if (is_corosync_cluster() && !pcmk_is_set(node->flags, crm_remote_node)) { node 764 lib/cluster/membership.c crm_remove_conflicting_peer(node); node 786 lib/cluster/membership.c crm_update_peer_proc(const char *source, crm_node_t * node, uint32_t flag, const char *status) node 791 lib/cluster/membership.c CRM_CHECK(node != NULL, crm_err("%s: Could not set %s to %s for NULL", node 795 lib/cluster/membership.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 796 lib/cluster/membership.c return node; node 799 lib/cluster/membership.c last = node->processes; node 801 lib/cluster/membership.c node->processes = flag; node 802 lib/cluster/membership.c if (node->processes != last) { node 807 lib/cluster/membership.c if ((node->processes & flag) != flag) { node 808 lib/cluster/membership.c node->processes = pcmk__set_flags_as(__func__, __LINE__, node 810 lib/cluster/membership.c node->uname, node->processes, node 815 lib/cluster/membership.c } else if (node->processes & flag) { node 816 lib/cluster/membership.c node->processes = pcmk__clear_flags_as(__func__, __LINE__, node 818 lib/cluster/membership.c node->uname, node->processes, node 825 lib/cluster/membership.c crm_info("%s: Node %s[%u] - all processes are now offline", source, node->uname, node 826 lib/cluster/membership.c node->id); node 828 lib/cluster/membership.c crm_info("%s: Node %s[%u] - %s is now %s", source, node->uname, node->id, node 836 lib/cluster/membership.c crm_status_callback(crm_status_processes, node, &last); node 849 lib/cluster/membership.c if (pcmk_is_set(node->processes, crm_get_cluster_proc())) { node 854 lib/cluster/membership.c node = crm_update_peer_state(__func__, node, peer_state, 0); node 857 lib/cluster/membership.c crm_trace("%s: Node %s[%u] - %s is unchanged (%s)", source, node->uname, node->id, node 860 lib/cluster/membership.c return node; node 864 lib/cluster/membership.c crm_update_peer_expected(const char *source, crm_node_t * node, const char *expected) node 869 lib/cluster/membership.c CRM_CHECK(node != NULL, crm_err("%s: Could not set 'expected' to %s", source, expected); node 873 lib/cluster/membership.c if (pcmk_is_set(node->flags, crm_remote_node)) { node 877 lib/cluster/membership.c last = node->expected; node 878 lib/cluster/membership.c if (expected != NULL && !pcmk__str_eq(node->expected, expected, pcmk__str_casei)) { node 879 lib/cluster/membership.c node->expected = strdup(expected); node 884 lib/cluster/membership.c crm_info("%s: Node %s[%u] - expected state is now %s (was %s)", source, node->uname, node->id, node 888 lib/cluster/membership.c crm_trace("%s: Node %s[%u] - expected state is unchanged (%s)", source, node->uname, node 889 lib/cluster/membership.c node->id, expected); node 910 lib/cluster/membership.c crm_update_peer_state_iter(const char *source, crm_node_t * node, const char *state, uint64_t membership, GHashTableIter *iter) node 914 lib/cluster/membership.c CRM_CHECK(node != NULL, node 921 lib/cluster/membership.c node->when_lost = 0; node 923 lib/cluster/membership.c node->last_seen = membership; node 927 lib/cluster/membership.c if (state && !pcmk__str_eq(node->state, state, pcmk__str_casei)) { node 928 lib/cluster/membership.c char *last = node->state; node 930 lib/cluster/membership.c node->state = strdup(state); node 932 lib/cluster/membership.c " nodeid=%u previous=%s source=%s", node->uname, state, node 933 lib/cluster/membership.c node->id, (last? last : "unknown"), source); node 935 lib/cluster/membership.c crm_status_callback(crm_status_nstate, node, last); node 940 lib/cluster/membership.c && !pcmk_is_set(node->flags, crm_remote_node)) { node 946 lib/cluster/membership.c crm_notice("Purged 1 peer with id=%u and/or uname=%s from the membership cache", node->id, node->uname); node 950 lib/cluster/membership.c reap_crm_member(node->id, node->uname); node 952 lib/cluster/membership.c node = NULL; node 957 lib/cluster/membership.c " nodeid=%u source=%s", node->uname, state, node->id, source); node 959 lib/cluster/membership.c return node; node 978 lib/cluster/membership.c crm_update_peer_state(const char *source, crm_node_t * node, const char *state, uint64_t membership) node 980 lib/cluster/membership.c return crm_update_peer_state_iter(source, node, state, membership, NULL); node 993 lib/cluster/membership.c crm_node_t *node = NULL; node 997 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *)&node)) { node 998 lib/cluster/membership.c if (node->last_seen != membership) { node 999 lib/cluster/membership.c if (node->state) { node 1005 lib/cluster/membership.c crm_update_peer_state_iter(__func__, node, CRM_NODE_LOST, node 1010 lib/cluster/membership.c node->uname, node->id); node 1033 lib/cluster/membership.c crm_node_t *node = NULL; node 1039 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 1040 lib/cluster/membership.c if (node->uname && strcasecmp(node->uname, uname) == 0) { node 1041 lib/cluster/membership.c crm_trace("Name match: %s = %p", node->uname, node); node 1042 lib/cluster/membership.c by_name = node; node 1050 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 1051 lib/cluster/membership.c if(strcasecmp(node->uuid, id) == 0) { node 1052 lib/cluster/membership.c crm_trace("ID match: %s= %p", id, node); node 1053 lib/cluster/membership.c by_id = node; node 1059 lib/cluster/membership.c node = by_id; /* Good default */ node 1068 lib/cluster/membership.c node = NULL; node 1071 lib/cluster/membership.c node = by_name; node 1078 lib/cluster/membership.c node = NULL; node 1090 lib/cluster/membership.c node = by_name; node 1093 lib/cluster/membership.c node = NULL; node 1096 lib/cluster/membership.c if (node == NULL) { node 1104 lib/cluster/membership.c return node; node 1112 lib/cluster/membership.c crm_node_t * node = NULL; node 1115 lib/cluster/membership.c node = crm_find_known_peer(id, uname); node 1117 lib/cluster/membership.c if (node == NULL) { node 1120 lib/cluster/membership.c node = calloc(1, sizeof(crm_node_t)); node 1121 lib/cluster/membership.c CRM_ASSERT(node != NULL); node 1123 lib/cluster/membership.c node->uname = strdup(uname); node 1124 lib/cluster/membership.c CRM_ASSERT(node->uname != NULL); node 1126 lib/cluster/membership.c node->uuid = strdup(id); node 1127 lib/cluster/membership.c CRM_ASSERT(node->uuid != NULL); node 1129 lib/cluster/membership.c g_hash_table_replace(crm_known_peer_cache, uniqueid, node); node 1131 lib/cluster/membership.c } else if (pcmk_is_set(node->flags, crm_node_dirty)) { node 1132 lib/cluster/membership.c if (!pcmk__str_eq(uname, node->uname, pcmk__str_casei)) { node 1133 lib/cluster/membership.c free(node->uname); node 1134 lib/cluster/membership.c node->uname = strdup(uname); node 1135 lib/cluster/membership.c CRM_ASSERT(node->uname != NULL); node 1139 lib/cluster/membership.c pcmk__clear_peer_flags(node, crm_node_dirty); node 1172 lib/cluster/membership.c crm_node_t *node = NULL; node 1177 lib/cluster/membership.c node = crm_find_peer_full(id, uname, flags); node 1179 lib/cluster/membership.c if (node || !(flags & CRM_GET_PEER_CLUSTER)) { node 1180 lib/cluster/membership.c return node; node 1187 lib/cluster/membership.c node = crm_find_known_peer(id_str, uname); node 1190 lib/cluster/membership.c return node; node 129 lib/common/ipc_controld.c for (xmlNode *node = first_named_child(msg_data, XML_CIB_TAG_NODE); node 130 lib/common/ipc_controld.c node != NULL; node = crm_next_same_xml(node)) { node 135 lib/common/ipc_controld.c crm_element_value_ll(node, XML_ATTR_ID, &id_ll); node 139 lib/common/ipc_controld.c node_info->uname = crm_element_value(node, XML_ATTR_UNAME); node 140 lib/common/ipc_controld.c node_info->state = crm_element_value(node, XML_NODE_IN_CLUSTER); node 271 lib/common/ipc_controld.c const char *node, xmlNode *msg_data) node 280 lib/common/ipc_controld.c if ((node == NULL) && !strcmp(op, CRM_OP_PING)) { node 285 lib/common/ipc_controld.c return create_request(op, msg_data, node, sys_to, node 317 lib/common/nvpair.c crm_xml_add(xmlNode *node, const char *name, const char *value) node 322 lib/common/nvpair.c CRM_CHECK(node != NULL, return NULL); node 332 lib/common/nvpair.c old_value = crm_element_value(node, name); node 341 lib/common/nvpair.c if (pcmk__tracking_xml_changes(node, FALSE)) { node 342 lib/common/nvpair.c const char *old = crm_element_value(node, name); node 349 lib/common/nvpair.c if (dirty && (pcmk__check_acl(node, name, xpf_acl_create) == FALSE)) { node 350 lib/common/nvpair.c crm_trace("Cannot add %s=%s to %s", name, value, node->name); node 354 lib/common/nvpair.c attr = xmlSetProp(node, (pcmkXmlStr) name, (pcmkXmlStr) value); node 374 lib/common/nvpair.c crm_xml_replace(xmlNode *node, const char *name, const char *value) node 380 lib/common/nvpair.c CRM_CHECK(node != NULL, return NULL); node 383 lib/common/nvpair.c old_value = crm_element_value(node, name); node 388 lib/common/nvpair.c if (pcmk__check_acl(node, name, xpf_acl_write) == FALSE) { node 390 lib/common/nvpair.c crm_trace("Cannot replace %s=%s to %s", name, value, node->name); node 394 lib/common/nvpair.c xml_remove_prop(node, name); node 398 lib/common/nvpair.c if (pcmk__tracking_xml_changes(node, FALSE)) { node 404 lib/common/nvpair.c attr = xmlSetProp(node, (pcmkXmlStr) name, (pcmkXmlStr) value); node 425 lib/common/nvpair.c crm_xml_add_int(xmlNode *node, const char *name, int value) node 428 lib/common/nvpair.c const char *added = crm_xml_add(node, name, number); node 447 lib/common/nvpair.c crm_xml_add_ms(xmlNode *node, const char *name, guint ms) node 450 lib/common/nvpair.c const char *added = crm_xml_add(node, name, number); node 296 lib/common/operations.c const char *node) node 298 lib/common/operations.c CRM_CHECK(node != NULL, return NULL); node 300 lib/common/operations.c action_id, transition_id, target_rc, 36, node); node 270 lib/common/output_html.c htmlNodePtr node = NULL; node 275 lib/common/output_html.c node = pcmk__output_create_html_node(out, "pre", NULL, NULL, buf); node 276 lib/common/output_html.c xmlSetProp(node, (pcmkXmlStr) "lang", (pcmkXmlStr) "xml"); node 285 lib/common/output_html.c xmlNodePtr node = NULL; node 317 lib/common/output_html.c node = pcmk__output_xml_create_parent(out, "ul"); node 318 lib/common/output_html.c g_queue_push_tail(priv->parent_q, node); node 409 lib/common/output_html.c htmlNodePtr node = pcmk__output_create_xml_text_node(out, element_name, text); node 412 lib/common/output_html.c xmlSetProp(node, (pcmkXmlStr) "class", (pcmkXmlStr) class_name); node 416 lib/common/output_html.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) id); node 419 lib/common/output_html.c return node; node 116 lib/common/output_log.c xmlNodePtr node = NULL; node 120 lib/common/output_log.c node = create_xml_node(NULL, name); node 121 lib/common/output_log.c xmlNodeSetContent(node, (pcmkXmlStr) buf); node 122 lib/common/output_log.c crm_log_xml_info(node, name); node 123 lib/common/output_log.c free(node); node 226 lib/common/output_text.c text_list_data_t *node = NULL; node 229 lib/common/output_text.c node = g_queue_pop_tail(priv->parent_q); node 231 lib/common/output_text.c if (node->singular_noun != NULL && node->plural_noun != NULL) { node 232 lib/common/output_text.c if (node->len == 1) { node 233 lib/common/output_text.c pcmk__indented_printf(out, "%d %s found\n", node->len, node->singular_noun); node 235 lib/common/output_text.c pcmk__indented_printf(out, "%d %s found\n", node->len, node->plural_noun); node 239 lib/common/output_text.c free(node); node 136 lib/common/output_xml.c xmlNodePtr node = (xmlNodePtr) user_data; node 137 lib/common/output_xml.c pcmk_create_xml_text_node(node, "error", str); node 142 lib/common/output_xml.c xmlNodePtr node; node 146 lib/common/output_xml.c GSList *node = priv->errors; node 152 lib/common/output_xml.c while (node != NULL) { node 153 lib/common/output_xml.c fprintf(stderr, "%s\n", (char *) node->data); node 154 lib/common/output_xml.c node = node->next; node 159 lib/common/output_xml.c node = create_xml_node(priv->root, "status"); node 160 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "code", (pcmkXmlStr) rc_as_str); node 161 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "message", (pcmkXmlStr) crm_exit_str(exit_status)); node 164 lib/common/output_xml.c xmlNodePtr errors_node = create_xml_node(node, "errors"); node 214 lib/common/output_xml.c xmlNodePtr node, child_node; node 219 lib/common/output_xml.c node = pcmk__output_xml_create_parent(out, "command"); node 220 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "code", (pcmkXmlStr) rc_as_str); node 223 lib/common/output_xml.c child_node = pcmk_create_xml_text_node(node, "output", proc_stdout); node 228 lib/common/output_xml.c child_node = pcmk_create_xml_text_node(node, "output", proc_stderr); node 232 lib/common/output_xml.c pcmk__output_xml_add_node(out, node); node 238 lib/common/output_xml.c xmlNodePtr node; node 242 lib/common/output_xml.c node = pcmk__output_create_xml_node(out, "version"); node 243 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "program", (pcmkXmlStr) "Pacemaker"); node 244 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "version", (pcmkXmlStr) PACEMAKER_VERSION); node 245 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "author", (pcmkXmlStr) "Andrew Beekhof"); node 246 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "build", (pcmkXmlStr) BUILD_VERSION); node 247 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "features", (pcmkXmlStr) CRM_FEATURES); node 365 lib/common/output_xml.c xmlNodePtr node; node 367 lib/common/output_xml.c node = g_queue_pop_tail(priv->parent_q); node 368 lib/common/output_xml.c buf = crm_strdup_printf("%lu", xmlChildElementCount(node)); node 369 lib/common/output_xml.c xmlSetProp(node, (pcmkXmlStr) "count", (pcmkXmlStr) buf); node 416 lib/common/output_xml.c xmlNodePtr node = pcmk__output_create_xml_node(out, name); node 417 lib/common/output_xml.c pcmk__output_xml_push_parent(out, node); node 418 lib/common/output_xml.c return node; node 422 lib/common/output_xml.c pcmk__output_xml_add_node(pcmk__output_t *out, xmlNodePtr node) { node 426 lib/common/output_xml.c CRM_ASSERT(node != NULL); node 428 lib/common/output_xml.c xmlAddChild(g_queue_peek_tail(priv->parent_q), node); node 442 lib/common/output_xml.c xmlNodePtr node = pcmk__output_create_xml_node(out, name); node 443 lib/common/output_xml.c xmlNodeSetContent(node, (pcmkXmlStr) content); node 444 lib/common/output_xml.c return node; node 223 lib/common/xml.c free_private_data(xmlNode *node) node 232 lib/common/xml.c if (node->type != XML_DOCUMENT_NODE || node->name == NULL node 233 lib/common/xml.c || node->name[0] != ' ') { node 234 lib/common/xml.c reset_xml_private_data(node->_private); node 235 lib/common/xml.c free(node->_private); node 241 lib/common/xml.c new_private_data(xmlNode *node) node 245 lib/common/xml.c switch(node->type) { node 254 lib/common/xml.c node->_private = p; node 262 lib/common/xml.c crm_trace("Ignoring %p %d", node, node->type); node 263 lib/common/xml.c CRM_LOG_ASSERT(node->type == XML_ELEMENT_NODE); node 267 lib/common/xml.c if(p && pcmk__tracking_xml_changes(node, FALSE)) { node 271 lib/common/xml.c mark_xml_node_dirty(node); node 625 lib/common/xml.c getDocPtr(xmlNode * node) node 629 lib/common/xml.c CRM_CHECK(node != NULL, return NULL); node 631 lib/common/xml.c doc = node->doc; node 634 lib/common/xml.c xmlDocSetRootElement(doc, node); node 635 lib/common/xml.c xmlSetTreeDoc(node, doc); node 666 lib/common/xml.c xmlNode *node = NULL; node 675 lib/common/xml.c node = xmlNewDocRawNode(doc, NULL, (pcmkXmlStr) name, NULL); node 676 lib/common/xml.c xmlDocSetRootElement(doc, node); node 680 lib/common/xml.c node = xmlNewDocRawNode(doc, NULL, (pcmkXmlStr) name, NULL); node 681 lib/common/xml.c xmlAddChild(parent, node); node 683 lib/common/xml.c pcmk__mark_xml_created(node); node 684 lib/common/xml.c return node; node 690 lib/common/xml.c xmlNode *node = create_xml_node(parent, name); node 692 lib/common/xml.c if (node != NULL) { node 693 lib/common/xml.c xmlNodeSetContent(node, (pcmkXmlStr) content); node 696 lib/common/xml.c return node; node 703 lib/common/xml.c xmlNode *node = pcmk_create_xml_text_node(parent, element_name, text); node 706 lib/common/xml.c xmlSetProp(node, (pcmkXmlStr) "class", (pcmkXmlStr) class_name); node 710 lib/common/xml.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) id); node 713 lib/common/xml.c return node; node 342 lib/fencing/st_client.c const char *node, const char *pattern, node 348 lib/fencing/st_client.c CRM_CHECK(node || pattern || (attr && value), return -EINVAL); node 353 lib/fencing/st_client.c if (node) { node 354 lib/fencing/st_client.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 372 lib/fencing/st_client.c stonith_api_remove_level(stonith_t * st, int options, const char *node, int level) node 374 lib/fencing/st_client.c return stonith_api_remove_level_full(st, options, node, node 394 lib/fencing/st_client.c create_level_registration_xml(const char *node, const char *pattern, node 402 lib/fencing/st_client.c CRM_CHECK(node || pattern || (attr && value), return NULL); node 411 lib/fencing/st_client.c if (node) { node 412 lib/fencing/st_client.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 435 lib/fencing/st_client.c stonith_api_register_level_full(stonith_t * st, int options, const char *node, node 441 lib/fencing/st_client.c xmlNode *data = create_level_registration_xml(node, pattern, attr, value, node 452 lib/fencing/st_client.c stonith_api_register_level(stonith_t * st, int options, const char *node, int level, node 455 lib/fencing/st_client.c return stonith_api_register_level_full(st, options, node, NULL, NULL, NULL, node 1076 lib/fencing/st_client.c stonith_api_fence_with_delay(stonith_t * stonith, int call_options, const char *node, node 1083 lib/fencing/st_client.c crm_xml_add(data, F_STONITH_TARGET, node); node 1096 lib/fencing/st_client.c stonith_api_fence(stonith_t * stonith, int call_options, const char *node, const char *action, node 1099 lib/fencing/st_client.c return stonith_api_fence_with_delay(stonith, call_options, node, action, node 1111 lib/fencing/st_client.c stonith_api_history(stonith_t * stonith, int call_options, const char *node, node 1121 lib/fencing/st_client.c if (node) { node 1123 lib/fencing/st_client.c crm_xml_add(data, F_STONITH_TARGET, node); node 1126 lib/fencing/st_client.c stonith__set_call_options(call_options, node, st_opt_sync_call); node 135 lib/fencing/st_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "fence_history"); node 138 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "status", (pcmkXmlStr) rc_s); node 185 lib/fencing/st_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "last-fenced"); node 188 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "target", (pcmkXmlStr) target); node 189 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "when", (pcmkXmlStr) buf); node 316 lib/fencing/st_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "fence_event"); node 325 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "status", (pcmkXmlStr) "failed"); node 329 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "status", (pcmkXmlStr) "success"); node 334 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "status", (pcmkXmlStr) "pending"); node 335 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "extended-status", (pcmkXmlStr) state); node 342 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "delegate", (pcmkXmlStr) event->delegate); node 345 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "action", (pcmkXmlStr) event->action); node 346 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "target", (pcmkXmlStr) event->target); node 347 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "client", (pcmkXmlStr) event->client); node 348 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "origin", (pcmkXmlStr) event->origin); node 352 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "completed", (pcmkXmlStr) buf); node 415 lib/fencing/st_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "validate"); node 423 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "agent", (pcmkXmlStr) agent); node 425 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "device", (pcmkXmlStr) device); node 427 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "valid", (pcmkXmlStr) pcmk__btoa(rc)); node 429 lib/fencing/st_output.c pcmk__output_xml_push_parent(out, node); node 238 lib/lrmd/lrmd_alerts.c const char *node, uint32_t nodeid, node 248 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, PCMK__alert_key_node, node); node 276 lib/lrmd/lrmd_alerts.c const char *node, uint32_t nodeid, const char *state) node 285 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, PCMK__alert_key_node, node); node 346 lib/lrmd/lrmd_alerts.c const char *node, lrmd_event_data_t *op) node 368 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, PCMK__alert_key_node, node); node 41 lib/pacemaker/pcmk_fence.c char *node = NULL; node 60 lib/pacemaker/pcmk_fence.c node = target; node 65 lib/pacemaker/pcmk_fence.c rc = st->cmds->register_level_full(st, st_opts, node, pattern, node 69 lib/pacemaker/pcmk_fence.c rc = st->cmds->remove_level_full(st, st_opts, node, pattern, node 28 lib/pacemaker/pcmk_sched_allocate.c extern void ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set); node 29 lib/pacemaker/pcmk_sched_allocate.c extern gboolean DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set); node 31 lib/pacemaker/pcmk_sched_allocate.c static enum remote_connection_state get_remote_node_state(pe_node_t *node); node 140 lib/pacemaker/pcmk_sched_allocate.c action->uuid, action->node ? action->node->details->uname : "[none]", node 148 lib/pacemaker/pcmk_sched_allocate.c check_rsc_parameters(pe_resource_t * rsc, pe_node_t * node, xmlNode * rsc_entry, node 174 lib/pacemaker/pcmk_sched_allocate.c trigger_unfencing(rsc, node, "Device definition changed", NULL, data_set); node 178 lib/pacemaker/pcmk_sched_allocate.c rsc->id, node->details->uname, attr_list[attr_lpc], node 184 lib/pacemaker/pcmk_sched_allocate.c stop_action(rsc, node, FALSE); node 354 lib/pacemaker/pcmk_sched_allocate.c check_params(pe_resource_t *rsc, pe_node_t *node, xmlNode *rsc_op, node 362 lib/pacemaker/pcmk_sched_allocate.c if (check_action_definition(rsc, node, rsc_op, data_set) node 363 lib/pacemaker/pcmk_sched_allocate.c && pe_get_failcount(node, rsc, NULL, pe_fc_effective, NULL, node 371 lib/pacemaker/pcmk_sched_allocate.c digest_data = rsc_action_digest_cmp(rsc, rsc_op, node, data_set); node 375 lib/pacemaker/pcmk_sched_allocate.c rsc->id, ID(rsc_op), node->details->id); node 387 lib/pacemaker/pcmk_sched_allocate.c pe__clear_failcount(rsc, node, reason, data_set); node 392 lib/pacemaker/pcmk_sched_allocate.c check_actions_for(xmlNode * rsc_entry, pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set) node 405 lib/pacemaker/pcmk_sched_allocate.c CRM_CHECK(node != NULL, return); node 413 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 419 lib/pacemaker/pcmk_sched_allocate.c } else if (pe_find_node_id(rsc->running_on, node->details->id) == NULL) { node 420 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, FALSE, data_set)) { node 421 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 424 lib/pacemaker/pcmk_sched_allocate.c rsc->id, node->details->uname); node 428 lib/pacemaker/pcmk_sched_allocate.c pe_rsc_trace(rsc, "Processing %s on %s", rsc->id, node->details->uname); node 430 lib/pacemaker/pcmk_sched_allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, TRUE, data_set)) { node 431 lib/pacemaker/pcmk_sched_allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 463 lib/pacemaker/pcmk_sched_allocate.c (pcmk_is_set(rsc->flags, pe_rsc_maintenance) || node->details->maintenance)) { node 465 lib/pacemaker/pcmk_sched_allocate.c CancelXmlOp(rsc, rsc_op, node, "maintenance mode", data_set); node 481 lib/pacemaker/pcmk_sched_allocate.c pe__add_param_check(rsc_op, rsc, node, pe_check_active, node 484 lib/pacemaker/pcmk_sched_allocate.c } else if (check_action_definition(rsc, node, rsc_op, data_set) node 485 lib/pacemaker/pcmk_sched_allocate.c && pe_get_failcount(node, rsc, NULL, pe_fc_effective, NULL, node 487 lib/pacemaker/pcmk_sched_allocate.c pe__clear_failcount(rsc, node, "action definition changed", node 556 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = NULL; node 571 lib/pacemaker/pcmk_sched_allocate.c node = pe_find_node_id(data_set->nodes, id); node 573 lib/pacemaker/pcmk_sched_allocate.c if (node == NULL) { node 577 lib/pacemaker/pcmk_sched_allocate.c } else if (can_run_resources(node) == FALSE && node->details->maintenance == FALSE) { node 579 lib/pacemaker/pcmk_sched_allocate.c node->details->uname); node 583 lib/pacemaker/pcmk_sched_allocate.c crm_trace("Processing node %s", node->details->uname); node 584 lib/pacemaker/pcmk_sched_allocate.c if (node->details->online node 608 lib/pacemaker/pcmk_sched_allocate.c check_actions_for(rsc_entry, rsc, node, data_set); node 631 lib/pacemaker/pcmk_sched_allocate.c failcount_clear_action_exists(pe_node_t * node, pe_resource_t * rsc) node 634 lib/pacemaker/pcmk_sched_allocate.c GList *list = pe__resource_actions(rsc, node, CRM_OP_CLEAR_FAILCOUNT, TRUE); node 652 lib/pacemaker/pcmk_sched_allocate.c check_migration_threshold(pe_resource_t *rsc, pe_node_t *node, node 669 lib/pacemaker/pcmk_sched_allocate.c fail_count = pe_get_failcount(node, rsc, NULL, node 686 lib/pacemaker/pcmk_sched_allocate.c resource_location(failed, node, -INFINITY, "__fail_limit__", data_set); node 688 lib/pacemaker/pcmk_sched_allocate.c failed->id, node->details->uname, fail_count, node 692 lib/pacemaker/pcmk_sched_allocate.c failed->id, countdown, node->details->uname); node 697 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set) node 705 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(child_rsc, node, data_set); node 712 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *current = pe_find_node_id(rsc->running_on, node->details->id); node 713 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 721 lib/pacemaker/pcmk_sched_allocate.c resource_location(sticky_rsc, node, rsc->stickiness, "stickiness", data_set); node 724 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, rsc->stickiness); node 730 lib/pacemaker/pcmk_sched_allocate.c " and node %s is not explicitly allowed", rsc->id, node->details->uname); node 749 lib/pacemaker/pcmk_sched_allocate.c if (failcount_clear_action_exists(node, rsc) == FALSE) { node 750 lib/pacemaker/pcmk_sched_allocate.c check_migration_threshold(rsc, node, data_set); node 859 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 862 lib/pacemaker/pcmk_sched_allocate.c g_hash_table_foreach(node->details->attrs, calculate_system_health, &system_health); node 865 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, system_health); node 877 lib/pacemaker/pcmk_sched_allocate.c rsc2node_new(health_strategy, rsc, system_health, NULL, node, data_set); node 915 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 916 lib/pacemaker/pcmk_sched_allocate.c const char *probed = pe_node_attribute_raw(node, CRM_OP_PROBED); node 918 lib/pacemaker/pcmk_sched_allocate.c if (node->details->online == FALSE) { node 920 lib/pacemaker/pcmk_sched_allocate.c if (pe__is_remote_node(node) && node->details->remote_rsc node 921 lib/pacemaker/pcmk_sched_allocate.c && (get_remote_node_state(node) == remote_state_failed)) { node 923 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, node, "the connection is unrecoverable", FALSE); node 927 lib/pacemaker/pcmk_sched_allocate.c } else if (node->details->unclean) { node 930 lib/pacemaker/pcmk_sched_allocate.c } else if (node->details->rsc_discovery_enabled == FALSE) { node 936 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *probe_op = custom_action(NULL, crm_strdup_printf("%s-%s", CRM_OP_REPROBE, node->details->uname), node 937 lib/pacemaker/pcmk_sched_allocate.c CRM_OP_REPROBE, node, FALSE, TRUE, data_set); node 946 lib/pacemaker/pcmk_sched_allocate.c rsc->cmds->create_probe(rsc, node, probe_node_complete, FALSE, data_set); node 953 lib/pacemaker/pcmk_sched_allocate.c rsc_discover_filter(pe_resource_t *rsc, pe_node_t *node) node 965 lib/pacemaker/pcmk_sched_allocate.c rsc_discover_filter(child_rsc, node); node 968 lib/pacemaker/pcmk_sched_allocate.c match = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 975 lib/pacemaker/pcmk_sched_allocate.c shutdown_time(pe_node_t *node, pe_working_set_t *data_set) node 977 lib/pacemaker/pcmk_sched_allocate.c const char *shutdown = pe_node_attribute_raw(node, XML_CIB_ATTR_SHUTDOWN); node 1030 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = rsc->running_on->data; node 1032 lib/pacemaker/pcmk_sched_allocate.c if (node->details->shutdown) { node 1033 lib/pacemaker/pcmk_sched_allocate.c if (node->details->unclean) { node 1035 lib/pacemaker/pcmk_sched_allocate.c rsc->id, node->details->uname); node 1037 lib/pacemaker/pcmk_sched_allocate.c rsc->lock_node = node; node 1038 lib/pacemaker/pcmk_sched_allocate.c rsc->lock_time = shutdown_time(node, data_set); node 1062 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = item->data; node 1064 lib/pacemaker/pcmk_sched_allocate.c if (strcmp(node->details->uname, rsc->lock_node->details->uname)) { node 1065 lib/pacemaker/pcmk_sched_allocate.c resource_location(rsc, node, -CRM_SCORE_INFINITY, node 1092 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1094 lib/pacemaker/pcmk_sched_allocate.c if (node && (node->weight >= 0) && node->details->online node 1095 lib/pacemaker/pcmk_sched_allocate.c && (node->details->type != node_ping)) { node 1106 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1112 lib/pacemaker/pcmk_sched_allocate.c common_apply_stickiness(rsc, node, data_set); node 1113 lib/pacemaker/pcmk_sched_allocate.c rsc_discover_filter(rsc, node); node 1235 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1242 lib/pacemaker/pcmk_sched_allocate.c r1_node = g_hash_table_lookup(r1_nodes, node->details->id); node 1250 lib/pacemaker/pcmk_sched_allocate.c r2_node = g_hash_table_lookup(r2_nodes, node->details->id); node 1354 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1356 lib/pacemaker/pcmk_sched_allocate.c if (node->details->online node 1357 lib/pacemaker/pcmk_sched_allocate.c && pe_get_failcount(node, rsc, NULL, pe_fc_effective, NULL, node 1362 lib/pacemaker/pcmk_sched_allocate.c clear_op = pe__clear_failcount(rsc, node, "it is orphaned", node 1393 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1395 lib/pacemaker/pcmk_sched_allocate.c dump_node_capacity(log_prio, "Original", node); node 1405 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1407 lib/pacemaker/pcmk_sched_allocate.c dump_node_capacity(log_prio, "Remaining", node); node 1523 lib/pacemaker/pcmk_sched_allocate.c fence_guest(pe_node_t *node, pe_working_set_t *data_set) node 1525 lib/pacemaker/pcmk_sched_allocate.c pe_resource_t *container = node->details->remote_rsc->container; node 1551 lib/pacemaker/pcmk_sched_allocate.c stonith_op = pe_fence_op(node, fence_action, FALSE, "guest is unclean", FALSE, data_set); node 1560 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *parent_stonith_op = pe_fence_op(stop->node, NULL, FALSE, NULL, FALSE, data_set); node 1562 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, stonith_op->id, stop->node->details->uname); node 1571 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, stonith_op->id, node 1581 lib/pacemaker/pcmk_sched_allocate.c stop = find_first_action(node->details->remote_rsc->actions, NULL, node 1588 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, stonith_op->id, stop->id); node 1594 lib/pacemaker/pcmk_sched_allocate.c node->details->uname, stonith_op->id); node 1633 lib/pacemaker/pcmk_sched_allocate.c pe_node_t *node = (pe_node_t *) gIter->data; node 1638 lib/pacemaker/pcmk_sched_allocate.c if (pe__is_guest_node(node)) { node 1639 lib/pacemaker/pcmk_sched_allocate.c if (node->details->remote_requires_reset && need_stonith node 1640 lib/pacemaker/pcmk_sched_allocate.c && pe_can_fence(data_set, node)) { node 1641 lib/pacemaker/pcmk_sched_allocate.c fence_guest(node, data_set); node 1648 lib/pacemaker/pcmk_sched_allocate.c if (node->details->unclean node 1649 lib/pacemaker/pcmk_sched_allocate.c && need_stonith && pe_can_fence(data_set, node)) { node 1651 lib/pacemaker/pcmk_sched_allocate.c stonith_op = pe_fence_op(node, NULL, FALSE, "node is unclean", FALSE, data_set); node 1652 lib/pacemaker/pcmk_sched_allocate.c pe_warn("Scheduling Node %s for STONITH", node->details->uname); node 1656 lib/pacemaker/pcmk_sched_allocate.c if (node->details->is_dc) { node 1677 lib/pacemaker/pcmk_sched_allocate.c } else if (node->details->online && node->details->shutdown && node 1681 lib/pacemaker/pcmk_sched_allocate.c pe__is_guest_or_remote_node(node) == FALSE) { node 1683 lib/pacemaker/pcmk_sched_allocate.c pe_action_t *down_op = sched_shutdown_op(node, data_set); node 1685 lib/pacemaker/pcmk_sched_allocate.c if (node->details->is_dc) { node 1694 lib/pacemaker/pcmk_sched_allocate.c if (node->details->unclean && stonith_op == NULL) { node 1696 lib/pacemaker/pcmk_sched_allocate.c pe_warn("Node %s is unclean!", node->details->uname); node 1724 lib/pacemaker/pcmk_sched_allocate.c node_stop->node->details->uname, node 1725 lib/pacemaker/pcmk_sched_allocate.c dc_down->task, dc_down->node->details->uname); node 1945 lib/pacemaker/pcmk_sched_allocate.c CRM_ASSERT(action->node); node 1946 lib/pacemaker/pcmk_sched_allocate.c CRM_ASSERT(pe__is_guest_or_remote_node(action->node)); node 1948 lib/pacemaker/pcmk_sched_allocate.c remote_rsc = action->node->details->remote_rsc; node 1955 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "container failed", FALSE); node 2027 lib/pacemaker/pcmk_sched_allocate.c get_remote_node_state(pe_node_t *node) node 2032 lib/pacemaker/pcmk_sched_allocate.c CRM_ASSERT(node); node 2034 lib/pacemaker/pcmk_sched_allocate.c remote_rsc = node->details->remote_rsc; node 2062 lib/pacemaker/pcmk_sched_allocate.c && node->details->remote_was_fenced node 2063 lib/pacemaker/pcmk_sched_allocate.c && !pe__shutdown_requested(node)) { node 2108 lib/pacemaker/pcmk_sched_allocate.c enum remote_connection_state state = get_remote_node_state(action->node); node 2116 lib/pacemaker/pcmk_sched_allocate.c CRM_ASSERT(action->node); node 2117 lib/pacemaker/pcmk_sched_allocate.c CRM_ASSERT(pe__is_guest_or_remote_node(action->node)); node 2119 lib/pacemaker/pcmk_sched_allocate.c remote_rsc = action->node->details->remote_rsc; node 2160 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "resources are active and the connection is unrecoverable", FALSE); node 2208 lib/pacemaker/pcmk_sched_allocate.c pe_fence_node(data_set, action->node, "resources are in an unknown state and the connection is unrecoverable", FALSE); node 2267 lib/pacemaker/pcmk_sched_allocate.c if (action->node == NULL) { node 2271 lib/pacemaker/pcmk_sched_allocate.c if (!pe__is_guest_or_remote_node(action->node)) { node 2285 lib/pacemaker/pcmk_sched_allocate.c remote = action->node->details->remote_rsc; node 2301 lib/pacemaker/pcmk_sched_allocate.c if ((rsc_action->node->details != action->node->details) node 2339 lib/pacemaker/pcmk_sched_allocate.c && probe->node && rh_action->node node 2340 lib/pacemaker/pcmk_sched_allocate.c && probe->node->details == rh_action->node->details) { node 2350 lib/pacemaker/pcmk_sched_allocate.c && probe->node && rh_action->node node 2351 lib/pacemaker/pcmk_sched_allocate.c && probe->node->details != rh_action->node->details) { node 2511 lib/pacemaker/pcmk_sched_allocate.c probe->node ? probe->node->details->uname: "", node 2513 lib/pacemaker/pcmk_sched_allocate.c after->node ? after->node->details->uname : ""); node 2605 lib/pacemaker/pcmk_sched_allocate.c after->node ? after->node->details->uname: "", node 2607 lib/pacemaker/pcmk_sched_allocate.c after_wrapper->action->node ? after_wrapper->action->node->details->uname : "", node 2986 lib/pacemaker/pcmk_sched_allocate.c && action->node node 2987 lib/pacemaker/pcmk_sched_allocate.c && action->node->details->shutdown node 3000 lib/pacemaker/pcmk_sched_allocate.c action->node->details->unclean ? "fence" : "shut down", node 3001 lib/pacemaker/pcmk_sched_allocate.c action->node->details->uname, action->rsc->id, node 3033 lib/pacemaker/pcmk_sched_allocate.c if (pe__is_guest_node(action->node)) { node 3034 lib/pacemaker/pcmk_sched_allocate.c node_name = crm_strdup_printf("%s (resource: %s)", action->node->details->uname, action->node->details->remote_rsc->container->id); node 3035 lib/pacemaker/pcmk_sched_allocate.c } else if(action->node) { node 3036 lib/pacemaker/pcmk_sched_allocate.c node_name = crm_strdup_printf("%s", action->node->details->uname); node 19 lib/pacemaker/pcmk_sched_bundle.c is_bundle_node(pe__bundle_variant_data_t *data, pe_node_t *node) node 24 lib/pacemaker/pcmk_sched_bundle.c if (node->details == replica->node->details) { node 62 lib/pacemaker/pcmk_sched_bundle.c migration_threshold_reached(pe_resource_t *rsc, pe_node_t *node, node 78 lib/pacemaker/pcmk_sched_bundle.c fail_count = pe_get_failcount(node, rsc, NULL, node 90 lib/pacemaker/pcmk_sched_bundle.c rsc->id, node->details->uname, fail_count, node 96 lib/pacemaker/pcmk_sched_bundle.c rsc->id, countdown, node->details->uname); node 158 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node = NULL; node 162 lib/pacemaker/pcmk_sched_bundle.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 163 lib/pacemaker/pcmk_sched_bundle.c if (node->details != replica->node->details) { node 164 lib/pacemaker/pcmk_sched_bundle.c node->weight = -INFINITY; node 165 lib/pacemaker/pcmk_sched_bundle.c } else if (!migration_threshold_reached(replica->child, node, node 167 lib/pacemaker/pcmk_sched_bundle.c node->weight = INFINITY; node 174 lib/pacemaker/pcmk_sched_bundle.c replica->child->cmds->allocate(replica->child, replica->node, node 182 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node = NULL; node 185 lib/pacemaker/pcmk_sched_bundle.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 186 lib/pacemaker/pcmk_sched_bundle.c if (is_bundle_node(bundle_data, node)) { node 187 lib/pacemaker/pcmk_sched_bundle.c node->weight = 0; node 189 lib/pacemaker/pcmk_sched_bundle.c node->weight = -INFINITY; node 412 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node = (pe_node_t *) gIter->data; node 414 lib/pacemaker/pcmk_sched_bundle.c pair = compatible_replica_for_node(rsc_lh, node, rsc, filter, current); node 553 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_action_flags(pe_action_t *action, pe_node_t *node) node 570 lib/pacemaker/pcmk_sched_bundle.c return summary_action_flags(action, data->child->children, node); node 577 lib/pacemaker/pcmk_sched_bundle.c flags = summary_action_flags(action, containers, node); node 617 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node) node 629 lib/pacemaker/pcmk_sched_bundle.c && (node->details == replica->node->details)) { node 639 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node, enum pe_action_flags flags, node 692 lib/pacemaker/pcmk_sched_bundle.c node); node 700 lib/pacemaker/pcmk_sched_bundle.c NULL, task2text(task), node); node 702 lib/pacemaker/pcmk_sched_bundle.c first_action = find_first_action(first_child->actions, NULL, task2text(task), node); node 705 lib/pacemaker/pcmk_sched_bundle.c then_replica = replica_for_container(then->rsc, then_child, node); node 716 lib/pacemaker/pcmk_sched_bundle.c NULL, then->task, node); node 718 lib/pacemaker/pcmk_sched_bundle.c then_action = find_first_action(then_child->actions, NULL, then->task, node); node 762 lib/pacemaker/pcmk_sched_bundle.c then_action, node, node 763 lib/pacemaker/pcmk_sched_bundle.c first_child->cmds->action_flags(first_action, node), node 814 lib/pacemaker/pcmk_sched_bundle.c pe_node_t *node, enum pe_action_flags flags, node 823 lib/pacemaker/pcmk_sched_bundle.c changed = multi_update_interleave_actions(first, then, node, flags, node 831 lib/pacemaker/pcmk_sched_bundle.c changed |= native_update_actions(first, then, node, flags, filter, node 839 lib/pacemaker/pcmk_sched_bundle.c pe_action_t *then_child_action = find_first_action(then_child->actions, NULL, then->task, node); node 842 lib/pacemaker/pcmk_sched_bundle.c enum pe_action_flags then_child_flags = then_child->cmds->action_flags(then_child_action, node); node 846 lib/pacemaker/pcmk_sched_bundle.c then_child_action, node, flags, filter, type, data_set); node 959 lib/pacemaker/pcmk_sched_bundle.c pcmk__bundle_create_probe(pe_resource_t *rsc, pe_node_t *node, node 975 lib/pacemaker/pcmk_sched_bundle.c any_created |= replica->ip->cmds->create_probe(replica->ip, node, node 979 lib/pacemaker/pcmk_sched_bundle.c if (replica->child && (node->details == replica->node->details)) { node 981 lib/pacemaker/pcmk_sched_bundle.c node, complete, node 986 lib/pacemaker/pcmk_sched_bundle.c node, complete, node 1024 lib/pacemaker/pcmk_sched_bundle.c && replica->remote->cmds->create_probe(replica->remote, node, node 1035 lib/pacemaker/pcmk_sched_bundle.c probe_uuid, NULL, node); node 1041 lib/pacemaker/pcmk_sched_bundle.c replica->remote->id, node->details->uname); node 46 lib/pacemaker/pcmk_sched_clone.c parent_node_instance(const pe_resource_t * rsc, pe_node_t * node) node 50 lib/pacemaker/pcmk_sched_clone.c if (node != NULL && rsc->parent) { node 51 lib/pacemaker/pcmk_sched_clone.c ret = pe_hash_table_lookup(rsc->parent->allowed_nodes, node->details->id); node 52 lib/pacemaker/pcmk_sched_clone.c } else if(node != NULL) { node 53 lib/pacemaker/pcmk_sched_clone.c ret = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 373 lib/pacemaker/pcmk_sched_clone.c can_run_instance(pe_resource_t * rsc, pe_node_t * node, int limit) node 377 lib/pacemaker/pcmk_sched_clone.c if (node == NULL && rsc->allowed_nodes) { node 386 lib/pacemaker/pcmk_sched_clone.c if (!node) { node 390 lib/pacemaker/pcmk_sched_clone.c } else if (can_run_resources(node) == FALSE) { node 397 lib/pacemaker/pcmk_sched_clone.c local_node = parent_node_instance(rsc, node); node 400 lib/pacemaker/pcmk_sched_clone.c crm_warn("%s cannot run on %s: node not allowed", rsc->id, node->details->uname); node 404 lib/pacemaker/pcmk_sched_clone.c common_update_score(rsc, node->details->id, local_node->weight); node 406 lib/pacemaker/pcmk_sched_clone.c rsc->id, node->details->uname); node 410 lib/pacemaker/pcmk_sched_clone.c rsc->id, node->details->uname, local_node->count); node 415 lib/pacemaker/pcmk_sched_clone.c rsc->id, node->details->uname, local_node->count, limit); node 419 lib/pacemaker/pcmk_sched_clone.c if (node) { node 420 lib/pacemaker/pcmk_sched_clone.c common_update_score(rsc, node->details->id, -INFINITY); node 540 lib/pacemaker/pcmk_sched_clone.c pe_node_t *node = nIter->data; node 542 lib/pacemaker/pcmk_sched_clone.c node->count = 0; node 543 lib/pacemaker/pcmk_sched_clone.c if (can_run_resources(node)) { node 969 lib/pacemaker/pcmk_sched_clone.c assign_node(pe_resource_t * rsc, pe_node_t * node, gboolean force) node 978 lib/pacemaker/pcmk_sched_clone.c changed |= assign_node(child_rsc, node, force); node 988 lib/pacemaker/pcmk_sched_clone.c native_assign_node(rsc, NULL, node, force); node 995 lib/pacemaker/pcmk_sched_clone.c pe_node_t *node = NULL; node 1001 lib/pacemaker/pcmk_sched_clone.c node = child_rsc->fns->location(child_rsc, NULL, current); node 1009 lib/pacemaker/pcmk_sched_clone.c if (node && (node->details == local_node->details)) { node 1012 lib/pacemaker/pcmk_sched_clone.c } else if (node) { node 1013 lib/pacemaker/pcmk_sched_clone.c crm_trace("%s - %s vs %s", child_rsc->id, node->details->uname, node 1042 lib/pacemaker/pcmk_sched_clone.c pe_node_t *node = (pe_node_t *) gIter->data; node 1044 lib/pacemaker/pcmk_sched_clone.c pair = find_compatible_child_by_node(local_child, node, rsc, filter, current); node 1212 lib/pacemaker/pcmk_sched_clone.c summary_action_flags(pe_action_t * action, GListPtr children, pe_node_t * node) node 1225 lib/pacemaker/pcmk_sched_clone.c child_action = find_first_action(child->actions, NULL, task_s, child->children ? NULL : node); node 1227 lib/pacemaker/pcmk_sched_clone.c node ? node->details->uname : "none", child_action?child_action->uuid:"NA"); node 1229 lib/pacemaker/pcmk_sched_clone.c enum pe_action_flags child_flags = child->cmds->action_flags(child_action, node); node 1247 lib/pacemaker/pcmk_sched_clone.c if (node == NULL) { node 1256 lib/pacemaker/pcmk_sched_clone.c clone_action_flags(pe_action_t * action, pe_node_t * node) node 1258 lib/pacemaker/pcmk_sched_clone.c return summary_action_flags(action, action->rsc->children, node); node 1340 lib/pacemaker/pcmk_sched_clone.c rsc_known_on(const pe_resource_t *rsc, const pe_node_t *node) node 1348 lib/pacemaker/pcmk_sched_clone.c if (rsc_known_on(child, node)) { node 1359 lib/pacemaker/pcmk_sched_clone.c if (node->details == known_node->details) { node 1369 lib/pacemaker/pcmk_sched_clone.c find_instance_on(const pe_resource_t *clone, const pe_node_t *node) node 1374 lib/pacemaker/pcmk_sched_clone.c if (rsc_known_on(child, node)) { node 1383 lib/pacemaker/pcmk_sched_clone.c probe_unique_clone(pe_resource_t *rsc, pe_node_t *node, pe_action_t *complete, node 1393 lib/pacemaker/pcmk_sched_clone.c any_created |= child->cmds->create_probe(child, node, complete, force, node 1401 lib/pacemaker/pcmk_sched_clone.c probe_anonymous_clone(pe_resource_t *rsc, pe_node_t *node, node 1406 lib/pacemaker/pcmk_sched_clone.c pe_resource_t *child = find_instance_on(rsc, node); node 1418 lib/pacemaker/pcmk_sched_clone.c if (local_node && (local_node->details == node->details)) { node 1430 lib/pacemaker/pcmk_sched_clone.c return child->cmds->create_probe(child, node, complete, force, data_set); node 1434 lib/pacemaker/pcmk_sched_clone.c clone_create_probe(pe_resource_t * rsc, pe_node_t * node, pe_action_t * complete, node 1448 lib/pacemaker/pcmk_sched_clone.c pe_node_t *allowed = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 1457 lib/pacemaker/pcmk_sched_clone.c g_hash_table_remove(rsc->allowed_nodes, node->details->id); node 1465 lib/pacemaker/pcmk_sched_clone.c any_created = probe_unique_clone(rsc, node, complete, force, data_set); node 1467 lib/pacemaker/pcmk_sched_clone.c any_created = probe_anonymous_clone(rsc, node, complete, force, node 801 lib/pacemaker/pcmk_sched_constraints.c const char *node = crm_element_value(xml_obj, XML_CIB_TAG_NODE); node 814 lib/pacemaker/pcmk_sched_constraints.c if (node != NULL && score != NULL) { node 816 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *match = pe_find_node(data_set->nodes, node); node 1041 lib/pacemaker/pcmk_sched_constraints.c get_node_score(const char *rule, const char *score, gboolean raw, pe_node_t * node, pe_resource_t *rsc) node 1052 lib/pacemaker/pcmk_sched_constraints.c const char *attr_score = pe_node_attribute_calculated(node, score, rsc); node 1056 lib/pacemaker/pcmk_sched_constraints.c rule, node->details->uname, score); node 1061 lib/pacemaker/pcmk_sched_constraints.c rule, node->details->uname, attr_score, score); node 1143 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *node = (pe_node_t *) gIter->data; node 1145 lib/pacemaker/pcmk_sched_constraints.c node->weight = get_node_score(rule_id, score, raw_score, node, rsc); node 1151 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *node = (pe_node_t *) gIter->data; node 1153 lib/pacemaker/pcmk_sched_constraints.c accept = pe_test_rule(rule_xml, node->details->attrs, RSC_ROLE_UNKNOWN, node 1157 lib/pacemaker/pcmk_sched_constraints.c node->details->uname); node 1159 lib/pacemaker/pcmk_sched_constraints.c score_f = get_node_score(rule_id, score, raw_score, node, rsc); node 1165 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *local = pe_find_node_id(match_L, node->details->id); node 1171 lib/pacemaker/pcmk_sched_constraints.c local = pe__copy_node(node); node 1178 lib/pacemaker/pcmk_sched_constraints.c crm_trace("node %s now has weight %d", node->details->uname, local->weight); node 1182 lib/pacemaker/pcmk_sched_constraints.c pe_node_t *delete = pe_find_node_id(match_L, node->details->id); node 1186 lib/pacemaker/pcmk_sched_constraints.c crm_trace("node %s did not match", node->details->uname); node 26 lib/pacemaker/pcmk_sched_graph.c get_action_flags(pe_action_t * action, pe_node_t * node) node 33 lib/pacemaker/pcmk_sched_graph.c if (pe_rsc_is_clone(action->rsc) && node) { node 36 lib/pacemaker/pcmk_sched_graph.c enum pe_action_flags clone_flags = action->rsc->cmds->action_flags(action, node); node 176 lib/pacemaker/pcmk_sched_graph.c graph_update_action(pe_action_t * first, pe_action_t * then, pe_node_t * node, node 201 lib/pacemaker/pcmk_sched_graph.c node = first->node; node 210 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 230 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 243 lib/pacemaker/pcmk_sched_graph.c changed |= first->rsc->cmds->update_actions(first, then, node, node 268 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 286 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 324 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 339 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 359 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 373 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 387 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 400 lib/pacemaker/pcmk_sched_graph.c changed |= then->rsc->cmds->update_actions(first, then, node, node 532 lib/pacemaker/pcmk_sched_graph.c : (then->node? then->node->details->uname : "")); node 561 lib/pacemaker/pcmk_sched_graph.c pe_node_t *then_node = then->node; node 562 lib/pacemaker/pcmk_sched_graph.c pe_node_t *first_node = first->node; node 623 lib/pacemaker/pcmk_sched_graph.c : (then->node? then->node->details->uname : ""), node 628 lib/pacemaker/pcmk_sched_graph.c : (first->node? first->node->details->uname : ""), node 645 lib/pacemaker/pcmk_sched_graph.c pe_node_t *node = then->node; node 646 lib/pacemaker/pcmk_sched_graph.c changed |= graph_update_action(first, then, node, first_flags, node 675 lib/pacemaker/pcmk_sched_graph.c : (first->node? first->node->details->uname : "")); node 699 lib/pacemaker/pcmk_sched_graph.c : (then->node? then->node->details-> uname : "")); node 717 lib/pacemaker/pcmk_sched_graph.c shutdown_constraints(pe_node_t * node, pe_action_t * shutdown_op, pe_working_set_t * data_set) node 727 lib/pacemaker/pcmk_sched_graph.c if (action->rsc == NULL || action->node == NULL) { node 729 lib/pacemaker/pcmk_sched_graph.c } else if (action->node->details != node->details) { node 734 lib/pacemaker/pcmk_sched_graph.c } else if (node->details->maintenance) { node 736 lib/pacemaker/pcmk_sched_graph.c action->uuid, node->details->uname); node 750 lib/pacemaker/pcmk_sched_graph.c node->details->uname); node 790 lib/pacemaker/pcmk_sched_graph.c || !pe__is_guest_or_remote_node(action->node)) { node 794 lib/pacemaker/pcmk_sched_graph.c CRM_ASSERT(action->node->details->remote_rsc != NULL); node 796 lib/pacemaker/pcmk_sched_graph.c began_on = pe__current_node(action->node->details->remote_rsc); node 797 lib/pacemaker/pcmk_sched_graph.c ended_on = action->node->details->remote_rsc->allocated_to; node 798 lib/pacemaker/pcmk_sched_graph.c if (action->node->details->remote_rsc node 799 lib/pacemaker/pcmk_sched_graph.c && (action->node->details->remote_rsc->container == NULL) node 800 lib/pacemaker/pcmk_sched_graph.c && action->node->details->remote_rsc->partial_migration_target) { node 878 lib/pacemaker/pcmk_sched_graph.c add_node_to_xml(const pe_node_t *node, void *xml) node 880 lib/pacemaker/pcmk_sched_graph.c add_node_to_xml_by_id(node->details->id, (xmlNode *) xml); node 900 lib/pacemaker/pcmk_sched_graph.c pe_node_t *node = (pe_node_t *) gIter->data; node 901 lib/pacemaker/pcmk_sched_graph.c struct pe_node_shared_s *details = node->details; node 903 lib/pacemaker/pcmk_sched_graph.c if (!pe__is_guest_or_remote_node(node)) { node 910 lib/pacemaker/pcmk_sched_graph.c add_node_to_xml_by_id(node->details->id, maintenance), node 955 lib/pacemaker/pcmk_sched_graph.c CRM_CHECK(xml && action && action->node && data_set, return); node 961 lib/pacemaker/pcmk_sched_graph.c add_node_to_xml_by_id(action->node->details->id, downed); node 970 lib/pacemaker/pcmk_sched_graph.c add_node_to_xml_by_id(action->node->details->id, downed); node 971 lib/pacemaker/pcmk_sched_graph.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); node 1003 lib/pacemaker/pcmk_sched_graph.c if ((action->rsc->lock_node == NULL) || (action->node == NULL) node 1004 lib/pacemaker/pcmk_sched_graph.c || (action->node->details != action->rsc->lock_node->details)) { node 1011 lib/pacemaker/pcmk_sched_graph.c if (action->node->details->shutdown && action->task node 1112 lib/pacemaker/pcmk_sched_graph.c if (needs_node_info && action->node != NULL) { node 1115 lib/pacemaker/pcmk_sched_graph.c crm_xml_add(action_xml, XML_LRM_ATTR_TARGET, action->node->details->uname); node 1116 lib/pacemaker/pcmk_sched_graph.c crm_xml_add(action_xml, XML_LRM_ATTR_TARGET_UUID, action->node->details->id); node 1121 lib/pacemaker/pcmk_sched_graph.c g_hash_table_insert(action->meta, strdup(XML_LRM_ATTR_TARGET), strdup(action->node->details->uname)); node 1122 lib/pacemaker/pcmk_sched_graph.c g_hash_table_insert(action->meta, strdup(XML_LRM_ATTR_TARGET_UUID), strdup(action->node->details->id)); node 1211 lib/pacemaker/pcmk_sched_graph.c if (action->rsc != NULL && action->node) { node 1214 lib/pacemaker/pcmk_sched_graph.c get_rsc_attributes(p, action->rsc, action->node, data_set); node 1223 lib/pacemaker/pcmk_sched_graph.c action->node, data_set); node 1267 lib/pacemaker/pcmk_sched_graph.c if (action->node && /* make clang analyzer happy */ node 1268 lib/pacemaker/pcmk_sched_graph.c pe__is_guest_node(action->node)) { node 1283 lib/pacemaker/pcmk_sched_graph.c host = pe__current_node(action->node->details->remote_rsc->container); node 1290 lib/pacemaker/pcmk_sched_graph.c host = action->node->details->remote_rsc->container->allocated_to; node 1305 lib/pacemaker/pcmk_sched_graph.c } else if (pcmk__str_eq(action->task, CRM_OP_FENCE, pcmk__str_casei) && action->node) { node 1312 lib/pacemaker/pcmk_sched_graph.c g_hash_table_foreach(action->node->details->attrs, hash2metafield, args_xml); node 1319 lib/pacemaker/pcmk_sched_graph.c if (needs_node_info && (action->node != NULL)) { node 1409 lib/pacemaker/pcmk_sched_graph.c if (action->node == NULL) { node 1419 lib/pacemaker/pcmk_sched_graph.c action->uuid, action->id, action->node->details->uname); node 1421 lib/pacemaker/pcmk_sched_graph.c } else if (pe__is_guest_node(action->node) node 1422 lib/pacemaker/pcmk_sched_graph.c && !action->node->details->remote_requires_reset) { node 1425 lib/pacemaker/pcmk_sched_graph.c action->uuid, action->id, action->node->details->uname); node 1427 lib/pacemaker/pcmk_sched_graph.c } else if (action->node->details->online == false) { node 1437 lib/pacemaker/pcmk_sched_graph.c } else if (action->node->details->unclean == false) { node 1554 lib/pacemaker/pcmk_sched_graph.c pe_node_t *input_node = input->action->node; node 1576 lib/pacemaker/pcmk_sched_graph.c } else if ((input_node == NULL) || (action->node == NULL) node 1577 lib/pacemaker/pcmk_sched_graph.c || (input_node->details != action->node->details)) { node 1582 lib/pacemaker/pcmk_sched_graph.c (action->node? action->node->details->uname : "<none>"), node 1597 lib/pacemaker/pcmk_sched_graph.c if (input->action->node && action->node node 1598 lib/pacemaker/pcmk_sched_graph.c && (input->action->node->details != action->node->details)) { node 1603 lib/pacemaker/pcmk_sched_graph.c action->node->details->uname, node 1604 lib/pacemaker/pcmk_sched_graph.c input->action->node->details->uname); node 1642 lib/pacemaker/pcmk_sched_graph.c input->action->node? input->action->node->details->uname : "no node", node 1659 lib/pacemaker/pcmk_sched_graph.c input->action->node? input->action->node->details->uname : "", node 1661 lib/pacemaker/pcmk_sched_graph.c action->node? action->node->details->uname : "", node 1674 lib/pacemaker/pcmk_sched_graph.c action->node? action->node->details->uname : "", node 1676 lib/pacemaker/pcmk_sched_graph.c init_action->node? init_action->node->details->uname : ""); node 1685 lib/pacemaker/pcmk_sched_graph.c action->node? action->node->details->uname : "", node 1687 lib/pacemaker/pcmk_sched_graph.c input->action->node? input->action->node->details->uname : "", node 1690 lib/pacemaker/pcmk_sched_graph.c init_action->node? init_action->node->details->uname : ""); node 1710 lib/pacemaker/pcmk_sched_graph.c input->action->node? input->action->node->details->uname : "", node 1712 lib/pacemaker/pcmk_sched_graph.c action->node? action->node->details->uname : "", node 1726 lib/pacemaker/pcmk_sched_graph.c && input->action->rsc && input->action->node node 1727 lib/pacemaker/pcmk_sched_graph.c && input->action->node->details->remote_rsc node 1728 lib/pacemaker/pcmk_sched_graph.c && (input->action->node->details->remote_rsc->container == action->rsc)) { node 23 lib/pacemaker/pcmk_sched_group.c pe_node_t *node = NULL; node 63 lib/pacemaker/pcmk_sched_group.c node = child_rsc->cmds->allocate(child_rsc, prefer, data_set); node 65 lib/pacemaker/pcmk_sched_group.c group_node = node; node 381 lib/pacemaker/pcmk_sched_group.c group_action_flags(pe_action_t * action, pe_node_t * node) node 390 lib/pacemaker/pcmk_sched_group.c pe_action_t *child_action = find_first_action(child->actions, NULL, task_s, node); node 393 lib/pacemaker/pcmk_sched_group.c enum pe_action_flags child_flags = child->cmds->action_flags(child_action, node); node 426 lib/pacemaker/pcmk_sched_group.c group_update_actions(pe_action_t *first, pe_action_t *then, pe_node_t *node, node 434 lib/pacemaker/pcmk_sched_group.c changed |= native_update_actions(first, then, node, flags, filter, type, node 439 lib/pacemaker/pcmk_sched_group.c pe_action_t *child_action = find_first_action(child->actions, NULL, then->task, node); node 442 lib/pacemaker/pcmk_sched_group.c changed |= child->cmds->update_actions(first, child_action, node, node 26 lib/pacemaker/pcmk_sched_native.c static void Recurring(pe_resource_t *rsc, pe_action_t *start, pe_node_t *node, node 28 lib/pacemaker/pcmk_sched_native.c static void RecurringOp(pe_resource_t *rsc, pe_action_t *start, pe_node_t *node, node 30 lib/pacemaker/pcmk_sched_native.c static void Recurring_Stopped(pe_resource_t *rsc, pe_action_t *start, pe_node_t *node, node 32 lib/pacemaker/pcmk_sched_native.c static void RecurringOp_Stopped(pe_resource_t *rsc, pe_action_t *start, pe_node_t *node, node 35 lib/pacemaker/pcmk_sched_native.c void ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set); node 36 lib/pacemaker/pcmk_sched_native.c gboolean DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set); node 211 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = NULL; node 217 lib/pacemaker/pcmk_sched_native.c while (g_hash_table_iter_next(&iter, NULL, (void **) &node)) { node 219 lib/pacemaker/pcmk_sched_native.c if ((node->weight > best_score) && can_run_resources(node) node 220 lib/pacemaker/pcmk_sched_native.c && pcmk__str_eq(value, pe_node_attribute_raw(node, attr), pcmk__str_casei)) { node 222 lib/pacemaker/pcmk_sched_native.c best_score = node->weight; node 223 lib/pacemaker/pcmk_sched_native.c best_node = node->details->uname; node 260 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = NULL; node 268 lib/pacemaker/pcmk_sched_native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 275 lib/pacemaker/pcmk_sched_native.c pe_node_attribute_raw(node, attr)); node 284 lib/pacemaker/pcmk_sched_native.c node->details->uname, node->weight, factor, score); node 288 lib/pacemaker/pcmk_sched_native.c if (node->weight == INFINITY_HACK) { node 290 lib/pacemaker/pcmk_sched_native.c node->details->uname, node->weight, factor, score); node 311 lib/pacemaker/pcmk_sched_native.c new_score = pe__add_scores(weight, node->weight); node 313 lib/pacemaker/pcmk_sched_native.c if (only_positive && (new_score < 0) && (node->weight > 0)) { node 316 lib/pacemaker/pcmk_sched_native.c node->details->uname, node->weight, factor, score, node 318 lib/pacemaker/pcmk_sched_native.c node->weight = INFINITY_HACK; node 322 lib/pacemaker/pcmk_sched_native.c if (only_positive && (new_score < 0) && (node->weight == 0)) { node 324 lib/pacemaker/pcmk_sched_native.c node->details->uname, node->weight, factor, score, node 329 lib/pacemaker/pcmk_sched_native.c crm_trace("%s: %d + %f * %d = %d", node->details->uname, node 330 lib/pacemaker/pcmk_sched_native.c node->weight, factor, score, new_score); node 331 lib/pacemaker/pcmk_sched_native.c node->weight = new_score; node 469 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = NULL; node 473 lib/pacemaker/pcmk_sched_native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 474 lib/pacemaker/pcmk_sched_native.c if (node->weight == INFINITY_HACK) { node 475 lib/pacemaker/pcmk_sched_native.c node->weight = 1; node 489 lib/pacemaker/pcmk_sched_native.c node_has_been_unfenced(pe_node_t *node) node 491 lib/pacemaker/pcmk_sched_native.c const char *unfenced = pe_node_attribute_raw(node, CRM_ATTR_UNFENCED); node 711 lib/pacemaker/pcmk_sched_native.c RecurringOp(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, node 718 lib/pacemaker/pcmk_sched_native.c const char *node_uname = node? node->details->uname : "n/a"; node 774 lib/pacemaker/pcmk_sched_native.c possible_matches = find_actions_exact(rsc->actions, key, node); node 805 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); node 839 lib/pacemaker/pcmk_sched_native.c mon = custom_action(rsc, key, name, node, is_optional, TRUE, data_set); node 851 lib/pacemaker/pcmk_sched_native.c } else if (node == NULL || node->details->online == FALSE || node->details->unclean) { node 869 lib/pacemaker/pcmk_sched_native.c if ((node == NULL) || pcmk_is_set(rsc->flags, pe_rsc_managed)) { node 892 lib/pacemaker/pcmk_sched_native.c Recurring(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, pe_working_set_t * data_set) node 895 lib/pacemaker/pcmk_sched_native.c (node == NULL || node->details->maintenance == FALSE)) { node 903 lib/pacemaker/pcmk_sched_native.c RecurringOp(rsc, start, node, operation, data_set); node 910 lib/pacemaker/pcmk_sched_native.c RecurringOp_Stopped(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, node 917 lib/pacemaker/pcmk_sched_native.c const char *node_uname = node? node->details->uname : "n/a"; node 969 lib/pacemaker/pcmk_sched_native.c if (node != NULL) { node 970 lib/pacemaker/pcmk_sched_native.c possible_matches = find_actions_exact(rsc->actions, key, node); node 976 lib/pacemaker/pcmk_sched_native.c cancel_op = pe_cancel_op(rsc, name, interval_ms, node, data_set); node 1002 lib/pacemaker/pcmk_sched_native.c if (node && pcmk__str_eq(stop_node_uname, node_uname, pcmk__str_casei)) { node 1105 lib/pacemaker/pcmk_sched_native.c Recurring_Stopped(pe_resource_t * rsc, pe_action_t * start, pe_node_t * node, pe_working_set_t * data_set) node 1108 lib/pacemaker/pcmk_sched_native.c (node == NULL || node->details->maintenance == FALSE)) { node 1116 lib/pacemaker/pcmk_sched_native.c RecurringOp_Stopped(rsc, start, node, operation, data_set); node 1443 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = NULL; node 1445 lib/pacemaker/pcmk_sched_native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1446 lib/pacemaker/pcmk_sched_native.c if (node->details->remote_rsc) { node 1447 lib/pacemaker/pcmk_sched_native.c node->weight = -INFINITY; node 1544 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = item->data; node 1545 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); node 1589 lib/pacemaker/pcmk_sched_native.c if (load_stopped->node == NULL) { node 1590 lib/pacemaker/pcmk_sched_native.c load_stopped->node = pe__copy_node(current); node 1605 lib/pacemaker/pcmk_sched_native.c if (load_stopped->node == NULL) { node 1606 lib/pacemaker/pcmk_sched_native.c load_stopped->node = pe__copy_node(next); node 1664 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = item->data; node 1666 lib/pacemaker/pcmk_sched_native.c if (node->details->remote_rsc != remote_rsc) { node 1667 lib/pacemaker/pcmk_sched_native.c node->weight = -INFINITY; node 1867 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = NULL; node 1887 lib/pacemaker/pcmk_sched_native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1890 lib/pacemaker/pcmk_sched_native.c constraint->id, rsc_lh->id, node->details->uname, node 1892 lib/pacemaker/pcmk_sched_native.c node->weight = pe__add_scores(-constraint->score, node->weight); node 1894 lib/pacemaker/pcmk_sched_native.c } else if (pcmk__str_eq(pe_node_attribute_raw(node, attribute), value, pcmk__str_casei)) { node 1898 lib/pacemaker/pcmk_sched_native.c node->details->uname, constraint->score); node 1899 lib/pacemaker/pcmk_sched_native.c node->weight = pe__add_scores(constraint->score, node->weight); node 1904 lib/pacemaker/pcmk_sched_native.c constraint->id, rsc_lh->id, node->details->uname, node 1906 lib/pacemaker/pcmk_sched_native.c node->weight = pe__add_scores(-constraint->score, node->weight); node 2025 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = (pe_node_t *) gIter->data; node 2027 lib/pacemaker/pcmk_sched_native.c pe_fence_node(data_set, node, "deadman ticket was lost", FALSE); node 2057 lib/pacemaker/pcmk_sched_native.c native_action_flags(pe_action_t * action, pe_node_t * node) node 2136 lib/pacemaker/pcmk_sched_native.c native_update_actions(pe_action_t *first, pe_action_t *then, pe_node_t *node, node 2146 lib/pacemaker/pcmk_sched_native.c first->uuid, first->node ? first->node->details->uname : "[none]", node 2161 lib/pacemaker/pcmk_sched_native.c && then->node node 2163 lib/pacemaker/pcmk_sched_native.c && then->node->details == ((pe_node_t *) then_rsc->running_on->data)->details) { node 2271 lib/pacemaker/pcmk_sched_native.c then->uuid, then->node ? then->node->details->uname : "[none]", then->flags, node 2284 lib/pacemaker/pcmk_sched_native.c first->uuid, first->node ? first->node->details->uname : "[none]", node 2320 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = (pe_node_t *) gIter->data; node 2323 lib/pacemaker/pcmk_sched_native.c other_node = (pe_node_t *) pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 2327 lib/pacemaker/pcmk_sched_native.c node->weight, node->details->uname); node 2329 lib/pacemaker/pcmk_sched_native.c node->weight); node 2333 lib/pacemaker/pcmk_sched_native.c node->weight, node->details->uname); node 2334 lib/pacemaker/pcmk_sched_native.c other_node = pe__copy_node(node); node 2652 lib/pacemaker/pcmk_sched_native.c pe_node_t *node = (pe_node_t *) gIter->data; node 2655 lib/pacemaker/pcmk_sched_native.c possible_matches = find_actions(rsc->actions, key, node); node 2665 lib/pacemaker/pcmk_sched_native.c LogAction("Stop", rsc, node, NULL, stop_op, node 2754 lib/pacemaker/pcmk_sched_native.c order_after_unfencing(pe_resource_t *rsc, pe_node_t *node, pe_action_t *action, node 2771 lib/pacemaker/pcmk_sched_native.c pe_action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, FALSE, data_set); node 2775 lib/pacemaker/pcmk_sched_native.c if (!node_has_been_unfenced(node)) { node 2780 lib/pacemaker/pcmk_sched_native.c trigger_unfencing(NULL, node, reason, NULL, data_set); node 2884 lib/pacemaker/pcmk_sched_native.c DeleteRsc(pe_resource_t * rsc, pe_node_t * node, gboolean optional, pe_working_set_t * data_set) node 2887 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Resource %s not deleted from %s: failed", rsc->id, node->details->uname); node 2890 lib/pacemaker/pcmk_sched_native.c } else if (node == NULL) { node 2894 lib/pacemaker/pcmk_sched_native.c } else if (node->details->unclean || node->details->online == FALSE) { node 2896 lib/pacemaker/pcmk_sched_native.c node->details->uname); node 2900 lib/pacemaker/pcmk_sched_native.c crm_notice("Removing %s from %s", rsc->id, node->details->uname); node 2902 lib/pacemaker/pcmk_sched_native.c delete_action(rsc, node, optional); node 2914 lib/pacemaker/pcmk_sched_native.c native_create_probe(pe_resource_t * rsc, pe_node_t * node, pe_action_t * complete, node 2932 lib/pacemaker/pcmk_sched_native.c CRM_CHECK(node != NULL, return FALSE); node 2938 lib/pacemaker/pcmk_sched_native.c if (pe__is_guest_or_remote_node(node)) { node 2944 lib/pacemaker/pcmk_sched_native.c rsc->id, node->details->id); node 2946 lib/pacemaker/pcmk_sched_native.c } else if (pe__is_guest_node(node) node 2950 lib/pacemaker/pcmk_sched_native.c rsc->id, node->details->id); node 2955 lib/pacemaker/pcmk_sched_native.c rsc->id, node->details->id); node 2967 lib/pacemaker/pcmk_sched_native.c any_created = child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set) node 2984 lib/pacemaker/pcmk_sched_native.c if (!force && g_hash_table_lookup(rsc->known_on, node->details->id)) { node 2985 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Skipping known: %s on %s", rsc->id, node->details->uname); node 2989 lib/pacemaker/pcmk_sched_native.c allowed = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 2994 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, A", rsc->id, node->details->id); node 2999 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, B", rsc->id, node->details->id); node 3004 lib/pacemaker/pcmk_sched_native.c if(allowed == NULL && node->rsc_discover_mode == pe_discover_never) { node 3010 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, C", rsc->id, node->details->id); node 3016 lib/pacemaker/pcmk_sched_native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, discovery mode", rsc->id, node->details->id); node 3020 lib/pacemaker/pcmk_sched_native.c if (pe__is_guest_node(node)) { node 3021 lib/pacemaker/pcmk_sched_native.c pe_resource_t *remote = node->details->remote_rsc->container; node 3054 lib/pacemaker/pcmk_sched_native.c rsc->id, node->details->id, remote->id); node 3060 lib/pacemaker/pcmk_sched_native.c } else if(node->details->remote_requires_reset node 3061 lib/pacemaker/pcmk_sched_native.c || node->details->unclean node 3075 lib/pacemaker/pcmk_sched_native.c rsc->id, node->details->id, remote->id); node 3084 lib/pacemaker/pcmk_sched_native.c probe = custom_action(rsc, key, RSC_STATUS, node, FALSE, TRUE, data_set); node 3088 lib/pacemaker/pcmk_sched_native.c order_after_unfencing(rsc, node, probe, pe_order_optional, data_set); node 3094 lib/pacemaker/pcmk_sched_native.c running = pe_find_node_id(rsc->running_on, node->details->id); node 3102 lib/pacemaker/pcmk_sched_native.c crm_debug("Probing %s on %s (%s) %d %p", rsc->id, node->details->uname, role2text(rsc->role), node 3108 lib/pacemaker/pcmk_sched_native.c crm_trace("Probing %s on %s (%s) as %s", rsc->id, node->details->uname, role2text(rsc->role), top->id); node 3153 lib/pacemaker/pcmk_sched_native.c rsc_is_known_on(pe_resource_t *rsc, const pe_node_t *node) node 3155 lib/pacemaker/pcmk_sched_native.c if (pe_hash_table_lookup(rsc->known_on, node->details->id)) { node 3160 lib/pacemaker/pcmk_sched_native.c && pe_hash_table_lookup(rsc->parent->known_on, node->details->id)) { node 3184 lib/pacemaker/pcmk_sched_native.c CRM_CHECK(stonith_op && stonith_op->node, return); node 3185 lib/pacemaker/pcmk_sched_native.c target = stonith_op->node; node 3234 lib/pacemaker/pcmk_sched_native.c CRM_CHECK(stonith_op && stonith_op->node, return); node 3235 lib/pacemaker/pcmk_sched_native.c target = stonith_op->node; node 3359 lib/pacemaker/pcmk_sched_native.c if (action->node->details->online == FALSE || action->node->details->unclean == TRUE node 3411 lib/pacemaker/pcmk_sched_native.c ReloadRsc(pe_resource_t * rsc, pe_node_t *node, pe_working_set_t * data_set) node 3420 lib/pacemaker/pcmk_sched_native.c ReloadRsc(child_rsc, node, data_set); node 3444 lib/pacemaker/pcmk_sched_native.c stop_action(rsc, node, FALSE); node 3447 lib/pacemaker/pcmk_sched_native.c } else if (node == NULL) { node 3456 lib/pacemaker/pcmk_sched_native.c rsc, reload_key(rsc), CRMD_ACTION_RELOAD, node, FALSE, TRUE, data_set); node 16 lib/pacemaker/pcmk_sched_notif.c pe_node_t *node; node 51 lib/pacemaker/pcmk_sched_notif.c if (entry_a->node == NULL && entry_b->node == NULL) { node 54 lib/pacemaker/pcmk_sched_notif.c if (entry_a->node == NULL) { node 57 lib/pacemaker/pcmk_sched_notif.c if (entry_b->node == NULL) { node 61 lib/pacemaker/pcmk_sched_notif.c return strcmp(entry_a->node->details->id, entry_b->node->details->id); node 70 lib/pacemaker/pcmk_sched_notif.c dup->node = entry->node; node 93 lib/pacemaker/pcmk_sched_notif.c pe_node_t *node = (pe_node_t *) gIter->data; node 95 lib/pacemaker/pcmk_sched_notif.c if (node->details->uname == NULL) { node 98 lib/pacemaker/pcmk_sched_notif.c pcmk__add_word(&node_list, &node_list_len, node->details->uname); node 100 lib/pacemaker/pcmk_sched_notif.c if(node->details->remote_rsc node 101 lib/pacemaker/pcmk_sched_notif.c && node->details->remote_rsc->container node 102 lib/pacemaker/pcmk_sched_notif.c && node->details->remote_rsc->container->running_on) { node 103 lib/pacemaker/pcmk_sched_notif.c node = pe__current_node(node->details->remote_rsc->container); node 106 lib/pacemaker/pcmk_sched_notif.c if (node->details->uname == NULL) { node 109 lib/pacemaker/pcmk_sched_notif.c pcmk__add_word(&metal_list, &metal_list_len, node->details->uname); node 168 lib/pacemaker/pcmk_sched_notif.c CRM_LOG_ASSERT((node_list == NULL) || (entry->node != NULL)); node 169 lib/pacemaker/pcmk_sched_notif.c if ((node_list != NULL) && (entry->node == NULL)) { node 179 lib/pacemaker/pcmk_sched_notif.c if ((node_list != NULL) && (entry->node->details->uname != NULL)) { node 181 lib/pacemaker/pcmk_sched_notif.c entry->node->details->uname); node 204 lib/pacemaker/pcmk_sched_notif.c pe_notify(pe_resource_t * rsc, pe_node_t * node, pe_action_t * op, pe_action_t * confirm, node 218 lib/pacemaker/pcmk_sched_notif.c CRM_CHECK(node != NULL, return NULL); node 220 lib/pacemaker/pcmk_sched_notif.c if (node->details->online == FALSE) { node 234 lib/pacemaker/pcmk_sched_notif.c trigger = custom_action(rsc, key, op->task, node, node 250 lib/pacemaker/pcmk_sched_notif.c pe_post_notify(pe_resource_t * rsc, pe_node_t * node, notify_data_t * n_data, pe_working_set_t * data_set) node 260 lib/pacemaker/pcmk_sched_notif.c notify = pe_notify(rsc, node, n_data->post, n_data->post_done, n_data, data_set); node 433 lib/pacemaker/pcmk_sched_notif.c entry->node = rsc->running_on->data; node 472 lib/pacemaker/pcmk_sched_notif.c && (op->node != NULL)) { node 476 lib/pacemaker/pcmk_sched_notif.c if(task == stop_rsc && op->node->details->unclean) { node 483 lib/pacemaker/pcmk_sched_notif.c entry->node = op->node; node 631 lib/pacemaker/pcmk_sched_notif.c if (action && action->node) { node 632 lib/pacemaker/pcmk_sched_notif.c pe_resource_t *remote_rsc = action->node->details->remote_rsc; node 666 lib/pacemaker/pcmk_sched_notif.c && (op->node != NULL)) { node 805 lib/pacemaker/pcmk_sched_notif.c add_notify_env(n_data, "notify_stop_uname", action->node->details->uname); node 164 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *node = NULL; node 189 lib/pacemaker/pcmk_sched_promotable.c node = rsc->fns->location(rsc, NULL, FALSE); node 190 lib/pacemaker/pcmk_sched_promotable.c if (node == NULL) { node 197 lib/pacemaker/pcmk_sched_promotable.c rsc->id, node->details->uname); node 207 lib/pacemaker/pcmk_sched_promotable.c } else if (can_run_resources(node) == FALSE) { node 208 lib/pacemaker/pcmk_sched_promotable.c crm_trace("Node can't run any resources: %s", node->details->uname); node 215 lib/pacemaker/pcmk_sched_promotable.c } else if (pe__is_guest_node(node) && (guest_location(node) == NULL)) { node 217 lib/pacemaker/pcmk_sched_promotable.c rsc->id, node->details->remote_rsc->container->id); node 222 lib/pacemaker/pcmk_sched_promotable.c local_node = pe_hash_table_lookup(parent->allowed_nodes, node->details->id); node 225 lib/pacemaker/pcmk_sched_promotable.c crm_err("%s cannot run on %s: node not allowed", rsc->id, node->details->uname); node 233 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "%s cannot be master on %s: node full", rsc->id, node->details->uname); node 277 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *node = NULL; node 309 lib/pacemaker/pcmk_sched_promotable.c node = (pe_node_t *) pe_hash_table_lookup(rsc->allowed_nodes, chosen->details->id); node 310 lib/pacemaker/pcmk_sched_promotable.c CRM_ASSERT(node != NULL); node 314 lib/pacemaker/pcmk_sched_promotable.c node->details->uname, child->id); node 315 lib/pacemaker/pcmk_sched_promotable.c node->weight = pe__add_scores(child->sort_index, node->weight); node 395 lib/pacemaker/pcmk_sched_promotable.c node = (pe_node_t *) pe_hash_table_lookup(rsc->allowed_nodes, chosen->details->id); node 396 lib/pacemaker/pcmk_sched_promotable.c CRM_ASSERT(node != NULL); node 398 lib/pacemaker/pcmk_sched_promotable.c child->sort_index = node->weight; node 409 lib/pacemaker/pcmk_sched_promotable.c filter_anonymous_instance(pe_resource_t *rsc, const pe_node_t *node) node 420 lib/pacemaker/pcmk_sched_promotable.c pe_resource_t *active = parent->fns->find_rsc(child, key, node, pe_find_clone|pe_find_current); node 423 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "Found %s for %s active on %s: done", active->id, key, node->details->uname); node 427 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "Found %s for %s on %s: not %s", active->id, key, node->details->uname, rsc->id); node 431 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "%s on %s: not active", key, node->details->uname); node 449 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "Checking %s for %s on %s", rsc->id, key, node->details->uname); node 450 lib/pacemaker/pcmk_sched_promotable.c if (g_hash_table_lookup(rsc->known_on, node->details->id)) { node 461 lib/pacemaker/pcmk_sched_promotable.c lookup_promotion_score(pe_resource_t *rsc, const pe_node_t *node, const char *name) node 465 lib/pacemaker/pcmk_sched_promotable.c if (node && name) { node 468 lib/pacemaker/pcmk_sched_promotable.c attr_value = pe_node_attribute_calculated(node, attr_name, rsc); node 475 lib/pacemaker/pcmk_sched_promotable.c promotion_score(pe_resource_t *rsc, const pe_node_t *node, int not_set_value) node 482 lib/pacemaker/pcmk_sched_promotable.c CRM_CHECK(node != NULL, return not_set_value); node 489 lib/pacemaker/pcmk_sched_promotable.c int c_score = promotion_score(child, node, not_set_value); node 501 lib/pacemaker/pcmk_sched_promotable.c && filter_anonymous_instance(rsc, node)) { node 503 lib/pacemaker/pcmk_sched_promotable.c pe_rsc_trace(rsc, "Anonymous clone %s is allowed on %s", rsc->id, node->details->uname); node 512 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *known = pe_hash_table_lookup(rsc->known_on, node->details->id); node 514 lib/pacemaker/pcmk_sched_promotable.c match = pe_find_node_id(rsc->running_on, node->details->id); node 517 lib/pacemaker/pcmk_sched_promotable.c rsc->id, rsc->clone_name, node->details->uname); node 522 lib/pacemaker/pcmk_sched_promotable.c match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 539 lib/pacemaker/pcmk_sched_promotable.c attr_value = lookup_promotion_score(rsc, node, name); node 541 lib/pacemaker/pcmk_sched_promotable.c name, node->details->uname, crm_str(attr_value)); node 550 lib/pacemaker/pcmk_sched_promotable.c attr_value = lookup_promotion_score(rsc, node, name); node 552 lib/pacemaker/pcmk_sched_promotable.c name, node->details->uname, crm_str(attr_value)); node 582 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *node = NULL; node 586 lib/pacemaker/pcmk_sched_promotable.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 587 lib/pacemaker/pcmk_sched_promotable.c if (can_run_resources(node) == FALSE) { node 595 lib/pacemaker/pcmk_sched_promotable.c score = promotion_score(child_rsc, node, 0); node 597 lib/pacemaker/pcmk_sched_promotable.c new_score = pe__add_scores(node->weight, score); node 598 lib/pacemaker/pcmk_sched_promotable.c if (new_score != node->weight) { node 600 lib/pacemaker/pcmk_sched_promotable.c child_rsc->id, node->details->uname, node->weight, new_score); node 601 lib/pacemaker/pcmk_sched_promotable.c node->weight = new_score; node 669 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *node = NULL; node 680 lib/pacemaker/pcmk_sched_promotable.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 681 lib/pacemaker/pcmk_sched_promotable.c node->count = 0; node 960 lib/pacemaker/pcmk_sched_promotable.c pe_node_t *node = NULL; node 972 lib/pacemaker/pcmk_sched_promotable.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 973 lib/pacemaker/pcmk_sched_promotable.c const char *tmp = pe_node_attribute_raw(node, attr); node 976 lib/pacemaker/pcmk_sched_promotable.c crm_trace("%s: %d + %d", node->details->uname, node->weight, other->weight); node 977 lib/pacemaker/pcmk_sched_promotable.c node->weight = pe__add_scores(node->weight, score); node 105 lib/pacemaker/pcmk_sched_transition.c create_node_entry(cib_t * cib_conn, const char *node) node 108 lib/pacemaker/pcmk_sched_transition.c char *xpath = crm_strdup_printf(NEW_NODE_TEMPLATE, node); node 115 lib/pacemaker/pcmk_sched_transition.c crm_xml_add(cib_object, XML_ATTR_ID, node); // Use node name as ID node 116 lib/pacemaker/pcmk_sched_transition.c crm_xml_add(cib_object, XML_ATTR_UNAME, node); node 167 lib/pacemaker/pcmk_sched_transition.c inject_node_state(cib_t * cib_conn, const char *node, const char *uuid) node 171 lib/pacemaker/pcmk_sched_transition.c char *xpath = crm_strdup_printf(NODE_TEMPLATE, node); node 174 lib/pacemaker/pcmk_sched_transition.c create_node_entry(cib_conn, node); node 192 lib/pacemaker/pcmk_sched_transition.c query_node_uuid(cib_conn, node, &found_uuid, NULL); node 199 lib/pacemaker/pcmk_sched_transition.c crm_xml_add(cib_object, XML_ATTR_UNAME, node); node 207 lib/pacemaker/pcmk_sched_transition.c crm_trace("injecting node state for %s. rc is %d", node, rc); node 216 lib/pacemaker/pcmk_sched_transition.c modify_node(cib_t * cib_conn, char *node, gboolean up) node 218 lib/pacemaker/pcmk_sched_transition.c xmlNode *cib_node = inject_node_state(cib_conn, node, NULL); node 241 lib/pacemaker/pcmk_sched_transition.c const char *node = crm_element_value(cib_node, XML_ATTR_UNAME); node 242 lib/pacemaker/pcmk_sched_transition.c char *xpath = crm_strdup_printf(RSC_TEMPLATE, node, resource); node 440 lib/pacemaker/pcmk_sched_transition.c char *node = (char *)gIter->data; node 442 lib/pacemaker/pcmk_sched_transition.c quiet_log(" + Bringing node %s online\n", node); node 443 lib/pacemaker/pcmk_sched_transition.c cib_node = modify_node(cib, node, TRUE); node 454 lib/pacemaker/pcmk_sched_transition.c char *node = (char *)gIter->data; node 456 lib/pacemaker/pcmk_sched_transition.c quiet_log(" + Taking node %s offline\n", node); node 457 lib/pacemaker/pcmk_sched_transition.c cib_node = modify_node(cib, node, FALSE); node 465 lib/pacemaker/pcmk_sched_transition.c snprintf(xpath, STATUS_PATH_MAX, "//node_state[@uname='%s']/%s", node, XML_CIB_TAG_LRM); node 469 lib/pacemaker/pcmk_sched_transition.c snprintf(xpath, STATUS_PATH_MAX, "//node_state[@uname='%s']/%s", node, node 477 lib/pacemaker/pcmk_sched_transition.c char *node = (char *)gIter->data; node 479 lib/pacemaker/pcmk_sched_transition.c quiet_log(" + Failing node %s\n", node); node 480 lib/pacemaker/pcmk_sched_transition.c cib_node = modify_node(cib, node, TRUE); node 538 lib/pacemaker/pcmk_sched_transition.c char *node = NULL; node 551 lib/pacemaker/pcmk_sched_transition.c node = calloc(1, strlen(spec) + 1); node 552 lib/pacemaker/pcmk_sched_transition.c rc = sscanf(spec, "%[^@]@%[^=]=%d", key, node, &outcome); node 556 lib/pacemaker/pcmk_sched_transition.c free(node); node 570 lib/pacemaker/pcmk_sched_transition.c cib_node = inject_node_state(cib, node, NULL); node 591 lib/pacemaker/pcmk_sched_transition.c free(node); node 599 lib/pacemaker/pcmk_sched_transition.c const char *node = crm_element_value(action->xml, XML_LRM_ATTR_TARGET); node 604 lib/pacemaker/pcmk_sched_transition.c quiet_log(" * Pseudo action: %s%s%s\n", task, node ? " on " : "", node ? node : ""); node 629 lib/pacemaker/pcmk_sched_transition.c char *node = crm_element_value_copy(action->xml, XML_LRM_ATTR_TARGET); node 634 lib/pacemaker/pcmk_sched_transition.c crm_info("Skipping %s op for %s", operation, node); node 640 lib/pacemaker/pcmk_sched_transition.c free(node); free(uuid); node 660 lib/pacemaker/pcmk_sched_transition.c quiet_log(" * Resource action: %-15s %s on %s\n", resource, operation, node); node 675 lib/pacemaker/pcmk_sched_transition.c cib_node = inject_node_state(fake_cib, node, (router_node? node : uuid)); node 682 lib/pacemaker/pcmk_sched_transition.c free(node); free(uuid); node 690 lib/pacemaker/pcmk_sched_transition.c resource, op->op_type, op->interval_ms, node); node 692 lib/pacemaker/pcmk_sched_transition.c quiet_log(" * Resource action: %-15s %s on %s\n", resource, op->op_type, node); node 702 lib/pacemaker/pcmk_sched_transition.c op->interval_ms, node); node 710 lib/pacemaker/pcmk_sched_transition.c op->interval_ms, node); node 745 lib/pacemaker/pcmk_sched_transition.c free(node); free(uuid); node 755 lib/pacemaker/pcmk_sched_transition.c const char *node = crm_element_value(action->xml, XML_LRM_ATTR_TARGET); node 762 lib/pacemaker/pcmk_sched_transition.c quiet_log(" * Cluster action: %s for %s on %s\n", task, ID(rsc), node); node 764 lib/pacemaker/pcmk_sched_transition.c quiet_log(" * Cluster action: %s on %s\n", task, node); node 126 lib/pacemaker/pcmk_sched_utilization.c pe_node_t *node; node 139 lib/pacemaker/pcmk_sched_utilization.c remaining = crm_parse_int(g_hash_table_lookup(data->node->details->utilization, key), "0"); node 143 lib/pacemaker/pcmk_sched_utilization.c CRM_ASSERT(data->node); node 146 lib/pacemaker/pcmk_sched_utilization.c data->node->details->uname, (char *)key, data->rsc_id, required, remaining); node 152 lib/pacemaker/pcmk_sched_utilization.c have_enough_capacity(pe_node_t * node, const char * rsc_id, GHashTable * utilization) node 156 lib/pacemaker/pcmk_sched_utilization.c data.node = node; node 338 lib/pacemaker/pcmk_sched_utilization.c pe_node_t *node = NULL; node 350 lib/pacemaker/pcmk_sched_utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 351 lib/pacemaker/pcmk_sched_utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 355 lib/pacemaker/pcmk_sched_utilization.c if (have_enough_capacity(node, rscs_id, unallocated_utilization)) { node 360 lib/pacemaker/pcmk_sched_utilization.c compare_capacity(node, most_capable_node) < 0) { node 362 lib/pacemaker/pcmk_sched_utilization.c most_capable_node = node; node 368 lib/pacemaker/pcmk_sched_utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 369 lib/pacemaker/pcmk_sched_utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 373 lib/pacemaker/pcmk_sched_utilization.c if (have_enough_capacity(node, rscs_id, unallocated_utilization) == FALSE) { node 377 lib/pacemaker/pcmk_sched_utilization.c rsc->id, node->details->uname); node 378 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); node 396 lib/pacemaker/pcmk_sched_utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 397 lib/pacemaker/pcmk_sched_utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 401 lib/pacemaker/pcmk_sched_utilization.c if (have_enough_capacity(node, rsc->id, rsc->utilization) == FALSE) { node 405 lib/pacemaker/pcmk_sched_utilization.c rsc->id, node->details->uname); node 406 lib/pacemaker/pcmk_sched_utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); node 65 lib/pacemaker/pcmk_sched_utils.c can_run_resources(const pe_node_t * node) node 67 lib/pacemaker/pcmk_sched_utils.c if (node == NULL) { node 71 lib/pacemaker/pcmk_sched_utils.c if (node->weight < 0) { node 76 lib/pacemaker/pcmk_sched_utils.c if (node->details->online == FALSE node 77 lib/pacemaker/pcmk_sched_utils.c || node->details->shutdown || node->details->unclean node 78 lib/pacemaker/pcmk_sched_utils.c || node->details->standby || node->details->maintenance) { node 80 lib/pacemaker/pcmk_sched_utils.c node->details->uname, node->details->online, node 81 lib/pacemaker/pcmk_sched_utils.c node->details->unclean, node->details->standby, node->details->maintenance); node 100 lib/pacemaker/pcmk_sched_utils.c pe_node_t *node = NULL; node 107 lib/pacemaker/pcmk_sched_utils.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 108 lib/pacemaker/pcmk_sched_utils.c pe_node_t *new_node = pe__copy_node(node); node 368 lib/pacemaker/pcmk_sched_utils.c } else if (action->node != NULL) { node 369 lib/pacemaker/pcmk_sched_utils.c node_uname = action->node->details->uname; node 370 lib/pacemaker/pcmk_sched_utils.c node_uuid = action->node->details->id; node 454 lib/pacemaker/pcmk_sched_utils.c pe_node_t *node = NULL; node 461 lib/pacemaker/pcmk_sched_utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 462 lib/pacemaker/pcmk_sched_utils.c if (can_run_resources(node) && node->weight >= 0) { node 497 lib/pacemaker/pcmk_sched_utils.c pe_node_t *node, pe_working_set_t *data_set) node 505 lib/pacemaker/pcmk_sched_utils.c cancel_op = custom_action(rsc, key, RSC_CANCEL, node, FALSE, TRUE, node 531 lib/pacemaker/pcmk_sched_utils.c sched_shutdown_op(pe_node_t *node, pe_working_set_t *data_set) node 534 lib/pacemaker/pcmk_sched_utils.c node->details->uname); node 537 lib/pacemaker/pcmk_sched_utils.c node, FALSE, TRUE, data_set); node 539 lib/pacemaker/pcmk_sched_utils.c crm_notice("Scheduling shutdown of node %s", node->details->uname); node 540 lib/pacemaker/pcmk_sched_utils.c shutdown_constraints(node, shutdown_op, data_set); node 607 lib/pacemaker/pcmk_sched_utils.c const char *node, const char *origin, int level) node 700 lib/pacemaker/pcmk_sched_utils.c crm_xml_add(xml_op, XML_LRM_ATTR_TARGET, node); /* For context during triage */ node 708 lib/pengine/bundle.c pe_node_t *node = NULL; node 757 lib/pengine/bundle.c node = pe_find_node(data_set->nodes, uname); node 758 lib/pengine/bundle.c if (node == NULL) { node 759 lib/pengine/bundle.c node = pe_create_node(uname, uname, "remote", "-INFINITY", node 762 lib/pengine/bundle.c node->weight = -INFINITY; node 764 lib/pengine/bundle.c node->rsc_discover_mode = pe_discover_never; node 787 lib/pengine/bundle.c replica->node = pe__copy_node(node); node 788 lib/pengine/bundle.c replica->node->weight = 500; node 789 lib/pengine/bundle.c replica->node->rsc_discover_mode = pe_discover_exclusive; node 799 lib/pengine/bundle.c (gpointer) replica->node->details->id, node 800 lib/pengine/bundle.c pe__copy_node(replica->node)); node 803 lib/pengine/bundle.c pe_node_t *copy = pe__copy_node(replica->node); node 806 lib/pengine/bundle.c (gpointer) replica->node->details->id, copy); node 813 lib/pengine/bundle.c while (g_hash_table_iter_next(&gIter, NULL, (void **)&node)) { node 814 lib/pengine/bundle.c if (pe__is_guest_or_remote_node(node)) { node 816 lib/pengine/bundle.c node->weight = -INFINITY; node 820 lib/pengine/bundle.c replica->node->details->remote_rsc = replica->remote; node 828 lib/pengine/bundle.c g_hash_table_insert(replica->node->details->attrs, node 991 lib/pengine/bundle.c pe_node_t *node = NULL; node 1003 lib/pengine/bundle.c node = replica->container->allocated_to; node 1004 lib/pengine/bundle.c if (node == NULL) { node 1008 lib/pengine/bundle.c node = pe__current_node(replica->container); node 1011 lib/pengine/bundle.c if(node == NULL) { node 1017 lib/pengine/bundle.c rsc->id, node->details->uname); node 1019 lib/pengine/bundle.c crm_xml_add(xml, field, node->details->uname); node 1022 lib/pengine/bundle.c return node->details->uname; node 1417 lib/pengine/bundle.c pe__find_bundle_replica(const pe_resource_t *bundle, const pe_node_t *node) node 1420 lib/pengine/bundle.c CRM_ASSERT(bundle && node); node 1427 lib/pengine/bundle.c CRM_ASSERT(replica && replica->node); node 1428 lib/pengine/bundle.c if (replica->node->details == node->details) { node 1600 lib/pengine/bundle.c pe_node_t *node, long options) node 1623 lib/pengine/bundle.c pe__common_output_html(out, rsc, buffer, node, options); node 1742 lib/pengine/bundle.c pe_node_t *node, long options) node 1765 lib/pengine/bundle.c pe__common_output_text(out, rsc, buffer, node, options); node 1875 lib/pengine/bundle.c pe_node_t *node = NULL; node 1897 lib/pengine/bundle.c node = pe__current_node(replica->container); node 1898 lib/pengine/bundle.c common_print(rsc, pre_text, buffer, node, options, print_data); node 1976 lib/pengine/bundle.c if (replica->node) { node 1977 lib/pengine/bundle.c free(replica->node); node 1978 lib/pengine/bundle.c replica->node = NULL; node 559 lib/pengine/clone.c pe_node_t *node = (pe_node_t *)nIter->data; node 561 lib/pengine/clone.c if (pe_find_node(rsc->running_on, node->details->uname) == NULL) { node 563 lib/pengine/clone.c node->details->uname); node 852 lib/pengine/clone.c pe_node_t *node = (pe_node_t *)nIter->data; node 854 lib/pengine/clone.c if (pe_find_node(rsc->running_on, node->details->uname) == NULL && node 855 lib/pengine/clone.c pcmk__str_in_list(only_node, node->details->uname)) { node 857 lib/pengine/clone.c node->details->uname); node 1087 lib/pengine/clone.c pe_node_t *node = (pe_node_t *)nIter->data; node 1089 lib/pengine/clone.c if (pe_find_node(rsc->running_on, node->details->uname) == NULL && node 1090 lib/pengine/clone.c pcmk__str_in_list(only_node, node->details->uname)) { node 1092 lib/pengine/clone.c node->details->uname); node 590 lib/pengine/common.c pe_node_attribute_calculated(const pe_node_t *node, const char *name, node 595 lib/pengine/common.c if(node == NULL) { node 599 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 604 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 614 lib/pengine/common.c CRM_ASSERT(node->details->remote_rsc); node 615 lib/pengine/common.c CRM_ASSERT(node->details->remote_rsc->container); node 617 lib/pengine/common.c if(node->details->remote_rsc->container->running_on) { node 618 lib/pengine/common.c pe_node_t *host = node->details->remote_rsc->container->running_on->data; node 624 lib/pengine/common.c rsc->id, name, node->details->remote_rsc->container->id); node 629 lib/pengine/common.c pe_node_attribute_raw(pe_node_t *node, const char *name) node 631 lib/pengine/common.c if(node == NULL) { node 634 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 101 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) node 118 lib/pengine/complex.c if (node) { node 119 lib/pengine/complex.c rule_data.node_hash = node->details->attrs; node 148 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) node 159 lib/pengine/complex.c if (node) { node 160 lib/pengine/complex.c rule_data.node_hash = node->details->attrs; node 168 lib/pengine/complex.c get_rsc_attributes(meta_hash, rsc->parent, node, data_set); node 180 lib/pengine/complex.c pe_node_t * node, pe_working_set_t * data_set) node 183 lib/pengine/complex.c .node_hash = (node == NULL)? NULL : node->details->attrs, node 196 lib/pengine/complex.c pe_get_versioned_attributes(meta_hash, rsc->parent, node, data_set); node 762 lib/pengine/complex.c pe_node_t *node = NULL; node 764 lib/pengine/complex.c node = pe_hash_table_lookup(rsc->allowed_nodes, id); node 765 lib/pengine/complex.c if (node != NULL) { node 766 lib/pengine/complex.c pe_rsc_trace(rsc, "Updating score for %s on %s: %d + %d", rsc->id, id, node->weight, score); node 767 lib/pengine/complex.c node->weight = pe__add_scores(node->weight, score); node 899 lib/pengine/complex.c pe_node_t *node = NULL; node 916 lib/pengine/complex.c node = node_iter->data; node 919 lib/pengine/complex.c is_happy = node->details->online && !node->details->unclean; node 933 lib/pengine/complex.c if (node->details == rsc->partial_migration_source->details) { node 935 lib/pengine/complex.c active = node; node 943 lib/pengine/complex.c active = node; node 950 lib/pengine/complex.c active = node; node 80 lib/pengine/failcounts.c block_failure(pe_node_t *node, pe_resource_t *rsc, xmlNode *xml_op, node 131 lib/pengine/failcounts.c node->details->uname, xml_name, node 251 lib/pengine/failcounts.c pe_get_failcount(pe_node_t *node, pe_resource_t *rsc, time_t *last_failure, node 264 lib/pengine/failcounts.c g_hash_table_iter_init(&iter, node->details->attrs); node 282 lib/pengine/failcounts.c && block_failure(node, rsc, xml_op, data_set)) { node 297 lib/pengine/failcounts.c rsc->id, node->details->uname, rsc->failure_timeout); node 321 lib/pengine/failcounts.c failcount += pe_get_failcount(node, filler, &filler_last_failure, node 333 lib/pengine/failcounts.c rsc->id, score, node->details->uname); node 341 lib/pengine/failcounts.c rsc->id, score, node->details->uname); node 360 lib/pengine/failcounts.c pe__clear_failcount(pe_resource_t *rsc, pe_node_t *node, node 366 lib/pengine/failcounts.c CRM_CHECK(rsc && node && reason && data_set, return NULL); node 369 lib/pengine/failcounts.c clear = custom_action(rsc, key, CRM_OP_CLEAR_FAILCOUNT, node, FALSE, TRUE, node 373 lib/pengine/failcounts.c rsc->id, node->details->uname, reason, clear->uuid); node 38 lib/pengine/native.c native_priority_to_node(pe_resource_t * rsc, pe_node_t * node) node 54 lib/pengine/native.c node->details->priority += priority; node 56 lib/pengine/native.c node->details->uname, node->details->priority, node 63 lib/pengine/native.c if (node->details->remote_rsc node 64 lib/pengine/native.c && node->details->remote_rsc->container) { node 65 lib/pengine/native.c GListPtr gIter = node->details->remote_rsc->container->running_on; node 77 lib/pengine/native.c node->details->uname); node 83 lib/pengine/native.c native_add_running(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set) node 87 lib/pengine/native.c CRM_CHECK(node != NULL, return); node 92 lib/pengine/native.c if (pcmk__str_eq(a_node->details->id, node->details->id, pcmk__str_casei)) { node 97 lib/pengine/native.c pe_rsc_trace(rsc, "Adding %s to %s %s", rsc->id, node->details->uname, node 100 lib/pengine/native.c rsc->running_on = g_list_append(rsc->running_on, node); node 102 lib/pengine/native.c node->details->running_rsc = g_list_append(node->details->running_rsc, rsc); node 104 lib/pengine/native.c native_priority_to_node(rsc, node); node 107 lib/pengine/native.c if (rsc->variant == pe_native && node->details->maintenance) { node 115 lib/pengine/native.c resource_location(rsc, node, INFINITY, "not_managed_default", data_set); node 117 lib/pengine/native.c while(p && node->details->online) { node 119 lib/pengine/native.c p->running_on = g_list_append(p->running_on, node); node 167 lib/pengine/native.c rsc->id, node->details->uname, node 171 lib/pengine/native.c pe_rsc_trace(rsc, "Resource %s is active on: %s", rsc->id, node->details->uname); node 175 lib/pengine/native.c native_add_running(rsc->parent, node, data_set); node 234 lib/pengine/native.c rsc_is_on_node(pe_resource_t *rsc, const pe_node_t *node, int flags) node 237 lib/pengine/native.c rsc->id, node->details->uname); node 244 lib/pengine/native.c if (loc->details == node->details) { node 254 lib/pengine/native.c && (rsc->allocated_to->details == node->details)) { node 316 lib/pengine/native.c native_parameter(pe_resource_t * rsc, pe_node_t * node, gboolean create, const char *name, node 330 lib/pengine/native.c if (node != NULL) { node 331 lib/pengine/native.c pe_rsc_trace(rsc, "Creating hash with node %s", node->details->uname); node 338 lib/pengine/native.c get_rsc_attributes(local_hash, rsc, node, data_set); node 529 lib/pengine/native.c pe_node_t *node = (pe_node_t *) gIter->data; node 532 lib/pengine/native.c node->details->uname, node->details->id, node 533 lib/pengine/native.c pcmk__btoa(node->details->online == FALSE)); node 552 lib/pengine/native.c add_output_node(GString *s, const char *node, bool have_nodes) node 555 lib/pengine/native.c g_string_append(s, node); node 574 lib/pengine/native.c native_output_string(pe_resource_t *rsc, const char *name, pe_node_t *node, node 592 lib/pengine/native.c if ((node == NULL) && (rsc->lock_node != NULL)) { node 593 lib/pengine/native.c node = rsc->lock_node; node 597 lib/pengine/native.c node = NULL; node 603 lib/pengine/native.c + (node? strlen(node->details->uname) + 1 : 0) node 629 lib/pengine/native.c if (node) { node 630 lib/pengine/native.c g_string_append_printf(outstr, " %s", node->details->uname); node 634 lib/pengine/native.c if (node && !(node->details->online) && node->details->unclean) { node 637 lib/pengine/native.c if (node && (node == rsc->lock_node)) { node 718 lib/pengine/native.c const char *name, pe_node_t *node, long options) node 761 lib/pengine/native.c gchar *s = native_output_string(rsc, name, node, options, target_role, node 810 lib/pengine/native.c const char *name, pe_node_t *node, long options) node 829 lib/pengine/native.c gchar *s = native_output_string(rsc, name, node, options, target_role, node 876 lib/pengine/native.c common_print(pe_resource_t * rsc, const char *pre_text, const char *name, pe_node_t *node, long options, void *print_data) node 926 lib/pengine/native.c gchar *resource_s = native_output_string(rsc, name, node, options, node 1032 lib/pengine/native.c pe_node_t *node = NULL; node 1040 lib/pengine/native.c node = pe__current_node(rsc); node 1042 lib/pengine/native.c if (node == NULL) { node 1044 lib/pengine/native.c node = rsc->pending_node; node 1047 lib/pengine/native.c common_print(rsc, pre_text, rsc_printable_id(rsc), node, options, print_data); node 1115 lib/pengine/native.c pe_node_t *node = (pe_node_t *) gIter->data; node 1118 lib/pengine/native.c "name", node->details->uname, node 1119 lib/pengine/native.c "id", node->details->id, node 1120 lib/pengine/native.c "cached", pcmk__btoa(node->details->online)); node 1138 lib/pengine/native.c pe_node_t *node = pe__current_node(rsc); node 1146 lib/pengine/native.c if (node == NULL) { node 1148 lib/pengine/native.c node = rsc->pending_node; node 1150 lib/pengine/native.c return pe__common_output_html(out, rsc, rsc_printable_id(rsc), node, options); node 1162 lib/pengine/native.c pe_node_t *node = pe__current_node(rsc); node 1170 lib/pengine/native.c if (node == NULL) { node 1172 lib/pengine/native.c node = rsc->pending_node; node 1174 lib/pengine/native.c return pe__common_output_text(out, rsc, rsc_printable_id(rsc), node, options); node 1243 lib/pengine/native.c pe_node_t *node = (pe_node_t *) gIter->data; node 1245 lib/pengine/native.c if (*list == NULL || pe_find_node_id(*list, node->details->id) == NULL) { node 1246 lib/pengine/native.c *list = g_list_append(*list, node); node 1298 lib/pengine/native.c pe_node_t *node = (pe_node_t *) gIter2->data; node 1301 lib/pengine/native.c if (node->details->unclean == FALSE && node->details->online == FALSE) { node 1305 lib/pengine/native.c node_table = g_hash_table_lookup(active_table, node->details->uname); node 1308 lib/pengine/native.c g_hash_table_insert(active_table, strdup(node->details->uname), node_table); node 346 lib/pengine/pe_output.c pe__node_display_name(pe_node_t *node, bool print_detail) node 353 lib/pengine/pe_output.c CRM_ASSERT((node != NULL) && (node->details != NULL) && (node->details->uname != NULL)); node 356 lib/pengine/pe_output.c if (pe__is_guest_node(node)) { node 357 lib/pengine/pe_output.c pe_node_t *host_node = pe__current_node(node->details->remote_rsc); node 368 lib/pengine/pe_output.c if (print_detail && !pcmk__str_eq(node->details->uname, node->details->id, pcmk__str_casei)) { node 369 lib/pengine/pe_output.c node_id = node->details->id; node 373 lib/pengine/pe_output.c name_len = strlen(node->details->uname) + 1; node 384 lib/pengine/pe_output.c strcpy(node_name, node->details->uname); node 468 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "ban"); node 475 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) location->id); node 476 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "resource", (pcmkXmlStr) location->rsc_lh->id); node 477 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "node", (pcmkXmlStr) pe_node->details->uname); node 478 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "weight", (pcmkXmlStr) weight_s); node 479 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "master_only", node 615 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "li"); node 622 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, "bold", "Current DC: "); node 628 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, buf); node 633 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, buf); node 636 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, "warning", "WITHOUT"); node 637 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, "quorum"); node 640 lib/pengine/pe_output.c pcmk_create_html_node(node ,"span", NULL, "warning", "NONE"); node 668 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "current_dc"); node 676 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "present", (pcmkXmlStr) "true"); node 677 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "version", (pcmkXmlStr) (dc_version_s ? dc_version_s : "")); node 678 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "name", (pcmkXmlStr) dc->details->uname); node 679 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) dc->details->id); node 680 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "with_quorum", node 683 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "present", (pcmkXmlStr) "false"); node 744 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "li"); node 746 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, "Resource management: "); node 747 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, "bold", "DISABLED"); node 748 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, node 751 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "li"); node 753 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, "Resource management: "); node 754 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, "bold", "STOPPED"); node 755 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, node 820 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "cluster_options"); node 823 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "stonith-enabled", node 825 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "symmetric-cluster", node 830 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "no-quorum-policy", (pcmkXmlStr) "freeze"); node 834 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "no-quorum-policy", (pcmkXmlStr) "stop"); node 838 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "no-quorum-policy", (pcmkXmlStr) "demote"); node 842 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "no-quorum-policy", (pcmkXmlStr) "ignore"); node 846 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "no-quorum-policy", (pcmkXmlStr) "suicide"); node 850 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "maintenance-mode", node 852 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "stop-all-resources", node 861 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "li"); node 864 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, "bold", "Stack: "); node 865 lib/pengine/pe_output.c pcmk_create_html_node(node, "span", NULL, NULL, stack_s); node 881 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "stack"); node 884 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "type", (pcmkXmlStr) stack_s); node 975 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "failure"); node 977 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) (op_key ? "op_key" : "id"), node 979 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "node", node 981 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "exitstatus", node 983 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "exitreason", (pcmkXmlStr) reason_s); node 984 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "exitcode", (pcmkXmlStr) rc_s); node 985 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "call", node 987 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "status", node 1003 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) XML_RSC_OP_LAST_CHANGE, (pcmkXmlStr) rc_change); node 1004 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "queued", node 1006 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "exec", node 1008 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "interval", (pcmkXmlStr) s); node 1009 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "task", node 1026 lib/pengine/pe_output.c pe_node_t *node = va_arg(args, pe_node_t *); node 1036 lib/pengine/pe_output.c char *node_name = pe__node_display_name(node, print_clone_detail); node 1044 lib/pengine/pe_output.c if (node->details->standby_onfail && node->details->online) { node 1046 lib/pengine/pe_output.c } else if (node->details->standby && node->details->online) { node 1047 lib/pengine/pe_output.c char *s = crm_strdup_printf(" standby%s", node->details->running_rsc ? " (with active resources)" : ""); node 1050 lib/pengine/pe_output.c } else if (node->details->standby) { node 1052 lib/pengine/pe_output.c } else if (node->details->maintenance && node->details->online) { node 1054 lib/pengine/pe_output.c } else if (node->details->maintenance) { node 1056 lib/pengine/pe_output.c } else if (node->details->online) { node 1062 lib/pengine/pe_output.c GListPtr rscs = pe__filter_rsc_list(node->details->running_rsc, only_rsc); node 1074 lib/pengine/pe_output.c for (lpc2 = node->details->running_rsc; lpc2 != NULL; lpc2 = lpc2->next) { node 1094 lib/pengine/pe_output.c pe_node_t *node = va_arg(args, pe_node_t *); node 1105 lib/pengine/pe_output.c char *node_name = pe__node_display_name(node, print_clone_detail); node 1109 lib/pengine/pe_output.c if (pe__is_guest_node(node)) { node 1111 lib/pengine/pe_output.c } else if (pe__is_remote_node(node)) { node 1120 lib/pengine/pe_output.c GListPtr rscs = pe__filter_rsc_list(node->details->running_rsc, only_rsc); node 1138 lib/pengine/pe_output.c for (gIter2 = node->details->running_rsc; gIter2 != NULL; gIter2 = gIter2->next) { node 1154 lib/pengine/pe_output.c out->begin_list(out, NULL, NULL, "Node: %s", pe__node_display_name(node, print_clone_detail)); node 1164 lib/pengine/pe_output.c pe_node_t *node = va_arg(args, pe_node_t *); node 1176 lib/pengine/pe_output.c char *length_s = crm_itoa(g_list_length(node->details->running_rsc)); node 1178 lib/pengine/pe_output.c switch (node->details->type) { node 1190 lib/pengine/pe_output.c "name", node->details->uname, node 1191 lib/pengine/pe_output.c "id", node->details->id, node 1192 lib/pengine/pe_output.c "online", pcmk__btoa(node->details->online), node 1193 lib/pengine/pe_output.c "standby", pcmk__btoa(node->details->standby), node 1194 lib/pengine/pe_output.c "standby_onfail", pcmk__btoa(node->details->standby_onfail), node 1195 lib/pengine/pe_output.c "maintenance", pcmk__btoa(node->details->maintenance), node 1196 lib/pengine/pe_output.c "pending", pcmk__btoa(node->details->pending), node 1197 lib/pengine/pe_output.c "unclean", pcmk__btoa(node->details->unclean), node 1198 lib/pengine/pe_output.c "shutdown", pcmk__btoa(node->details->shutdown), node 1199 lib/pengine/pe_output.c "expected_up", pcmk__btoa(node->details->expected_up), node 1200 lib/pengine/pe_output.c "is_dc", pcmk__btoa(node->details->is_dc), node 1204 lib/pengine/pe_output.c if (pe__is_guest_node(node)) { node 1207 lib/pengine/pe_output.c (pcmkXmlStr) node->details->remote_rsc->container->id); node 1213 lib/pengine/pe_output.c for (lpc = node->details->running_rsc; lpc != NULL; lpc = lpc->next) { node 1225 lib/pengine/pe_output.c xmlSetProp(parent, (pcmkXmlStr) "name", (pcmkXmlStr) node->details->uname); node 1295 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "attribute"); node 1296 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "name", (pcmkXmlStr) name); node 1297 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "value", (pcmkXmlStr) value); node 1301 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "expected", (pcmkXmlStr) buf); node 1322 lib/pengine/pe_output.c pe_node_t *node = (pe_node_t *) gIter->data; node 1324 lib/pengine/pe_output.c if (!pcmk__str_in_list(only_node, node->details->uname)) { node 1330 lib/pengine/pe_output.c out->message(out, "node", node, print_opts, TRUE, NULL, print_clone_detail, node 1365 lib/pengine/pe_output.c pe_node_t *node = (pe_node_t *) gIter->data; node 1367 lib/pengine/pe_output.c char *node_name = pe__node_display_name(node, print_clone_detail); node 1369 lib/pengine/pe_output.c if (!pcmk__str_in_list(only_node, node->details->uname)) { node 1377 lib/pengine/pe_output.c if (node->details->unclean) { node 1378 lib/pengine/pe_output.c if (node->details->online) { node 1381 lib/pengine/pe_output.c } else if (node->details->pending) { node 1388 lib/pengine/pe_output.c } else if (node->details->pending) { node 1391 lib/pengine/pe_output.c } else if (node->details->standby_onfail && node->details->online) { node 1394 lib/pengine/pe_output.c } else if (node->details->standby) { node 1395 lib/pengine/pe_output.c if (node->details->online) { node 1396 lib/pengine/pe_output.c if (node->details->running_rsc) { node 1405 lib/pengine/pe_output.c } else if (node->details->maintenance) { node 1406 lib/pengine/pe_output.c if (node->details->online) { node 1412 lib/pengine/pe_output.c } else if (node->details->online) { node 1415 lib/pengine/pe_output.c if (pe__is_guest_node(node)) { node 1418 lib/pengine/pe_output.c } else if (pe__is_remote_node(node)) { node 1431 lib/pengine/pe_output.c if (pe__is_remote_node(node)) { node 1434 lib/pengine/pe_output.c } else if (pe__is_guest_node(node)) { node 1446 lib/pengine/pe_output.c out->message(out, "node", node, print_opts, TRUE, node_mode, print_clone_detail, node 1490 lib/pengine/pe_output.c pe_node_t *node = (pe_node_t *) gIter->data; node 1492 lib/pengine/pe_output.c if (!pcmk__str_in_list(only_node, node->details->uname)) { node 1496 lib/pengine/pe_output.c out->message(out, "node", node, print_opts, TRUE, NULL, print_clone_detail, node 1532 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_create_xml_node(out, "operation_history"); node 1534 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "call", node 1536 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "task", (pcmkXmlStr) task); node 1540 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "interval", (pcmkXmlStr) s); node 1551 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) XML_RSC_OP_LAST_CHANGE, node 1560 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) XML_RSC_OP_LAST_RUN, node 1568 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) XML_RSC_OP_T_EXEC, (pcmkXmlStr) s); node 1574 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) XML_RSC_OP_T_QUEUE, (pcmkXmlStr) s); node 1580 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "rc", (pcmkXmlStr) rc_s); node 1581 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "rc_text", (pcmkXmlStr) services_ocf_exitcode_str(rc)); node 1618 lib/pengine/pe_output.c xmlNodePtr node = pcmk__output_xml_create_parent(out, "resource_history"); node 1619 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) rsc_id); node 1622 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "orphan", (pcmkXmlStr) "true"); node 1626 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "orphan", (pcmkXmlStr) "false"); node 1627 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "migration-threshold", node 1634 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) PCMK__FAIL_COUNT_PREFIX, node 1640 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) PCMK__LAST_FAILURE_PREFIX, node 1797 lib/pengine/pe_output.c xmlNodePtr node = NULL; node 1801 lib/pengine/pe_output.c node = pcmk__output_create_xml_node(out, "ticket"); node 1802 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "id", (pcmkXmlStr) ticket->id); node 1803 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "status", (pcmkXmlStr) (ticket->granted ? "granted" : "revoked")); node 1804 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "standby", node 1808 lib/pengine/pe_output.c xmlSetProp(node, (pcmkXmlStr) "last-granted", node 1896 lib/pengine/pe_output.c pe__output_node(pe_node_t *node, gboolean details, pcmk__output_t *out) node 1898 lib/pengine/pe_output.c if (node == NULL) { node 1903 lib/pengine/pe_output.c CRM_ASSERT(node->details); node 1905 lib/pengine/pe_output.c node->details->online ? "" : "Unavailable/Unclean ", node 1906 lib/pengine/pe_output.c node->details->uname, node->weight, node->fixed ? "True" : "False"); node 1910 lib/pengine/pe_output.c GListPtr gIter = node->details->running_rsc; node 1916 lib/pengine/pe_output.c g_hash_table_foreach(node->details->attrs, print_str_str, pe_mutable); node 25 lib/pengine/remote.c pe__is_remote_node(const pe_node_t *node) node 27 lib/pengine/remote.c return (node != NULL) && (node->details->type == node_remote) node 28 lib/pengine/remote.c && ((node->details->remote_rsc == NULL) node 29 lib/pengine/remote.c || (node->details->remote_rsc->container == NULL)); node 33 lib/pengine/remote.c pe__is_guest_node(const pe_node_t *node) node 35 lib/pengine/remote.c return (node != NULL) && (node->details->type == node_remote) node 36 lib/pengine/remote.c && (node->details->remote_rsc != NULL) node 37 lib/pengine/remote.c && (node->details->remote_rsc->container != NULL); node 41 lib/pengine/remote.c pe__is_guest_or_remote_node(const pe_node_t *node) node 43 lib/pengine/remote.c return (node != NULL) && (node->details->type == node_remote); node 47 lib/pengine/remote.c pe__is_bundle_node(const pe_node_t *node) node 49 lib/pengine/remote.c return pe__is_guest_node(node) node 50 lib/pengine/remote.c && pe_rsc_is_bundled(node->details->remote_rsc); node 215 lib/pengine/remote.c pe_node_t *node; // Known node corresponding to history entry node 220 lib/pengine/remote.c pe__add_param_check(xmlNode *rsc_op, pe_resource_t *rsc, pe_node_t *node, node 225 lib/pengine/remote.c CRM_CHECK(data_set && rsc_op && rsc && node, return); node 233 lib/pengine/remote.c check_op->node = node; node 255 lib/pengine/remote.c cb(check_op->rsc, check_op->node, check_op->rsc_op, node 544 lib/pengine/rules.c xmlNode *node = expr; node 547 lib/pengine/rules.c free_xml(node); node 186 lib/pengine/status.c pe_node_t *node = (pe_node_t *) iterator->data; node 189 lib/pengine/status.c if (node == NULL) { node 192 lib/pengine/status.c if (node->details == NULL) { node 193 lib/pengine/status.c free(node); node 200 lib/pengine/status.c crm_trace("Freeing node %s", (pe__is_guest_or_remote_node(node)? node 201 lib/pengine/status.c "(guest or remote)" : node->details->uname)); node 203 lib/pengine/status.c if (node->details->attrs != NULL) { node 204 lib/pengine/status.c g_hash_table_destroy(node->details->attrs); node 206 lib/pengine/status.c if (node->details->utilization != NULL) { node 207 lib/pengine/status.c g_hash_table_destroy(node->details->utilization); node 209 lib/pengine/status.c if (node->details->digest_cache != NULL) { node 210 lib/pengine/status.c g_hash_table_destroy(node->details->digest_cache); node 212 lib/pengine/status.c g_list_free(node->details->running_rsc); node 213 lib/pengine/status.c g_list_free(node->details->allocated_rsc); node 214 lib/pengine/status.c free(node->details); node 215 lib/pengine/status.c free(node); node 424 lib/pengine/status.c pe_node_t *node = (pe_node_t *) gIter->data; node 426 lib/pengine/status.c if (node && pcmk__str_eq(node->details->id, id, pcmk__str_casei)) { node 427 lib/pengine/status.c return node; node 440 lib/pengine/status.c pe_node_t *node = (pe_node_t *) gIter->data; node 442 lib/pengine/status.c if (node && pcmk__str_eq(node->details->uname, uname, pcmk__str_casei)) { node 443 lib/pengine/status.c return node; node 68 lib/pengine/tags.c pe_node_t *node = pe_find_node_id(data_set->nodes, id); node 70 lib/pengine/tags.c if (!node) { node 75 lib/pengine/tags.c retval = g_list_append(retval, strdup(node->details->uname)); node 52 lib/pengine/unpack.c static void unpack_rsc_op(pe_resource_t *rsc, pe_node_t *node, xmlNode *xml_op, node 58 lib/pengine/unpack.c static void add_node_attrs(xmlNode *attrs, pe_node_t *node, bool overwrite, node 63 lib/pengine/unpack.c static void unpack_lrm_resources(pe_node_t *node, xmlNode *lrm_state, node 71 lib/pengine/unpack.c is_dangling_guest_node(pe_node_t *node) node 76 lib/pengine/unpack.c if (pe__is_guest_or_remote_node(node) && node 77 lib/pengine/unpack.c node->details->remote_rsc && node 78 lib/pengine/unpack.c node->details->remote_rsc->container == NULL && node 79 lib/pengine/unpack.c pcmk_is_set(node->details->remote_rsc->flags, node 97 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, node 100 lib/pengine/unpack.c CRM_CHECK(node, return); node 103 lib/pengine/unpack.c if (pe__is_guest_node(node)) { node 104 lib/pengine/unpack.c pe_resource_t *rsc = node->details->remote_rsc->container; node 111 lib/pengine/unpack.c node->details->uname, reason, rsc->id); node 115 lib/pengine/unpack.c node->details->uname, rsc->id, reason); node 121 lib/pengine/unpack.c node->details->remote_requires_reset = TRUE; node 126 lib/pengine/unpack.c } else if (is_dangling_guest_node(node)) { node 130 lib/pengine/unpack.c node->details->uname, reason); node 131 lib/pengine/unpack.c pe__set_resource_flags(node->details->remote_rsc, node 134 lib/pengine/unpack.c } else if (pe__is_remote_node(node)) { node 135 lib/pengine/unpack.c pe_resource_t *rsc = node->details->remote_rsc; node 140 lib/pengine/unpack.c node->details->uname, reason); node 141 lib/pengine/unpack.c } else if(node->details->remote_requires_reset == FALSE) { node 142 lib/pengine/unpack.c node->details->remote_requires_reset = TRUE; node 144 lib/pengine/unpack.c node->details->uname, node 145 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", node 148 lib/pengine/unpack.c node->details->unclean = TRUE; node 150 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, FALSE, data_set); node 152 lib/pengine/unpack.c } else if (node->details->unclean) { node 154 lib/pengine/unpack.c node->details->uname, node 155 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", node 160 lib/pengine/unpack.c node->details->uname, node 161 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", node 163 lib/pengine/unpack.c node->details->unclean = TRUE; node 164 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, priority_delay, data_set); node 1234 lib/pengine/unpack.c pe_node_t *node = pe__current_node(container); node 1236 lib/pengine/unpack.c if (node) { node 1237 lib/pengine/unpack.c stop_action(container, node, FALSE); node 1628 lib/pengine/unpack.c pe_node_t *node; node 1631 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); node 1632 lib/pengine/unpack.c if (node == NULL) { node 1633 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); node 1637 lib/pengine/unpack.c if (node) { node 1639 lib/pengine/unpack.c node->details->shutdown = TRUE; node 1659 lib/pengine/unpack.c pe_node_t *node, pe_working_set_t *data_set) node 1667 lib/pengine/unpack.c top->id, parent->id, rsc_id, node->details->uname); node 1686 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, pe_node_t * node, pe_resource_t * parent, node 1699 lib/pengine/unpack.c pe_rsc_trace(parent, "Looking for %s on %s in %s", rsc_id, node->details->uname, parent->id); node 1727 lib/pengine/unpack.c if (((pe_node_t *)locations->data)->details == node->details) { node 1747 lib/pengine/unpack.c parent->id, node->details->uname); node 1769 lib/pengine/unpack.c && (inactive_instance->pending_node->details != node->details)) { node 1794 lib/pengine/unpack.c && (!node->details->online || node->details->unclean) node 1795 lib/pengine/unpack.c && !pe__is_guest_node(node) node 1802 lib/pengine/unpack.c rsc = create_anonymous_orphan(parent, rsc_id, node, data_set); node 1809 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, pe_node_t * node, const char *rsc_id, node 1848 lib/pengine/unpack.c rsc = pe__find_bundle_replica(parent->parent, node); node 1852 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); node 1864 lib/pengine/unpack.c rsc_id, node->details->uname, rsc->id, node 1871 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, pe_node_t * node, pe_working_set_t * data_set) node 1876 lib/pengine/unpack.c crm_debug("Detected orphan resource %s on %s", rsc_id, node->details->uname); node 1891 lib/pengine/unpack.c process_rsc_state(pe_resource_t * rsc, pe_node_t * node, node 1900 lib/pengine/unpack.c rsc->id, role2text(rsc->role), node->details->uname, fail2text(on_fail)); node 1907 lib/pengine/unpack.c if (g_hash_table_lookup(iter->known_on, node->details->id) == NULL) { node 1908 lib/pengine/unpack.c pe_node_t *n = pe__copy_node(node); node 1923 lib/pengine/unpack.c && node->details->online == FALSE node 1924 lib/pengine/unpack.c && node->details->maintenance == FALSE node 1936 lib/pengine/unpack.c if (pe__is_guest_node(node)) { node 1941 lib/pengine/unpack.c if (pe__is_remote_node(node) && node->details->remote_rsc node 1942 lib/pengine/unpack.c && !pcmk_is_set(node->details->remote_rsc->flags, pe_rsc_failed)) { node 1950 lib/pengine/unpack.c node->details->unseen = TRUE; node 1963 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); node 1968 lib/pengine/unpack.c if (node->details->unclean) { node 1982 lib/pengine/unpack.c demote_action(rsc, node, FALSE); node 1990 lib/pengine/unpack.c pe_fence_node(data_set, node, reason, FALSE); node 1995 lib/pengine/unpack.c node->details->standby = TRUE; node 1996 lib/pengine/unpack.c node->details->standby_onfail = TRUE; node 2011 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); node 2021 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 2036 lib/pengine/unpack.c stop_action(rsc->container, node, FALSE); node 2038 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 2063 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 2089 lib/pengine/unpack.c rsc->id, node->details->uname); node 2094 lib/pengine/unpack.c rsc->id, node->details->uname); node 2098 lib/pengine/unpack.c native_add_running(rsc, node, data_set); node 2120 lib/pengine/unpack.c GList *possible_matches = pe__resource_actions(rsc, node, RSC_STOP, node 2136 lib/pengine/unpack.c process_recurring(pe_node_t * node, pe_resource_t * rsc, node 2157 lib/pengine/unpack.c if (node->details->online == FALSE) { node 2158 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: node is offline", rsc->id, node->details->uname); node 2163 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: resource is not active", id, node->details->uname); node 2167 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: old %d", id, node->details->uname, counter); node 2173 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: non-recurring", id, node->details->uname); node 2179 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: status", id, node->details->uname); node 2185 lib/pengine/unpack.c pe_rsc_trace(rsc, "Creating %s/%s", key, node->details->uname); node 2186 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); node 2240 lib/pengine/unpack.c unpack_shutdown_lock(xmlNode *rsc_entry, pe_resource_t *rsc, pe_node_t *node, node 2252 lib/pengine/unpack.c rsc->id, node->details->uname); node 2253 lib/pengine/unpack.c pe__clear_resource_history(rsc, node, data_set); node 2255 lib/pengine/unpack.c rsc->lock_node = node; node 2262 lib/pengine/unpack.c unpack_lrm_rsc_state(pe_node_t * node, xmlNode * rsc_entry, pe_working_set_t * data_set) node 2284 lib/pengine/unpack.c crm_element_name(rsc_entry), rsc_id, node->details->uname); node 2307 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, rsc_entry); node 2313 lib/pengine/unpack.c rsc = process_orphan_resource(rsc_entry, node, data_set); node 2320 lib/pengine/unpack.c unpack_shutdown_lock(rsc_entry, rsc, node, data_set); node 2336 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); node 2341 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); node 2346 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); node 2411 lib/pengine/unpack.c unpack_lrm_resources(pe_node_t *node, xmlNode *lrm_rsc_list, node 2421 lib/pengine/unpack.c pe_resource_t *rsc = unpack_lrm_rsc_state(node, rsc_entry, data_set); node 2454 lib/pengine/unpack.c pe_node_t *node = value; node 2457 lib/pengine/unpack.c node->weight = *score; node 2462 lib/pengine/unpack.c find_lrm_op(const char *resource, const char *op, const char *node, const char *source, node 2469 lib/pengine/unpack.c offset += snprintf(xpath + offset, STATUS_PATH_MAX - offset, "//node_state[@uname='%s']", node); node 2535 lib/pengine/unpack.c stop_happened_after(pe_resource_t *rsc, pe_node_t *node, xmlNode *xml_op, node 2539 lib/pengine/unpack.c node->details->uname, NULL, TRUE, data_set); node 2545 lib/pengine/unpack.c unpack_migrate_to_success(pe_resource_t *rsc, pe_node_t *node, xmlNode *xml_op, node 2574 lib/pengine/unpack.c CRM_CHECK(source && target && !strcmp(source, node->details->uname), return); node 2576 lib/pengine/unpack.c if (stop_happened_after(rsc, node, xml_op, data_set)) { node 2605 lib/pengine/unpack.c rsc->dangling_migrations = g_list_prepend(rsc->dangling_migrations, node); node 2650 lib/pengine/unpack.c unpack_migrate_to_failure(pe_resource_t *rsc, pe_node_t *node, xmlNode *xml_op, node 2661 lib/pengine/unpack.c CRM_CHECK(source && target && !strcmp(source, node->details->uname), return); node 2714 lib/pengine/unpack.c rsc->dangling_migrations = g_list_prepend(rsc->dangling_migrations, node); node 2719 lib/pengine/unpack.c unpack_migrate_from_failure(pe_resource_t *rsc, pe_node_t *node, node 2728 lib/pengine/unpack.c CRM_CHECK(source && target && !strcmp(target, node->details->uname), return); node 2758 lib/pengine/unpack.c record_failed_op(xmlNode *op, const pe_node_t *node, node 2764 lib/pengine/unpack.c if (node->details->online == FALSE) { node 2772 lib/pengine/unpack.c if(pcmk__str_eq(op_key, key, pcmk__str_casei) && pcmk__str_eq(uname, node->details->uname, pcmk__str_casei)) { node 2773 lib/pengine/unpack.c crm_trace("Skipping duplicate entry %s on %s", op_key, node->details->uname); node 2778 lib/pengine/unpack.c crm_trace("Adding entry %s on %s", op_key, node->details->uname); node 2779 lib/pengine/unpack.c crm_xml_add(op, XML_ATTR_UNAME, node->details->uname); node 2904 lib/pengine/unpack.c unpack_rsc_op_failure(pe_resource_t * rsc, pe_node_t * node, int rc, xmlNode * xml_op, xmlNode ** last_failure, node 2936 lib/pengine/unpack.c (is_probe? "probe" : task), rsc->id, node->details->uname, node 2943 lib/pengine/unpack.c (is_probe? "probe" : task), rsc->id, node->details->uname, node 2955 lib/pengine/unpack.c rsc->id, node->details->uname); node 2958 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 2969 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); node 2972 lib/pengine/unpack.c unpack_migrate_to_failure(rsc, node, xml_op, data_set); node 2975 lib/pengine/unpack.c unpack_migrate_from_failure(rsc, node, xml_op, data_set); node 3010 lib/pengine/unpack.c pcmk__btoa(node->details->unclean), node 3067 lib/pengine/unpack.c pe_resource_t *rsc, int rc, int target_rc, pe_node_t * node, xmlNode * xml_op, enum action_fail_response * on_fail, pe_working_set_t * data_set) node 3101 lib/pengine/unpack.c key, node->details->uname); node 3106 lib/pengine/unpack.c key, node->details->uname, node 3117 lib/pengine/unpack.c rsc->id, node->details->uname, node 3140 lib/pengine/unpack.c rsc->id, node->details->uname, node 3165 lib/pengine/unpack.c if (!pe_can_fence(data_set, node) node 3171 lib/pengine/unpack.c node->details->uname, services_ocf_exitcode_str(rc), node 3184 lib/pengine/unpack.c rc, task, rsc->id, node->details->uname, node 3196 lib/pengine/unpack.c pe_resource_t *rsc, pe_node_t *node, node 3206 lib/pengine/unpack.c pe__add_param_check(xml_op, rsc, node, pe_check_last_failure, node 3212 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); node 3217 lib/pengine/unpack.c rsc->id, get_op_key(xml_op), node->details->id); node 3309 lib/pengine/unpack.c check_operation_expiry(pe_resource_t *rsc, pe_node_t *node, int rc, node 3339 lib/pengine/unpack.c unexpired_fail_count = pe_get_failcount(node, rsc, &last_failure, node 3356 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, NULL, pe_fc_default, xml_op, data_set)) { node 3383 lib/pengine/unpack.c && should_clear_for_param_change(xml_op, task, rsc, node, data_set)) { node 3389 lib/pengine/unpack.c pe_action_t *clear_op = pe__clear_failcount(rsc, node, clear_reason, node 3449 lib/pengine/unpack.c update_resource_state(pe_resource_t * rsc, pe_node_t * node, xmlNode * xml_op, const char * task, int rc, node 3502 lib/pengine/unpack.c unpack_migrate_to_success(rsc, node, xml_op, data_set); node 3505 lib/pengine/unpack.c pe_rsc_trace(rsc, "%s active on %s", rsc->id, node->details->uname); node 3565 lib/pengine/unpack.c remap_monitor_rc(int rc, xmlNode *xml_op, const pe_node_t *node, node 3572 lib/pengine/unpack.c if (!node->details->shutdown || node->details->online) { node 3573 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 3580 lib/pengine/unpack.c unpack_rsc_op(pe_resource_t *rsc, pe_node_t *node, xmlNode *xml_op, node 3596 lib/pengine/unpack.c CRM_CHECK(rsc && node && xml_op, return); node 3626 lib/pengine/unpack.c task_key, task, task_id, status, rc, node->details->uname, role2text(rsc->role)); node 3628 lib/pengine/unpack.c if (node->details->unclean) { node 3631 lib/pengine/unpack.c node->details->uname, rsc->id); node 3647 lib/pengine/unpack.c && check_operation_expiry(rsc, node, rc, xml_op, data_set)) { node 3652 lib/pengine/unpack.c rc = remap_monitor_rc(rc, xml_op, node, rsc, data_set); node 3661 lib/pengine/unpack.c task_key, node->details->uname, rc, target_rc, magic); node 3664 lib/pengine/unpack.c } else if(node->details->online && node->details->unclean == FALSE) { node 3677 lib/pengine/unpack.c task_key, node->details->uname, rc, target_rc, magic); node 3689 lib/pengine/unpack.c status = determine_op_status(rsc, rc, target_rc, node, xml_op, on_fail, data_set); node 3698 lib/pengine/unpack.c ID(xml_op), task, rsc->id, node->details->uname, node 3710 lib/pengine/unpack.c } else if (!strcmp(task, CRMD_ACTION_MIGRATE) && node->details->unclean) { node 3723 lib/pengine/unpack.c rsc->pending_node = node; node 3732 lib/pengine/unpack.c rsc->pending_node = node; node 3740 lib/pengine/unpack.c task, rsc->id, node->details->uname, node 3742 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); node 3751 lib/pengine/unpack.c task, rsc->id, node->details->uname, status, rc, node 3756 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); node 3757 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); node 3761 lib/pengine/unpack.c if (pe__is_guest_or_remote_node(node) node 3762 lib/pengine/unpack.c && pcmk_is_set(node->details->remote_rsc->flags, pe_rsc_managed)) { node 3769 lib/pengine/unpack.c pe__set_resource_flags(node->details->remote_rsc, node 3791 lib/pengine/unpack.c node->details->uname, last_change_str(xml_op), rc, node 3794 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, target_rc, *last_failure, on_fail, data_set); node 3795 lib/pengine/unpack.c crm_xml_add(xml_op, XML_ATTR_UNAME, node->details->uname); node 3798 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 3806 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); node 3812 lib/pengine/unpack.c parent->id, node->details->uname, node 3816 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); node 3837 lib/pengine/unpack.c add_node_attrs(xmlNode *xml_obj, pe_node_t *node, bool overwrite, node 3851 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3852 lib/pengine/unpack.c strdup(CRM_ATTR_UNAME), strdup(node->details->uname)); node 3854 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, strdup(CRM_ATTR_ID), node 3855 lib/pengine/unpack.c strdup(node->details->id)); node 3856 lib/pengine/unpack.c if (pcmk__str_eq(node->details->id, data_set->dc_uuid, pcmk__str_casei)) { node 3857 lib/pengine/unpack.c data_set->dc_node = node; node 3858 lib/pengine/unpack.c node->details->is_dc = TRUE; node 3859 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3862 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3868 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, strdup(CRM_ATTR_CLUSTER_NAME), node 3873 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set); node 3875 lib/pengine/unpack.c if (pe_node_attribute_raw(node, CRM_ATTR_SITE_NAME) == NULL) { node 3876 lib/pengine/unpack.c const char *site_name = pe_node_attribute_raw(node, "site-name"); node 3879 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3885 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3893 lib/pengine/unpack.c extract_operations(const char *node, const char *rsc, xmlNode * rsc_entry, gboolean active_filter) node 3915 lib/pengine/unpack.c crm_xml_add(rsc_op, XML_ATTR_UNAME, node); node 3957 lib/pengine/unpack.c find_operations(const char *rsc, const char *node, gboolean active_filter, node 3976 lib/pengine/unpack.c if (node != NULL && !pcmk__str_eq(uname, node, pcmk__str_casei)) { node 87 lib/pengine/utils.c pe_can_fence(pe_working_set_t *data_set, pe_node_t *node) node 89 lib/pengine/utils.c if (pe__is_guest_node(node)) { node 93 lib/pengine/utils.c pe_resource_t *rsc = node->details->remote_rsc->container; node 117 lib/pengine/utils.c } else if(node == NULL) { node 120 lib/pengine/utils.c } else if(node->details->online) { node 121 lib/pengine/utils.c crm_notice("We can fence %s without quorum because they're in our membership", node->details->uname); node 125 lib/pengine/utils.c crm_trace("Cannot fence %s", node->details->uname); node 165 lib/pengine/utils.c pe_node_t *node = NULL; node 168 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 170 lib/pengine/utils.c other_node = pe_find_node_id(list, node->details->id); node 172 lib/pengine/utils.c node->weight = -INFINITY; node 174 lib/pengine/utils.c node->weight = pe__add_scores(node->weight, other_node->weight); node 179 lib/pengine/utils.c pe_node_t *node = (pe_node_t *) gIter->data; node 181 lib/pengine/utils.c other_node = pe_hash_table_lookup(result, node->details->id); node 184 lib/pengine/utils.c pe_node_t *new_node = pe__copy_node(node); node 239 lib/pengine/utils.c pe_node_t *node = (pe_node_t *) gIter->data; node 241 lib/pengine/utils.c score2char_stack(node->weight, score, sizeof(score)); node 244 lib/pengine/utils.c comment, rsc->id, node->details->uname, score); node 246 lib/pengine/utils.c printf("%s: %s = %s\n", comment, node->details->uname, score); node 268 lib/pengine/utils.c pe_node_t *node = NULL; node 275 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **) &node)) { node 276 lib/pengine/utils.c score2char_stack(node->weight, score, sizeof(score)); node 282 lib/pengine/utils.c node->details->uname, score); node 286 lib/pengine/utils.c comment, node->details->uname, node 350 lib/pengine/utils.c dump_node_capacity(int level, const char *comment, pe_node_t * node) node 353 lib/pengine/utils.c comment, node->details->uname); node 355 lib/pengine/utils.c g_hash_table_foreach(node->details->utilization, append_dump_text, &dump_text); node 367 lib/pengine/utils.c dump_rsc_utilization(int level, const char *comment, pe_resource_t * rsc, pe_node_t * node) node 370 lib/pengine/utils.c comment, rsc->id, node->details->uname); node 523 lib/pengine/utils.c action->node = pe__copy_node(on_node); node 578 lib/pengine/utils.c && action->node != NULL && action->op_entry != NULL) { node 580 lib/pengine/utils.c .node_hash = action->node->details->attrs, node 597 lib/pengine/utils.c } else if (action->node == NULL) { node 606 lib/pengine/utils.c action->uuid, action->node->details->uname, rsc->id); node 611 lib/pengine/utils.c && !(action->node->details->online) node 612 lib/pengine/utils.c && (!pe__is_guest_node(action->node) node 613 lib/pengine/utils.c || action->node->details->remote_requires_reset)) { node 617 lib/pengine/utils.c action->uuid, action->node->details->uname); node 620 lib/pengine/utils.c && action->node->details->unclean == FALSE) { node 621 lib/pengine/utils.c pe_fence_node(data_set, action->node, "resource actions are unrunnable", FALSE); node 625 lib/pengine/utils.c && action->node->details->pending) { node 629 lib/pengine/utils.c action->uuid, action->node->details->uname); node 633 lib/pengine/utils.c if (pe__is_guest_node(action->node) node 634 lib/pengine/utils.c && !pe_can_fence(data_set, action->node)) { node 642 lib/pengine/utils.c action->uuid, action->node->details->uname); node 646 lib/pengine/utils.c action->uuid, action->node->details->uname); node 660 lib/pengine/utils.c action->uuid, action->node->details->uname); node 667 lib/pengine/utils.c action->uuid, action->node->details->uname); node 1372 lib/pengine/utils.c print_node(const char *pre_text, pe_node_t * node, gboolean details) node 1374 lib/pengine/utils.c if (node == NULL) { node 1379 lib/pengine/utils.c CRM_ASSERT(node->details); node 1383 lib/pengine/utils.c node->details->online ? "" : "Unavailable/Unclean ", node 1384 lib/pengine/utils.c node->details->uname, node->weight, node->fixed ? "True" : "False"); node 1390 lib/pengine/utils.c GListPtr gIter = node->details->running_rsc; node 1393 lib/pengine/utils.c g_hash_table_foreach(node->details->attrs, print_str_str, pe_mutable); node 1441 lib/pengine/utils.c free(action->node); node 1468 lib/pengine/utils.c } else if (action->node == NULL) { node 1470 lib/pengine/utils.c } else if (action->node->details != not_on_node->details) { node 1521 lib/pengine/utils.c } else if (action->node == NULL) { node 1524 lib/pengine/utils.c } else if (on_node->details == action->node->details) { node 1551 lib/pengine/utils.c } else if (action->node == NULL) { node 1555 lib/pengine/utils.c action->node = pe__copy_node(on_node); node 1558 lib/pengine/utils.c } else if (on_node->details == action->node->details) { node 1564 lib/pengine/utils.c key, action->node->details->uname, node 1588 lib/pengine/utils.c if (action->node == NULL) { node 1595 lib/pengine/utils.c } else if (!pcmk__str_eq(on_node->details->id, action->node->details->id, pcmk__str_casei)) { node 1597 lib/pengine/utils.c key, on_node->details->id, action->node->details->id); node 1621 lib/pengine/utils.c pe__resource_actions(const pe_resource_t *rsc, const pe_node_t *node, node 1628 lib/pengine/utils.c result = find_actions_exact(rsc->actions, key, node); node 1630 lib/pengine/utils.c result = find_actions(rsc->actions, key, node); node 1637 lib/pengine/utils.c resource_node_score(pe_resource_t * rsc, pe_node_t * node, int score, const char *tag) node 1641 lib/pengine/utils.c if ((rsc->exclusive_discover || (node->rsc_discover_mode == pe_discover_never)) node 1655 lib/pengine/utils.c resource_node_score(child_rsc, node, score, tag); node 1659 lib/pengine/utils.c pe_rsc_trace(rsc, "Setting %s for %s on %s: %d", tag, rsc->id, node->details->uname, score); node 1660 lib/pengine/utils.c match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 1662 lib/pengine/utils.c match = pe__copy_node(node); node 1669 lib/pengine/utils.c resource_location(pe_resource_t * rsc, pe_node_t * node, int score, const char *tag, node 1672 lib/pengine/utils.c if (node != NULL) { node 1673 lib/pengine/utils.c resource_node_score(rsc, node, score, tag); node 1694 lib/pengine/utils.c if (node == NULL && score == -INFINITY) { node 2055 lib/pengine/utils.c pe_node_t *node, xmlNode *xml_op, bool calc_secure, node 2060 lib/pengine/utils.c data = g_hash_table_lookup(node->details->digest_cache, key); node 2063 lib/pengine/utils.c pe_action_t *action = custom_action(rsc, strdup(key), task, node, TRUE, FALSE, data_set); node 2076 lib/pengine/utils.c get_rsc_attributes(local_rsc_params, rsc, node, data_set); node 2078 lib/pengine/utils.c pe_get_versioned_attributes(local_versioned_params, rsc, node, data_set); node 2087 lib/pengine/utils.c rsc->id, node->details->uname); node 2141 lib/pengine/utils.c g_hash_table_insert(node->details->digest_cache, strdup(key), data); node 2148 lib/pengine/utils.c rsc_action_digest_cmp(pe_resource_t * rsc, xmlNode * xml_op, pe_node_t * node, node 2161 lib/pengine/utils.c CRM_ASSERT(node != NULL); node 2169 lib/pengine/utils.c data = rsc_action_digest(rsc, task, key, node, xml_op, node 2176 lib/pengine/utils.c key, node->details->uname, node 2187 lib/pengine/utils.c key, node->details->uname, node 2278 lib/pengine/utils.c pe_node_t *node, pe_working_set_t *data_set) node 2285 lib/pengine/utils.c node, NULL, TRUE, data_set); node 2290 lib/pengine/utils.c node_summary = pe_node_attribute_raw(node, CRM_ATTR_DIGESTS_ALL); node 2304 lib/pengine/utils.c node_summary = pe_node_attribute_raw(node, CRM_ATTR_DIGESTS_SECURE); node 2310 lib/pengine/utils.c rsc->id, node->details->uname); node 2323 lib/pengine/utils.c rsc->id, node->details->uname, digest); node 2376 lib/pengine/utils.c node_priority_fencing_delay(pe_node_t * node, pe_working_set_t * data_set) node 2391 lib/pengine/utils.c if (node->details->type != node_member) { node 2396 lib/pengine/utils.c if (node->details->online) { node 2435 lib/pengine/utils.c if (node->details->priority < top_priority) { node 2443 lib/pengine/utils.c pe_fence_op(pe_node_t * node, const char *op, bool optional, const char *reason, node 2453 lib/pengine/utils.c op_key = crm_strdup_printf("%s-%s-%s", CRM_OP_FENCE, node->details->uname, op); node 2460 lib/pengine/utils.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); node 2462 lib/pengine/utils.c add_hash_param(stonith_op->meta, XML_LRM_ATTR_TARGET, node->details->uname); node 2463 lib/pengine/utils.c add_hash_param(stonith_op->meta, XML_LRM_ATTR_TARGET_UUID, node->details->id); node 2466 lib/pengine/utils.c if (pe__is_guest_or_remote_node(node) node 2487 lib/pengine/utils.c data = fencing_action_digest_cmp(match, agent, node, data_set); node 2490 lib/pengine/utils.c crm_notice("Unfencing %s (remote): because the definition of %s changed", node->details->uname, match->id); node 2492 lib/pengine/utils.c fprintf(stdout, " notice: Unfencing %s (remote): because the definition of %s changed\n", node->details->uname, match->id); node 2532 lib/pengine/utils.c char *delay_s = crm_itoa(node_priority_fencing_delay(node, data_set)); node 2539 lib/pengine/utils.c if(optional == FALSE && pe_can_fence(data_set, node)) { node 2550 lib/pengine/utils.c pe_resource_t * rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t * data_set) node 2561 lib/pengine/utils.c } else if(node node 2562 lib/pengine/utils.c && node->details->online node 2563 lib/pengine/utils.c && node->details->unclean == FALSE node 2564 lib/pengine/utils.c && node->details->shutdown == FALSE) { node 2565 lib/pengine/utils.c pe_action_t *unfence = pe_fence_op(node, "on", FALSE, reason, FALSE, data_set); node 2575 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 2576 lib/pengine/utils.c if(node->details->online && node->details->unclean == FALSE && node->details->shutdown == FALSE) { node 2577 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); node 2712 lib/pengine/utils.c pe__shutdown_requested(pe_node_t *node) node 2714 lib/pengine/utils.c const char *shutdown = pe_node_attribute_raw(node, XML_CIB_ATTR_SHUTDOWN); node 2787 lib/pengine/utils.c pe__clear_resource_history(pe_resource_t *rsc, pe_node_t *node, node 2792 lib/pengine/utils.c CRM_ASSERT(rsc && node); node 2794 lib/pengine/utils.c return custom_action(rsc, key, CRM_OP_LRM_DELETE, node, FALSE, TRUE, node 2802 lib/pengine/utils.c pe_node_t *node = (pe_node_t *) ele->data; node 2803 lib/pengine/utils.c if (pcmk__str_in_list(node_list, node->details->uname)) { node 47 lib/pengine/variant.h pe_node_t *node; node 276 tools/crm_mon.c GSList *node = lst; node 284 tools/crm_mon.c while (node != NULL) { node 285 tools/crm_mon.c char *s = node->data; node 301 tools/crm_mon.c node = node->next; node 1478 tools/crm_mon.c pe_node_t *node = (pe_node_t *) gIter->data; node 1480 tools/crm_mon.c if (node->details->standby && node->details->online) { node 1482 tools/crm_mon.c } else if (node->details->maintenance && node->details->online) { node 1484 tools/crm_mon.c } else if (node->details->online) { node 1487 tools/crm_mon.c char *s = crm_strdup_printf("offline node: %s", node->details->uname); node 1581 tools/crm_mon.c send_custom_trap(const char *node, const char *rsc, const char *task, int target_rc, int rc, node 1599 tools/crm_mon.c setenv("CRM_notify_node", node, 1); node 1636 tools/crm_mon.c const char *node = NULL; node 1674 tools/crm_mon.c node = crm_element_value(rsc_op, XML_LRM_ATTR_TARGET); node 1680 tools/crm_mon.c if(node == NULL && n) { node 1681 tools/crm_mon.c node = crm_element_value(n, XML_ATTR_UNAME); node 1684 tools/crm_mon.c if (node == NULL && n) { node 1685 tools/crm_mon.c node = ID(n); node 1688 tools/crm_mon.c if (node == NULL) { node 1689 tools/crm_mon.c node = node_id; node 1692 tools/crm_mon.c if (node == NULL) { node 1700 tools/crm_mon.c crm_notice("%s of %s on %s completed: %s", task, rsc, node, desc); node 1707 tools/crm_mon.c crm_warn("%s of %s on %s failed: %s", task, rsc, node, desc); node 1711 tools/crm_mon.c crm_warn("%s of %s on %s failed: %s", task, rsc, node, desc); node 1715 tools/crm_mon.c send_custom_trap(node, rsc, task, target_rc, rc, status, desc); node 1760 tools/crm_mon.c const char *node = NULL; node 1800 tools/crm_mon.c node = crm_element_value(state, XML_ATTR_UNAME); node 1801 tools/crm_mon.c if (node == NULL) { node 1802 tools/crm_mon.c node = ID(state); node 1804 tools/crm_mon.c handle_rsc_op(state, node); node 1813 tools/crm_mon.c node = crm_element_value(state, XML_ATTR_UNAME); node 1814 tools/crm_mon.c if (node == NULL) { node 1815 tools/crm_mon.c node = ID(state); node 1817 tools/crm_mon.c handle_rsc_op(state, node); node 1821 tools/crm_mon.c node = crm_element_value(match, XML_ATTR_UNAME); node 1822 tools/crm_mon.c if (node == NULL) { node 1823 tools/crm_mon.c node = ID(match); node 1825 tools/crm_mon.c handle_rsc_op(match, node); node 1828 tools/crm_mon.c node = ID(match); node 1829 tools/crm_mon.c handle_rsc_op(match, node); node 229 tools/crm_mon_curses.c curses_list_data_t *node = NULL; node 232 tools/crm_mon_curses.c node = g_queue_pop_tail(priv->parent_q); node 234 tools/crm_mon_curses.c if (node->singular_noun != NULL && node->plural_noun != NULL) { node 235 tools/crm_mon_curses.c if (node->len == 1) { node 236 tools/crm_mon_curses.c curses_indented_printf(out, "%d %s found\n", node->len, node->singular_noun); node 238 tools/crm_mon_curses.c curses_indented_printf(out, "%d %s found\n", node->len, node->plural_noun); node 242 tools/crm_mon_curses.c free(node); node 36 tools/crm_mon_print.c pe_node_t *node, xmlNode *rsc_entry, unsigned int mon_ops, node 39 tools/crm_mon_print.c pe_node_t *node, xmlNode *node_state, gboolean operations, node 41 tools/crm_mon_print.c static gboolean add_extra_info(pcmk__output_t *out, pe_node_t * node, GListPtr rsc_list, node 69 tools/crm_mon_print.c pe_node_t *node = pe_find_node(data_set->nodes, s); node 71 tools/crm_mon_print.c if (node) { node 124 tools/crm_mon_print.c failure_count(pe_working_set_t *data_set, pe_node_t *node, pe_resource_t *rsc, time_t *last_failure) { node 125 tools/crm_mon_print.c return rsc ? pe_get_failcount(node, rsc, last_failure, pe_fc_default, node 175 tools/crm_mon_print.c print_rsc_history(pcmk__output_t *out, pe_working_set_t *data_set, pe_node_t *node, node 201 tools/crm_mon_print.c int failcount = failure_count(data_set, node, rsc, &last_failure); node 231 tools/crm_mon_print.c pe_node_t *node, xmlNode *node_state, gboolean operations, node 273 tools/crm_mon_print.c int failcount = failure_count(data_set, node, rsc, &last_failure); node 281 tools/crm_mon_print.c out->message(out, "node", node, get_resource_display_options(mon_ops), node 300 tools/crm_mon_print.c out->message(out, "node", node, get_resource_display_options(mon_ops), node 308 tools/crm_mon_print.c print_rsc_history(out, data_set, node, rsc_entry, mon_ops, op_list); node 332 tools/crm_mon_print.c add_extra_info(pcmk__output_t *out, pe_node_t *node, GListPtr rsc_list, node 343 tools/crm_mon_print.c if (add_extra_info(out, node, rsc->children, attrname, expected_score)) { node 383 tools/crm_mon_print.c pe_node_t *node; node 394 tools/crm_mon_print.c value = pe_node_attribute_raw(data->node, name); node 396 tools/crm_mon_print.c add_extra = add_extra_info(data->out, data->node, data->node->details->running_rsc, node 429 tools/crm_mon_print.c pe_node_t *node; node 435 tools/crm_mon_print.c node = pe_find_node_id(data_set->nodes, ID(node_state)); node 437 tools/crm_mon_print.c if (!node || !node->details || !node->details->online) { node 441 tools/crm_mon_print.c if (!pcmk__str_in_list(only_node, node->details->uname)) { node 447 tools/crm_mon_print.c print_node_history(out, data_set, node, node_state, operations, mon_ops, node 520 tools/crm_mon_print.c pe_node_t *node = (pe_node_t *) gIter2->data; node 522 tools/crm_mon_print.c if (node->weight < 0) { node 524 tools/crm_mon_print.c out->message(out, "ban", node, location, node 562 tools/crm_mon_print.c data.node = (pe_node_t *) gIter->data; node 564 tools/crm_mon_print.c if (data.node && data.node->details && data.node->details->online) { node 569 tools/crm_mon_print.c g_hash_table_iter_init(&iter, data.node->details->attrs); node 578 tools/crm_mon_print.c if (!pcmk__str_in_list(only_node, data.node->details->uname)) { node 584 tools/crm_mon_print.c out->message(out, "node", data.node, get_resource_display_options(mon_ops), node 231 tools/crm_node.c pcmk_controld_api_node_t *node = node_iter->data; node 232 tools/crm_node.c const char *uname = (node->uname? node->uname : ""); node 233 tools/crm_node.c const char *state = (node->state? node->state : ""); node 237 tools/crm_node.c (unsigned long) node->id, uname, state); node 332 tools/crm_node.c xmlNode *node = NULL; node 341 tools/crm_node.c node = create_xml_node(NULL, XML_CIB_TAG_NODE); node 344 tools/crm_node.c crm_xml_add(node, XML_ATTR_UNAME, name); node 347 tools/crm_node.c crm_xml_set_id(node, "%ld", id); node 348 tools/crm_node.c crm_xml_add(node_state, XML_ATTR_ID, ID(node)); node 354 tools/crm_node.c rc = cib->cmds->remove(cib, XML_CIB_TAG_NODES, node, cib_sync_call); node 1256 tools/crm_resource.c pe_node_t *node = pe_find_node(data_set->nodes, options.host_uname); node 1258 tools/crm_resource.c if (pe__is_guest_or_remote_node(node)) { node 1259 tools/crm_resource.c node = pe__current_node(node->details->remote_rsc); node 1260 tools/crm_resource.c if (node == NULL) { node 1267 tools/crm_resource.c router_node = node->details->uname; node 36 tools/crm_resource.h const char *rsc, const char *node, gboolean promoted_role_only); node 99 tools/crm_resource.h pe_node_t *node); node 330 tools/crm_resource_ban.c build_clear_xpath_string(xmlNode *constraint_node, const char *rsc, const char *node, gboolean promoted_role_only) node 352 tools/crm_resource_ban.c if (node != NULL || rsc != NULL || promoted_role_only == TRUE) { node 355 tools/crm_resource_ban.c if (node != NULL) { node 357 tools/crm_resource_ban.c offset += snprintf(first_half + offset, XPATH_MAX - offset, "@node='%s' and ", node); node 359 tools/crm_resource_ban.c offset += snprintf(first_half + offset, XPATH_MAX - offset, "@node='%s'", node); node 377 tools/crm_resource_ban.c if (node != NULL) { node 380 tools/crm_resource_ban.c first_half, rsc_role_substr, node, date_substr); node 383 tools/crm_resource_ban.c first_half, node, date_substr); node 399 tools/crm_resource_ban.c const char *rsc, const char *node, gboolean promoted_role_only) node 416 tools/crm_resource_ban.c xpath_string = build_clear_xpath_string(constraint_node, rsc, node, promoted_role_only); node 60 tools/crm_resource_print.c pe_node_t *node = pe__current_node(rsc); node 68 tools/crm_resource_print.c if (node != NULL) { node 69 tools/crm_resource_print.c host = node->details->uname; node 191 tools/crm_resource_print.c pe_node_t *node = (pe_node_t *) lpc2->data; node 192 tools/crm_resource_print.c char *score = score2char(node->weight); node 195 tools/crm_resource_print.c prefix ? prefix : " ", 71 - offset, node->details->uname, score, cons->id); node 22 tools/crm_resource_runtime.c pe_node_t *node = (pe_node_t *) lpc->data; node 25 tools/crm_resource_runtime.c fprintf(stdout, "%s\n", node->details->uname); node 32 tools/crm_resource_runtime.c fprintf(stdout, "resource %s is running on: %s %s\n", rsc, node->details->uname, state); node 509 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, host_uname); node 511 tools/crm_resource_runtime.c if (node == NULL) { node 516 tools/crm_resource_runtime.c if (!(node->details->online)) { node 524 tools/crm_resource_runtime.c if (!cib_only && pe__is_guest_or_remote_node(node)) { node 525 tools/crm_resource_runtime.c node = pe__current_node(node->details->remote_rsc); node 526 tools/crm_resource_runtime.c if (node == NULL) { node 531 tools/crm_resource_runtime.c router_node = node->details->uname; node 682 tools/crm_resource_runtime.c const char *interval_spec, pe_node_t *node) node 688 tools/crm_resource_runtime.c if (pe__is_guest_or_remote_node(node)) { node 691 tools/crm_resource_runtime.c rc = pcmk__node_attr_request_clear(NULL, node->details->uname, rsc_name, node 706 tools/crm_resource_runtime.c pe_node_t *node = NULL; node 735 tools/crm_resource_runtime.c pe_node_t *node = NULL; node 738 tools/crm_resource_runtime.c while (g_hash_table_iter_next(&iter, NULL, (void**)&node)) { node 739 tools/crm_resource_runtime.c if(node->weight >= 0) { node 740 tools/crm_resource_runtime.c nodes = g_list_prepend(nodes, node); node 749 tools/crm_resource_runtime.c node = (pe_node_t *) lpc->data; node 751 tools/crm_resource_runtime.c if (node->details->online) { node 752 tools/crm_resource_runtime.c rc = cli_resource_delete(controld_api, node->details->uname, node 766 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); node 768 tools/crm_resource_runtime.c if (node == NULL) { node 774 tools/crm_resource_runtime.c if (!node->details->rsc_discovery_enabled) { node 786 tools/crm_resource_runtime.c rc = clear_rsc_fail_attrs(rsc, operation, interval_spec, node); node 825 tools/crm_resource_runtime.c pe_node_t *node = pe_find_node(data_set->nodes, node_name); node 827 tools/crm_resource_runtime.c if (node == NULL) { node 831 tools/crm_resource_runtime.c if (pe__is_guest_or_remote_node(node)) { node 854 tools/crm_resource_runtime.c pe_node_t *node = (pe_node_t *) iter->data; node 856 tools/crm_resource_runtime.c rc = clear_rsc_failures(controld_api, node->details->uname, NULL, node 989 tools/crm_resource_runtime.c pe_node_t *node = (pe_node_t *) hIter->data; node 991 tools/crm_resource_runtime.c if(strcmp(host, node->details->uname) == 0) { node 994 tools/crm_resource_runtime.c } else if(strcmp(host, node->details->id) == 0) { node 1584 tools/crm_resource_runtime.c if (a->node) { node 1585 tools/crm_resource_runtime.c fprintf(stderr, "\ton %s", a->node->details->uname); node 2037 tools/crm_resource_runtime.c cli_resource_why_without_rsc_with_host(cib_t *cib_conn,GListPtr resources,pe_node_t *node) node 2039 tools/crm_resource_runtime.c const char* host_uname = node->details->uname; node 2040 tools/crm_resource_runtime.c GListPtr allResources = node->details->allocated_rsc; node 2041 tools/crm_resource_runtime.c GListPtr activeResources = node->details->running_rsc; node 2076 tools/crm_resource_runtime.c pe_node_t *node) node 2078 tools/crm_resource_runtime.c const char *host_uname = (node == NULL)? NULL : node->details->uname; node 2088 tools/crm_resource_runtime.c cli_resource_why_without_rsc_with_host(cib_conn, resources, node); node 404 tools/crm_simulate.c pe_node_t *node = (pe_node_t *) gIter->data; node 408 tools/crm_simulate.c if (pe__is_guest_node(node)) { node 409 tools/crm_simulate.c node_name = crm_strdup_printf("%s:%s", node->details->uname, node->details->remote_rsc->container->id); node 411 tools/crm_simulate.c node_name = crm_strdup_printf("%s", node->details->uname); node 414 tools/crm_simulate.c if (node->details->unclean) { node 415 tools/crm_simulate.c if (node->details->online && node->details->unclean) { node 418 tools/crm_simulate.c } else if (node->details->pending) { node 425 tools/crm_simulate.c } else if (node->details->pending) { node 428 tools/crm_simulate.c } else if (node->details->standby_onfail && node->details->online) { node 431 tools/crm_simulate.c } else if (node->details->standby) { node 432 tools/crm_simulate.c if (node->details->online) { node 438 tools/crm_simulate.c } else if (node->details->maintenance) { node 439 tools/crm_simulate.c if (node->details->online) { node 445 tools/crm_simulate.c } else if (node->details->online) { node 446 tools/crm_simulate.c if (pe__is_guest_node(node)) { node 449 tools/crm_simulate.c } else if (pe__is_remote_node(node)) { node 459 tools/crm_simulate.c if (pe__is_remote_node(node)) { node 462 tools/crm_simulate.c } else if (pe__is_guest_node(node)) { node 471 tools/crm_simulate.c if (pe__is_guest_node(node)) { node 473 tools/crm_simulate.c } else if (pe__is_remote_node(node)) { node 475 tools/crm_simulate.c } else if (pcmk__str_eq(node->details->uname, node->details->id, pcmk__str_casei)) { node 478 tools/crm_simulate.c printf("Node %s (%s): %s\n", node_name, node->details->id, node_mode); node 527 tools/crm_simulate.c if (action->node) { node 528 tools/crm_simulate.c action_host = action->node->details->uname; node 591 tools/crmadmin.c xmlNode *node = NULL; node 594 tools/crmadmin.c for (node = first_named_child(nodes, XML_CIB_TAG_NODE); node != NULL; node 595 tools/crmadmin.c node = crm_next_same_xml(node)) { node 599 tools/crmadmin.c crm_element_value(node, XML_ATTR_UNAME), node 600 tools/crmadmin.c crm_element_value(node, XML_ATTR_ID)); node 602 tools/crmadmin.c const char *node_type = crm_element_value(node, XML_ATTR_TYPE); node 608 tools/crmadmin.c crm_element_value(node, XML_ATTR_UNAME), node 609 tools/crmadmin.c crm_element_value(node, XML_ATTR_ID));