node 65 attrd/attrd_common.h int attrd_send_attribute_alert(const char *node, int nodeid, node 149 attrd/attrd_common_alerts.c attrd_send_attribute_alert(const char *node, int nodeid, node 156 attrd/attrd_common_alerts.c node, nodeid, attr, value); node 63 attrd/commands.c send_attrd_message(crm_node_t * node, xmlNode * data) node 70 attrd/commands.c return send_cluster_message(node, crm_msg_attrd, data, TRUE); node 1484 cib/callbacks.c cib_client_status_callback(const char *node, const char *client, const char *status, void *private) node 1490 cib/callbacks.c peer = crm_get_peer(0, node); node 1494 cib/callbacks.c node, client, status); node 1498 cib/callbacks.c crm_info("Status update: Client %s/%s now has status [%s]", node, client, status); node 71 cib/callbacks.h extern void cib_client_status_callback(const char *node, const char *client, node 416 cib/main.c cib_peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 422 cib/main.c && is_not_set(node->processes, crm_get_cluster_proc())) { node 426 cib/main.c if ((node->processes ^ old) & crm_proc_cpg) { node 428 cib/main.c node->uname); node 105 crmd/callbacks.c peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 110 crmd/callbacks.c bool is_remote = is_set(node->flags, crm_remote_node); node 121 crmd/callbacks.c if (node->uname == NULL) { node 130 crmd/callbacks.c node->uname, state_text(node->state)); node 138 crmd/callbacks.c CRM_CHECK(safe_str_neq(data, node->state), return); node 142 crmd/callbacks.c node->uname, state_text(node->state), state_text(data)); node 144 crmd/callbacks.c if (safe_str_eq(CRM_NODE_MEMBER, node->state)) { node 147 crmd/callbacks.c remove_stonith_cleanup(node->uname); node 151 crmd/callbacks.c crmd_alert_node_event(node); node 157 crmd/callbacks.c changed = node->processes ^ old; node 160 crmd/callbacks.c status = (node->processes & proc_flags) ? ONLINESTATUS : OFFLINESTATUS; node 162 crmd/callbacks.c node->uname, peer2text(proc_flags), status, node 167 crmd/callbacks.c crm_trace("No change %6x %6x %6x", old, node->processes, proc_flags); node 177 crmd/callbacks.c appeared = (node->processes & proc_flags) != 0; node 178 crmd/callbacks.c if (safe_str_eq(node->uname, fsa_our_uname) && (node->processes & proc_flags) == 0) { node 183 crmd/callbacks.c } else if (safe_str_eq(node->uname, fsa_our_dc) && crm_is_peer_active(node) == FALSE) { node 197 crmd/callbacks.c erase_status_tag(node->uname, XML_TAG_TRANSIENT_NODEATTRS, cib_scope_local); node 201 crmd/callbacks.c crm_info("Peer %s left us", node->uname); node 202 crmd/callbacks.c erase_status_tag(node->uname, XML_TAG_TRANSIENT_NODEATTRS, cib_scope_local); node 210 crmd/callbacks.c gboolean alive = is_remote? appeared : crm_is_peer_active(node); node 211 crmd/callbacks.c crm_action_t *down = match_down_event(node->uuid, appeared); node 227 crmd/callbacks.c (down->confirmed? "after" : "before"), node->uname); node 231 crmd/callbacks.c task, node->uname, down->id); node 238 crmd/callbacks.c crmd_peer_down(node, FALSE); node 247 crmd/callbacks.c node->uname, (alive? "" : "not "), task, down->id); node 251 crmd/callbacks.c crm_notice("Stonith/shutdown of %s not matched", node->uname); node 254 crmd/callbacks.c crm_update_peer_join(__FUNCTION__, node, crm_join_none); node 259 crmd/callbacks.c fail_incompletable_actions(transition_graph, node->uuid); node 263 crmd/callbacks.c node->uname); node 280 crmd/callbacks.c update = create_node_state_update(node, flags, NULL, __FUNCTION__); node 26 crmd/crmd_alerts.h void crmd_alert_node_event(crm_node_t *node); node 28 crmd/crmd_alerts.h void crmd_alert_resource_op(const char *node, lrmd_event_data_t *op); node 30 crmd/crmd_callbacks.h extern void crmd_ha_status_callback(const char *node, const char *status, void *private_data); node 32 crmd/crmd_callbacks.h extern void crmd_client_status_callback(const char *node, const char *client, const char *status, node 41 crmd/crmd_callbacks.h extern void peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data); node 88 crmd/crmd_utils.h void crm_update_peer_join(const char *source, crm_node_t * node, enum crm_join_phase phase); node 89 crmd/crmd_utils.h xmlNode *create_node_state_update(crm_node_t *node, int flags, node 246 crmd/election.c crm_node_t *node = crm_get_peer(0, fsa_our_uname); node 248 crmd/election.c crm_update_peer_expected(__FUNCTION__, node, CRMD_JOINSTATE_DOWN); node 249 crmd/election.c update = create_node_state_update(node, node_update_expected, NULL, node 383 crmd/heartbeat.c crmd_ha_status_callback(const char *node, const char *status, void *private) node 388 crmd/heartbeat.c crm_notice("Status update: Node %s now has status [%s]", node, status); node 390 crmd/heartbeat.c peer = crm_get_peer(0, node); node 415 crmd/heartbeat.c crmd_client_status_callback(const char *node, const char *client, const char *status, void *private) node 424 crmd/heartbeat.c peer = crm_get_peer(0, node); node 429 crmd/heartbeat.c node, client, status, AM_I_DC ? "true" : "false"); node 436 crmd/heartbeat.c node, client, status, AM_I_DC ? "true" : "false"); node 449 crmd/heartbeat.c crm_trace("Uncaching UUID for %s", node); node 43 crmd/join_dc.c crm_update_peer_join(const char *source, crm_node_t * node, enum crm_join_phase phase) node 47 crmd/join_dc.c if(node == NULL) { node 55 crmd/join_dc.c if (is_set(node->flags, crm_remote_node)) { node 59 crmd/join_dc.c last = node->join; node 63 crmd/join_dc.c source, node->uname, node->id, current_join_id, node 67 crmd/join_dc.c node->join = phase; node 69 crmd/join_dc.c source, node->uname, node->id, current_join_id, node 75 crmd/join_dc.c node->uname, current_join_id, source, node->id, node 738 crmd/lrm_state.c crmd_alert_node_event(crm_node_t *node) node 752 crmd/lrm_state.c node->uname, node->id, node->state); node 782 crmd/lrm_state.c crmd_alert_resource_op(const char *node, lrmd_event_data_t * op) node 795 crmd/lrm_state.c lrmd_send_resource_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, node, node 49 crmd/membership.c crm_node_t *node = value; node 51 crmd/membership.c if (crm_is_peer_active(node) == FALSE) { node 52 crmd/membership.c crm_update_peer_join(__FUNCTION__, node, crm_join_none); node 54 crmd/membership.c if(node && node->uname) { node 55 crmd/membership.c election_remove(fsa_election, node->uname); node 57 crmd/membership.c if (safe_str_eq(fsa_our_uname, node->uname)) { node 61 crmd/membership.c } else if (AM_I_DC == FALSE && safe_str_eq(node->uname, fsa_our_dc)) { node 62 crmd/membership.c crm_warn("Our DC node (%s) left the cluster", node->uname); node 70 crmd/membership.c if(node && node->uuid) { node 71 crmd/membership.c fail_incompletable_actions(transition_graph, node->uuid); node 143 crmd/membership.c create_node_state_update(crm_node_t *node, int flags, xmlNode *parent, node 149 crmd/membership.c if (!node->state) { node 150 crmd/membership.c crm_info("Node update for %s cancelled: no state, not seen yet", node->uname); node 156 crmd/membership.c if (is_set(node->flags, crm_remote_node)) { node 160 crmd/membership.c set_uuid(node_state, XML_ATTR_UUID, node); node 163 crmd/membership.c crm_info("Node update for %s cancelled: no id", node->uname); node 168 crmd/membership.c crm_xml_add(node_state, XML_ATTR_UNAME, node->uname); node 170 crmd/membership.c if ((flags & node_update_cluster) && node->state) { node 172 crmd/membership.c safe_str_eq(node->state, CRM_NODE_MEMBER)); node 175 crmd/membership.c if (!is_set(node->flags, crm_remote_node)) { node 178 crmd/membership.c if (node->processes & proc_flags) { node 185 crmd/membership.c if (node->join <= crm_join_none) { node 194 crmd/membership.c crm_xml_add(node_state, XML_NODE_EXPECTED, node->expected); node 243 crmd/membership.c crm_node_t *node = NULL; node 258 crmd/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 259 crmd/membership.c if (node->uuid node 260 crmd/membership.c && safe_str_eq(node->uuid, node_uuid) node 261 crmd/membership.c && node->uname node 262 crmd/membership.c && safe_str_eq(node->uname, node_uname)) { node 337 crmd/membership.c crm_node_t *node = NULL; node 340 crmd/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 343 crmd/membership.c crm_trace("Creating node entry for %s/%s", node->uname, node->uuid); node 344 crmd/membership.c if(node->uuid && node->uname) { node 349 crmd/membership.c crm_xml_add(new_node, XML_ATTR_ID, node->uuid); node 350 crmd/membership.c crm_xml_add(new_node, XML_ATTR_UNAME, node->uname); node 356 crmd/membership.c node->uname, node->uuid); node 360 crmd/membership.c fsa_register_cib_callback(call_id, FALSE, strdup(node->uuid), node 379 crmd/membership.c crm_node_t *node = NULL; node 384 crmd/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 385 crmd/membership.c create_node_state_update(node, flags, node_list, source); node 390 crmd/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 391 crmd/membership.c create_node_state_update(node, flags, node_list, source); node 702 crmd/messages.c crm_node_t *node = crm_find_peer(0, from); node 704 crmd/messages.c crm_update_peer_expected(__FUNCTION__, node, CRMD_JOINSTATE_DOWN); node 182 crmd/remote_lrmd_ra.c crm_node_t *node; node 199 crmd/remote_lrmd_ra.c node = crm_remote_peer_get(node_name); node 200 crmd/remote_lrmd_ra.c CRM_CHECK(node != NULL, return); node 201 crmd/remote_lrmd_ra.c crm_update_peer_state(__FUNCTION__, node, CRM_NODE_MEMBER, 0); node 212 crmd/remote_lrmd_ra.c state = create_node_state_update(node, node_update_cluster, update, node 253 crmd/remote_lrmd_ra.c crm_node_t *node; node 270 crmd/remote_lrmd_ra.c node = crm_remote_peer_get(node_name); node 271 crmd/remote_lrmd_ra.c CRM_CHECK(node != NULL, return); node 272 crmd/remote_lrmd_ra.c crm_update_peer_state(__FUNCTION__, node, CRM_NODE_LOST, 0); node 279 crmd/remote_lrmd_ra.c create_node_state_update(node, node_update_cluster, update, __FUNCTION__); node 312 crmd/remote_lrmd_ra.c crm_node_t *node = crm_remote_peer_get(cmd->rsc_id); node 314 crmd/remote_lrmd_ra.c CRM_CHECK(node != NULL, return); node 315 crmd/remote_lrmd_ra.c crm_update_peer_state(__FUNCTION__, node, CRM_NODE_MEMBER, 0); node 1198 crmd/remote_lrmd_ra.c crm_node_t *node; node 1201 crmd/remote_lrmd_ra.c node = crm_remote_peer_get(lrm_state->node_name); node 1202 crmd/remote_lrmd_ra.c CRM_CHECK(node != NULL, return); node 1204 crmd/remote_lrmd_ra.c state = create_node_state_update(node, node_update_none, update, node 1234 crmd/remote_lrmd_ra.c xmlNode *node; node 1237 crmd/remote_lrmd_ra.c for (node = node 1239 crmd/remote_lrmd_ra.c node; node = __xml_next(node)) { node 1240 crmd/remote_lrmd_ra.c lrm_state_t *lrm_state = lrm_state_find(ID(node)); node 1247 crmd/remote_lrmd_ra.c crm_atoi(crm_element_value(node, node 61 crmd/te_actions.c crm_node_t *node = NULL; node 64 crmd/te_actions.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 67 crmd/te_actions.c if (safe_str_eq(fsa_our_uname, node->uname)) { node 71 crmd/te_actions.c cmd = create_request(task, pseudo->xml, node->uname, node 73 crmd/te_actions.c send_cluster_message(node, crm_msg_crmd, cmd, FALSE); node 48 crmd/te_callbacks.c xmlNode *node = rsc_op; node 50 crmd/te_callbacks.c while (node != NULL && safe_str_neq(XML_CIB_TAG_STATE, TYPE(node))) { node 51 crmd/te_callbacks.c node = node->parent; node 54 crmd/te_callbacks.c CRM_CHECK(node != NULL, return NULL); node 55 crmd/te_callbacks.c return ID(node); node 190 crmd/te_callbacks.c const char *node = get_node_id(rsc_op); node 192 crmd/te_callbacks.c process_graph_event(rsc_op, node); node 219 crmd/te_callbacks.c const char *node = get_node_id(match); node 220 crmd/te_callbacks.c crm_action_t *cancelled = get_cancel_action(op_id, node); node 224 crmd/te_callbacks.c node); node 232 crmd/te_callbacks.c op_id, node, cancelled->id); node 245 crmd/te_callbacks.c const char *node, xmlNode *xml, xmlNode *change, const char *op, const char *xpath) node 286 crmd/te_callbacks.c process_graph_event(rsc_op, node); node 423 crmd/te_callbacks.c const char *node = NULL; node 520 crmd/te_callbacks.c node = ID(state); node 521 crmd/te_callbacks.c process_resource_updates(node, lrm, change, op, xpath); node 534 crmd/te_callbacks.c node = ID(state); node 535 crmd/te_callbacks.c process_resource_updates(node, lrm, change, op, xpath); node 541 crmd/te_callbacks.c node = ID(match); node 542 crmd/te_callbacks.c process_resource_updates(node, lrm, change, op, xpath); node 545 crmd/te_callbacks.c node = ID(match); node 546 crmd/te_callbacks.c process_resource_updates(node, match, change, op, xpath); node 612 crmd/te_callbacks.c const char *node = get_node_id(rsc_op); node 614 crmd/te_callbacks.c process_graph_event(rsc_op, node); node 75 crmd/te_events.c crm_node_t *node = crm_get_peer(0, router); node 76 crmd/te_events.c if (node) { node 77 crmd/te_events.c router_uuid = node->uuid; node 347 crmd/te_events.c get_cancel_action(const char *id, const char *node) node 369 crmd/te_events.c crm_trace("Wrong key %s for %s on %s", task, id, node); node 374 crmd/te_events.c if (node && safe_str_neq(target, node)) { node 375 crmd/te_events.c crm_trace("Wrong node %s for %s on %s", target, id, node); node 379 crmd/te_events.c crm_trace("Found %s on %s", id, node); node 37 crmd/tengine.h extern crm_action_t *get_cancel_action(const char *id, const char *node); node 47 crmd/throttle.c char *node; node 403 crmd/throttle.c free(r->node); node 509 crmd/throttle.c throttle_get_job_limit(const char *node) node 514 crmd/throttle.c r = g_hash_table_lookup(throttle_records, node); node 517 crmd/throttle.c r->node = strdup(node); node 520 crmd/throttle.c crm_trace("Defaulting to local values for unknown node %s", node); node 522 crmd/throttle.c g_hash_table_insert(throttle_records, r->node, r); node 540 crmd/throttle.c crm_err("Unknown throttle mode %.4x on %s", r->mode, node); node 561 crmd/throttle.c r->node = strdup(from); node 562 crmd/throttle.c g_hash_table_insert(throttle_records, r->node, r); node 26 crmd/throttle.h int throttle_get_job_limit(const char *node); node 295 fencing/admin.c char *node = NULL; node 307 fencing/admin.c node = target; node 312 fencing/admin.c return st->cmds->register_level_full(st, st_opts, node, pattern, node 316 fencing/admin.c return st->cmds->remove_level_full(st, st_opts, node, pattern, node 455 fencing/commands.c crm_node_t *node = crm_get_peer(0, cmd->victim); node 457 fencing/commands.c cmd->victim_nodeid = node->id; node 226 fencing/internal.h gboolean node_has_attr(const char *node, const char *name, const char *value); node 426 fencing/main.c topology_remove_helper(const char *node, int level) node 434 fencing/main.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 586 fencing/main.c node_t *node = NULL; node 590 fencing/main.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 591 fencing/main.c if (node && strcmp(node->details->uname, stonith_our_uname) == 0) { node 594 fencing/main.c node = NULL; node 597 fencing/main.c return node; node 610 fencing/main.c node_t *node = NULL; node 645 fencing/main.c node = our_node_allowed_for(rsc); node 650 fencing/main.c if(node == NULL) { node 656 fencing/main.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 657 fencing/main.c crm_trace("Available: %s = %d", node->details->uname, node->weight); node 662 fencing/main.c } else if(node->weight < 0 || (parent && parent->weight < 0)) { node 664 fencing/main.c char *score = score2char((node->weight < 0) ? node->weight : parent->weight); node 682 fencing/main.c crm_debug("Device %s is allowed on %s: score=%d", rsc->id, stonith_our_uname, node->weight); node 683 fencing/main.c get_rsc_attributes(rsc->parameters, rsc, node, data_set); node 684 fencing/main.c get_meta_attributes(rsc->meta, rsc, node, data_set); node 903 fencing/main.c node_has_attr(const char *node, const char *name, const char *value) node 919 fencing/main.c node, name, value); node 1258 fencing/main.c st_peer_update_callback(enum crm_status_type type, crm_node_t * node, const void *data) node 1260 fencing/main.c if ((type != crm_status_processes) && !is_set(node->flags, crm_remote_node)) { node 1263 fencing/main.c if (node->id && node->uname) { node 1264 fencing/main.c g_hash_table_insert(known_peer_names, GUINT_TO_POINTER(node->id), strdup(node->uname)); node 1277 fencing/main.c crm_debug("Broadcasting our uname because of node %u", node->id); node 702 fencing/remote.c topology_matches(const stonith_topology_t *tp, const char *node) node 706 fencing/remote.c CRM_CHECK(node && tp && tp->target, return FALSE); node 715 fencing/remote.c if (node_has_attr(node, tp->target_attribute, tp->target_value)) { node 716 fencing/remote.c crm_notice("Matched %s with %s by attribute", node, tp->target); node 728 fencing/remote.c int status = regexec(&r_patt, node, 0, NULL, 0); node 732 fencing/remote.c crm_notice("Matched %s with %s by name", node, tp->target); node 738 fencing/remote.c crm_trace("Testing %s against %s", node, tp->target); node 739 fencing/remote.c return safe_str_eq(tp->target, node); node 741 fencing/remote.c crm_trace("No match for %s with %s", node, tp->target); node 926 fencing/remote.c crm_node_t *node = crm_find_peer(nodeid, NULL); node 929 fencing/remote.c if (node && node->uname) { node 930 fencing/remote.c return strdup(node->uname); node 144 fencing/standalone_config.c standalone_cfg_add_node(const char *node, const char *device, const char *ports) node 153 fencing/standalone_config.c if (!node || !device) { node 157 fencing/standalone_config.c device, node); node 163 fencing/standalone_config.c len += strlen(node); node 182 fencing/standalone_config.c sprintf(tmp, "%s:%s;", node, ports); node 184 fencing/standalone_config.c sprintf(tmp, "%s ", node); node 191 fencing/standalone_config.c standalone_cfg_add_node_priority(const char *node, const char *device, unsigned int level) node 196 fencing/standalone_config.c if (!node || !device) { node 200 fencing/standalone_config.c if (!(topo = find_topology(node))) { node 203 fencing/standalone_config.c topo->node_name = strdup(node); node 74 fencing/standalone_config.h int standalone_cfg_add_node(const char *node, const char *device, const char *ports); node 79 fencing/standalone_config.h int standalone_cfg_add_node_priority(const char *node, const char *device, unsigned int level); node 149 include/crm/cluster.h gboolean send_cluster_message(crm_node_t * node, enum crm_ais_msg_types service, node 168 include/crm/cluster.h gboolean crm_is_peer_active(const crm_node_t * node); node 174 include/crm/cluster.h gboolean crm_is_heartbeat_peer_active(const crm_node_t * node); node 189 include/crm/cluster.h gboolean crm_is_corosync_peer_active(const crm_node_t * node); node 191 include/crm/cluster.h crm_node_t * node, enum crm_ais_msg_types dest); node 194 include/crm/cluster.h const char *crm_peer_uuid(crm_node_t *node); node 196 include/crm/cluster.h void set_uuid(xmlNode *xml, const char *attr, crm_node_t *node); node 396 include/crm/cluster/internal.h const char *node, gboolean force_ordered); node 426 include/crm/cluster/internal.h crm_node_t * node, enum crm_ais_msg_types dest); node 455 include/crm/cluster/internal.h crm_node_t *crm_update_peer_state(const char *source, crm_node_t * node, node 458 include/crm/cluster/internal.h void crm_update_peer_uname(crm_node_t *node, const char *uname); node 459 include/crm/cluster/internal.h void crm_update_peer_expected(const char *source, crm_node_t * node, const char *expected); node 66 include/crm/common/xml.h xmlDoc *getDocPtr(xmlNode * node); node 101 include/crm/common/xml.h const char *crm_xml_add(xmlNode * node, const char *name, const char *value); node 103 include/crm/common/xml.h const char *crm_xml_replace(xmlNode * node, const char *name, const char *value); node 105 include/crm/common/xml.h const char *crm_xml_add_int(xmlNode * node, const char *name, int value); node 120 include/crm/common/xml.h crm_xml_add_boolean(xmlNode *node, const char *name, gboolean value) node 122 include/crm/common/xml.h return crm_xml_add(node, name, (value? "true" : "false")); node 129 include/crm/common/xml.h void unlink_xml_node(xmlNode * node); node 45 include/crm/fencing/internal.h xmlNode *create_level_registration_xml(const char *node, const char *pattern, node 26 include/crm/lrmd_alerts_internal.h const char *node, uint32_t nodeid, node 29 include/crm/lrmd_alerts_internal.h const char *node, uint32_t nodeid, const char *state); node 34 include/crm/lrmd_alerts_internal.h const char *node, lrmd_event_data_t *op); node 44 include/crm/pengine/complex.h resource_t *(*find_rsc) (resource_t * parent, const char *search, node_t * node, int flags); node 55 include/crm/pengine/complex.h void get_meta_attributes(GHashTable * meta_hash, resource_t * rsc, node_t * node, node 57 include/crm/pengine/complex.h void get_rsc_attributes(GHashTable * meta_hash, resource_t * rsc, node_t * node, node 61 include/crm/pengine/complex.h void pe_get_versioned_attributes(xmlNode * meta_hash, resource_t * rsc, node_t * node, node 57 include/crm/pengine/internal.h bool pe_can_fence(pe_working_set_t *data_set, node_t *node); node 63 include/crm/pengine/internal.h char *native_parameter(resource_t * rsc, node_t * node, gboolean create, const char *name, node 71 include/crm/pengine/internal.h void native_add_running(resource_t * rsc, node_t * node, pe_working_set_t * data_set); node 80 include/crm/pengine/internal.h resource_t *native_find_rsc(resource_t * rsc, const char *id, node_t * node, int flags); node 124 include/crm/pengine/internal.h int pe_get_failcount(node_t *node, resource_t *rsc, time_t *last_failure, node 157 include/crm/pengine/internal.h extern void print_node(const char *pre_text, node_t * node, gboolean details); node 164 include/crm/pengine/internal.h extern void dump_node_capacity(int level, const char *comment, node_t * node); node 165 include/crm/pengine/internal.h extern void dump_rsc_utilization(int level, const char *comment, resource_t * rsc, node_t * node); node 181 include/crm/pengine/internal.h # define delete_action(rsc, node, optional) custom_action( \ node 182 include/crm/pengine/internal.h rsc, delete_key(rsc), CRMD_ACTION_DELETE, node, \ node 186 include/crm/pengine/internal.h # define stopped_action(rsc, node, optional) custom_action( \ node 187 include/crm/pengine/internal.h rsc, stopped_key(rsc), CRMD_ACTION_STOPPED, node, \ node 191 include/crm/pengine/internal.h # define stop_action(rsc, node, optional) custom_action( \ node 192 include/crm/pengine/internal.h rsc, stop_key(rsc), CRMD_ACTION_STOP, node, \ node 197 include/crm/pengine/internal.h # define start_action(rsc, node, optional) custom_action( \ node 198 include/crm/pengine/internal.h rsc, start_key(rsc), CRMD_ACTION_START, node, \ node 202 include/crm/pengine/internal.h # define started_action(rsc, node, optional) custom_action( \ node 203 include/crm/pengine/internal.h rsc, started_key(rsc), CRMD_ACTION_STARTED, node, \ node 207 include/crm/pengine/internal.h # define promote_action(rsc, node, optional) custom_action( \ node 208 include/crm/pengine/internal.h rsc, promote_key(rsc), CRMD_ACTION_PROMOTE, node, \ node 212 include/crm/pengine/internal.h # define promoted_action(rsc, node, optional) custom_action( \ node 213 include/crm/pengine/internal.h rsc, promoted_key(rsc), CRMD_ACTION_PROMOTED, node, \ node 217 include/crm/pengine/internal.h # define demote_action(rsc, node, optional) custom_action( \ node 218 include/crm/pengine/internal.h rsc, demote_key(rsc), CRMD_ACTION_DEMOTE, node, \ node 222 include/crm/pengine/internal.h # define demoted_action(rsc, node, optional) custom_action( \ node 223 include/crm/pengine/internal.h rsc, demoted_key(rsc), CRMD_ACTION_DEMOTED, node, \ node 240 include/crm/pengine/internal.h extern void resource_location(resource_t * rsc, node_t * node, int score, const char *tag, node 296 include/crm/pengine/internal.h op_digest_cache_t *rsc_action_digest_cmp(resource_t * rsc, xmlNode * xml_op, node_t * node, node 299 include/crm/pengine/internal.h action_t *pe_fence_op(node_t * node, const char *op, bool optional, const char *reason, pe_working_set_t * data_set); node 301 include/crm/pengine/internal.h resource_t * rsc, node_t *node, const char *reason, action_t *dependency, pe_working_set_t * data_set); node 316 include/crm/pengine/internal.h void pe_fence_node(pe_working_set_t * data_set, node_t * node, const char *reason); node 321 include/crm/pengine/internal.h void common_print(resource_t * rsc, const char *pre_text, const char *name, node_t *node, long options, void *print_data); node 322 include/crm/pengine/internal.h resource_t *find_container_child(const char *stem, resource_t * rsc, node_t *node); node 325 include/crm/pengine/internal.h const char *pe_node_attribute_calculated(pe_node_t *node, const char *name, resource_t *rsc); node 326 include/crm/pengine/internal.h const char *pe_node_attribute_raw(pe_node_t *node, const char *name); node 22 include/crm/pengine/remote.h gboolean is_baremetal_remote_node(node_t *node); node 23 include/crm/pengine/remote.h gboolean is_container_remote_node(node_t *node); node 24 include/crm/pengine/remote.h gboolean is_remote_node(node_t *node); node 336 include/crm/pengine/status.h node_t *node; node 474 include/crm/pengine/status.h GListPtr find_operations(const char *rsc, const char *node, gboolean active_filter, node 176 include/crm/stonith-ng.h stonith_t *st, int options, const char *node, int level); node 188 include/crm/stonith-ng.h stonith_t *st, int options, const char *node, int level, stonith_key_value_t *device_list); node 247 include/crm/stonith-ng.h int (*query)(stonith_t *st, int options, const char *node, node 265 include/crm/stonith-ng.h int (*fence)(stonith_t *st, int options, const char *node, const char *action, node 274 include/crm/stonith-ng.h int (*confirm)(stonith_t *st, int options, const char *node); node 284 include/crm/stonith-ng.h int (*history)(stonith_t *st, int options, const char *node, stonith_history_t **output, int timeout); node 335 include/crm/stonith-ng.h const char *node, const char *pattern, node 356 include/crm/stonith-ng.h const char *node, const char *pattern, node 151 include/crm_internal.h char *generate_transition_key(int action, int transition_id, int target_rc, const char *node); node 155 include/crm_internal.h const char *node, const char *origin, node 709 lib/ais/plugin.c crm_node_t *node = value; node 711 lib/ais/plugin.c if (node->last_seen != membership_seq && ais_str_eq(CRM_NODE_LOST, node->state) == FALSE) { node 712 lib/ais/plugin.c ais_info("Node %s was not seen in the previous transition", node->uname); node 713 lib/ais/plugin.c *changed += update_member(node->id, 0, membership_seq, node->votes, node 714 lib/ais/plugin.c node->processes, node->uname, CRM_NODE_LOST, NULL); node 768 lib/ais/plugin.c crm_node_t *node = NULL; node 774 lib/ais/plugin.c node = g_hash_table_lookup(membership_list, GUINT_TO_POINTER(nodeid)); node 775 lib/ais/plugin.c if (node->addr == NULL) { node 778 lib/ais/plugin.c node->addr = ais_strdup(addr); node 779 lib/ais/plugin.c ais_debug("Node %u has address %s", nodeid, node->addr); node 1159 lib/ais/plugin.c crm_node_t *node = value; node 1161 lib/ais/plugin.c if (ais_str_eq(CRM_NODE_MEMBER, node->state)) { node 1162 lib/ais/plugin.c plugin_has_votes += node->votes; node 1169 lib/ais/plugin.c crm_node_t *node = value; node 1172 lib/ais/plugin.c ais_trace("Dumping node %u", node->id); node 1173 lib/ais/plugin.c data->string = append_member(data->string, node); node 1686 lib/ais/plugin.c crm_node_t *node = g_hash_table_lookup(membership_list, GUINT_TO_POINTER(id)); node 1688 lib/ais/plugin.c if (node == NULL) { node 1691 lib/ais/plugin.c } else if (ais_str_eq(CRM_NODE_MEMBER, node->state)) { node 1692 lib/ais/plugin.c ais_warn("Peer %u/%s is still active", id, node->uname); node 1703 lib/ais/plugin.c ais_warn("Peer %u/%s was not removed", id, node->uname); node 1712 lib/ais/plugin.c crm_node_t *node = NULL; node 1717 lib/ais/plugin.c while (g_hash_table_iter_next(&iter, &key, (void **)&node)) { node 1718 lib/ais/plugin.c if (ais_str_eq(node_name, node->uname)) { node 1757 lib/ais/plugin.c char *node = data + 12; node 1759 lib/ais/plugin.c ais_remove_peer_by_name(node); node 1769 lib/ais/plugin.c crm_node_t *node = value; node 1772 lib/ais/plugin.c " addr=%s version=%s", node->id, node->uname ? node->uname : "-unknown-", node->state, node 1773 lib/ais/plugin.c node->processes, node->born, node->last_seen, node->addr ? node->addr : "-unknown-", node 1774 lib/ais/plugin.c node->version ? node->version : "-unknown-"); node 284 lib/ais/utils.c crm_node_t *node = data; node 286 lib/ais/utils.c ais_info("Destroying entry for node %u", node->id); node 288 lib/ais/utils.c ais_free(node->addr); node 289 lib/ais/utils.c ais_free(node->uname); node 290 lib/ais/utils.c ais_free(node->state); node 291 lib/ais/utils.c ais_free(node); node 299 lib/ais/utils.c crm_node_t *node = NULL; node 301 lib/ais/utils.c node = g_hash_table_lookup(membership_list, GUINT_TO_POINTER(id)); node 303 lib/ais/utils.c if (node == NULL) { node 304 lib/ais/utils.c ais_malloc0(node, sizeof(crm_node_t)); node 306 lib/ais/utils.c node->id = id; node 307 lib/ais/utils.c node->addr = NULL; node 308 lib/ais/utils.c node->state = ais_strdup("unknown"); node 310 lib/ais/utils.c g_hash_table_insert(membership_list, GUINT_TO_POINTER(id), node); node 311 lib/ais/utils.c node = g_hash_table_lookup(membership_list, GUINT_TO_POINTER(id)); node 313 lib/ais/utils.c AIS_ASSERT(node != NULL); node 316 lib/ais/utils.c node->last_seen = seq; node 319 lib/ais/utils.c if (born != 0 && node->born != born) { node 321 lib/ais/utils.c node->born = born; node 322 lib/ais/utils.c ais_info("%p Node %u (%s) born on: " U64T, node, id, uname, born); node 326 lib/ais/utils.c ais_free(node->version); node 327 lib/ais/utils.c node->version = ais_strdup(version); node 331 lib/ais/utils.c if (node->uname == NULL || ais_str_eq(node->uname, uname) == FALSE) { node 332 lib/ais/utils.c ais_info("%p Node %u now known as %s (was: %s)", node, id, uname, node->uname); node 333 lib/ais/utils.c ais_free(node->uname); node 334 lib/ais/utils.c node->uname = ais_strdup(uname); node 339 lib/ais/utils.c if (procs != 0 && procs != node->processes) { node 340 lib/ais/utils.c ais_info("Node %s now has process list: %.32x (%u)", node->uname, procs, procs); node 341 lib/ais/utils.c node->processes = procs; node 345 lib/ais/utils.c if (votes >= 0 && votes != node->votes) { node 346 lib/ais/utils.c ais_info("Node %s now has %d quorum votes (was %d)", node->uname, votes, node->votes); node 347 lib/ais/utils.c node->votes = votes; node 352 lib/ais/utils.c if (node->state == NULL || ais_str_eq(node->state, state) == FALSE) { node 353 lib/ais/utils.c ais_free(node->state); node 354 lib/ais/utils.c node->state = ais_strdup(state); node 355 lib/ais/utils.c ais_info("Node %u/%s is now: %s", id, node->uname ? node->uname : "unknown", state); node 376 lib/ais/utils.c crm_node_t *node = g_hash_table_lookup(membership_list, GUINT_TO_POINTER(id)); node 378 lib/ais/utils.c if (node == NULL) { node 381 lib/ais/utils.c if (node->uname == NULL) { node 384 lib/ais/utils.c return node->uname; node 388 lib/ais/utils.c append_member(char *data, crm_node_t * node) node 402 lib/ais/utils.c size += strlen(node->state); node 403 lib/ais/utils.c if (node->uname) { node 404 lib/ais/utils.c size += (7 + strlen(node->uname)); node 406 lib/ais/utils.c if (node->addr) { node 407 lib/ais/utils.c size += (6 + strlen(node->addr)); node 409 lib/ais/utils.c if (node->version) { node 410 lib/ais/utils.c size += (9 + strlen(node->version)); node 414 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "<node id=\"%u\" ", node->id); node 415 lib/ais/utils.c if (node->uname) { node 416 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "uname=\"%s\" ", node->uname); node 418 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "state=\"%s\" ", node->state); node 419 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "born=\"" U64T "\" ", node->born); node 420 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "seen=\"" U64T "\" ", node->last_seen); node 421 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "votes=\"%d\" ", node->votes); node 422 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "processes=\"%u\" ", node->processes); node 423 lib/ais/utils.c if (node->addr) { node 424 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "addr=\"%s\" ", node->addr); node 426 lib/ais/utils.c if (node->version) { node 427 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "version=\"%s\" ", node->version); node 88 lib/ais/utils.h extern char *append_member(char *data, crm_node_t * node); node 106 lib/cluster/cluster.c get_corosync_uuid(crm_node_t *node) node 108 lib/cluster/cluster.c if(node == NULL) { node 112 lib/cluster/cluster.c if (node->id > 0) { node 118 lib/cluster/cluster.c snprintf(buffer, len, "%u", node->id); node 124 lib/cluster/cluster.c crm_info("Node %s is not yet known by corosync", node->uname); node 127 lib/cluster/cluster.c } else if (node->uname != NULL) { node 128 lib/cluster/cluster.c return strdup(node->uname); node 271 lib/cluster/cluster.c send_cluster_message(crm_node_t * node, enum crm_ais_msg_types service, xmlNode * data, node 277 lib/cluster/cluster.c return send_cluster_message_cs(data, FALSE, node, service); node 282 lib/cluster/cluster.c return send_ha_message(heartbeat_cluster, data, node ? node->uname : NULL, ordered); node 378 lib/cluster/cluster.c crm_node_t *node = NULL; node 389 lib/cluster/cluster.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 390 lib/cluster/cluster.c if(node->uuid && strcasecmp(node->uuid, uuid) == 0) { node 391 lib/cluster/cluster.c if(node->uname) { node 392 lib/cluster/cluster.c return node->uname; node 397 lib/cluster/cluster.c node = NULL; node 404 lib/cluster/cluster.c node = crm_find_peer(id, NULL); node 410 lib/cluster/cluster.c node = crm_find_peer(0, uuid); node 413 lib/cluster/cluster.c if (node) { node 414 lib/cluster/cluster.c crm_info("Setting uuid for node %s[%u] to '%s'", node->uname, node->id, uuid); node 415 lib/cluster/cluster.c node->uuid = strdup(uuid); node 416 lib/cluster/cluster.c if(node->uname) { node 417 lib/cluster/cluster.c return node->uname; node 437 lib/cluster/cluster.c node = crm_get_peer(0, uname); node 444 lib/cluster/cluster.c if (node) { node 445 lib/cluster/cluster.c crm_info("Setting uuid for node %s to '%s'", node->uname, uuid); node 446 lib/cluster/cluster.c node->uuid = strdup(uuid); node 447 lib/cluster/cluster.c if(node->uname) { node 448 lib/cluster/cluster.c return node->uname; node 459 lib/cluster/cluster.c set_uuid(xmlNode *xml, const char *attr, crm_node_t *node) node 461 lib/cluster/cluster.c const char *uuid_calc = crm_peer_uuid(node); node 183 lib/cluster/corosync.c crm_node_t *node = NULL; node 212 lib/cluster/corosync.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 213 lib/cluster/corosync.c node->last_seen = 0; node 223 lib/cluster/corosync.c node = crm_get_peer(id, NULL); node 224 lib/cluster/corosync.c if (node->uname == NULL) { node 228 lib/cluster/corosync.c node = crm_get_peer(id, name); node 233 lib/cluster/corosync.c crm_update_peer_state(__FUNCTION__, node, CRM_NODE_MEMBER, ring_id); node 468 lib/cluster/corosync.c crm_is_corosync_peer_active(const crm_node_t * node) node 470 lib/cluster/corosync.c if (node == NULL) { node 474 lib/cluster/corosync.c } else if (safe_str_neq(node->state, CRM_NODE_MEMBER)) { node 475 lib/cluster/corosync.c crm_trace("%s: state=%s", node->uname, node->state); node 478 lib/cluster/corosync.c } else if ((node->processes & crm_proc_cpg) == 0) { node 479 lib/cluster/corosync.c crm_trace("%s: processes=%.16x", node->uname, node->processes); node 528 lib/cluster/corosync.c crm_node_t *node = NULL; node 531 lib/cluster/corosync.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 532 lib/cluster/corosync.c if(node && node->uname && strcasecmp(node->uname, name) == 0) { node 533 lib/cluster/corosync.c if (node->id && node->id != nodeid) { node 534 lib/cluster/corosync.c crm_crit("Nodes %u and %u share the same name '%s': shutting down", node->id, node 551 lib/cluster/corosync.c xmlNode *node = create_xml_node(xml_parent, XML_CIB_TAG_NODE); node 553 lib/cluster/corosync.c crm_xml_set_id(node, "%u", nodeid); node 554 lib/cluster/corosync.c crm_xml_add(node, XML_ATTR_UNAME, name); node 556 lib/cluster/corosync.c crm_xml_add(node, XML_ATTR_TYPE, CRM_NODE_MEMBER); node 509 lib/cluster/cpg.c send_cluster_message_cs(xmlNode * msg, gboolean local, crm_node_t * node, enum crm_ais_msg_types dest) node 515 lib/cluster/cpg.c rc = send_cluster_text(crm_class_cluster, data, local, node, dest); node 522 lib/cluster/cpg.c gboolean local, crm_node_t * node, enum crm_ais_msg_types dest) node 571 lib/cluster/cpg.c if (node) { node 572 lib/cluster/cpg.c if (node->uname) { node 573 lib/cluster/cpg.c target = strdup(node->uname); node 574 lib/cluster/cpg.c msg->host.size = strlen(node->uname); node 576 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); node 578 lib/cluster/cpg.c target = crm_strdup_printf("%u", node->id); node 580 lib/cluster/cpg.c msg->host.id = node->id; node 272 lib/cluster/election.c const crm_node_t *node; node 276 lib/cluster/election.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) & node)) { node 277 lib/cluster/election.c if (crm_is_peer_active(node)) { node 278 lib/cluster/election.c crm_err("member: %s proc=%.32x", node->uname, node->processes); node 338 lib/cluster/heartbeat.c crm_is_heartbeat_peer_active(const crm_node_t * node) node 342 lib/cluster/heartbeat.c if (node == NULL) { node 346 lib/cluster/heartbeat.c } else if (safe_str_neq(node->state, CRM_NODE_MEMBER)) { node 347 lib/cluster/heartbeat.c crm_trace("%s: state=%s", node->uname, node->state); node 350 lib/cluster/heartbeat.c } else if ((node->processes & crm_proc_heartbeat) == 0) { node 351 lib/cluster/heartbeat.c crm_trace("%s: processes=%.16x", node->uname, node->processes); node 357 lib/cluster/heartbeat.c } else if ((node->processes & proc) == 0) { node 358 lib/cluster/heartbeat.c crm_trace("%s: proc %.16x not in %.16x", node->uname, proc, node->processes); node 405 lib/cluster/heartbeat.c send_ha_message(ll_cluster_t * hb_conn, xmlNode * xml, const char *node, gboolean force_ordered) node 422 lib/cluster/heartbeat.c } else if (node != NULL) { node 423 lib/cluster/heartbeat.c char *host_lowercase = g_ascii_strdown(node, -1); node 624 lib/cluster/heartbeat.c xmlNode *node = NULL; node 649 lib/cluster/heartbeat.c node = create_xml_node(xml_parent, XML_CIB_TAG_NODE); node 650 lib/cluster/heartbeat.c crm_xml_add(node, XML_ATTR_ID, ha_node_uuid); node 651 lib/cluster/heartbeat.c crm_xml_add(node, XML_ATTR_UNAME, ha_node); node 652 lib/cluster/heartbeat.c crm_xml_add(node, XML_ATTR_TYPE, ha_node_type); node 569 lib/cluster/legacy.c xmlNode *node = NULL; node 571 lib/cluster/legacy.c for (node = __xml_first_child(msg); node != NULL; node = __xml_next(node)) { node 574 lib/cluster/legacy.c const char *uname = crm_element_value(node, "uname"); node 576 lib/cluster/legacy.c crm_element_value_int(node, "id", &id); node 577 lib/cluster/legacy.c crm_element_value_int(node, "processes", &children); node 931 lib/cluster/legacy.c crm_is_corosync_peer_active(const crm_node_t * node) node 935 lib/cluster/legacy.c if (node == NULL) { node 939 lib/cluster/legacy.c } else if (safe_str_neq(node->state, CRM_NODE_MEMBER)) { node 940 lib/cluster/legacy.c crm_trace("%s: state=%s", node->uname, node->state); node 943 lib/cluster/legacy.c } else if (is_cman_cluster() && (node->processes & crm_proc_cpg)) { node 947 lib/cluster/legacy.c crm_trace("%s: processes=%.8x", node->uname, node->processes); node 951 lib/cluster/legacy.c if (node->processes < crm_proc_none) { node 952 lib/cluster/legacy.c crm_debug("%s: unknown process list, assuming active for now", node->uname); node 955 lib/cluster/legacy.c } else if (is_set(node->processes, crm_proc_none)) { node 956 lib/cluster/legacy.c crm_debug("%s: all processes are inactive", node->uname); node 959 lib/cluster/legacy.c } else if (is_not_set(node->processes, crm_proc_plugin)) { node 960 lib/cluster/legacy.c crm_trace("%s: processes=%.8x", node->uname, node->processes); node 966 lib/cluster/legacy.c if (proc > crm_proc_none && (node->processes & proc) == 0) { node 967 lib/cluster/legacy.c crm_trace("%s: proc %.8x not in %.8x", node->uname, proc, node->processes); node 91 lib/cluster/membership.c crm_node_t *node; node 99 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, node_name); node 100 lib/cluster/membership.c if (node) { node 101 lib/cluster/membership.c return node; node 105 lib/cluster/membership.c node = calloc(1, sizeof(crm_node_t)); node 106 lib/cluster/membership.c if (node == NULL) { node 111 lib/cluster/membership.c node->flags = crm_remote_node; node 112 lib/cluster/membership.c node->uuid = strdup(node_name); node 113 lib/cluster/membership.c if (node->uuid == NULL) { node 114 lib/cluster/membership.c free(node); node 120 lib/cluster/membership.c g_hash_table_replace(crm_remote_peer_cache, node->uuid, node); node 124 lib/cluster/membership.c crm_update_peer_uname(node, node_name); node 125 lib/cluster/membership.c return node; node 194 lib/cluster/membership.c crm_node_t *node; node 204 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, remote); node 206 lib/cluster/membership.c if (node == NULL) { node 208 lib/cluster/membership.c node = crm_remote_peer_get(remote); node 209 lib/cluster/membership.c CRM_ASSERT(node); node 211 lib/cluster/membership.c crm_update_peer_state(__FUNCTION__, node, state, 0); node 214 lib/cluster/membership.c } else if (is_set(node->flags, crm_node_dirty)) { node 216 lib/cluster/membership.c clear_bit(node->flags, crm_node_dirty); node 218 lib/cluster/membership.c crm_update_peer_state(__FUNCTION__, node, state, 0); node 295 lib/cluster/membership.c crm_is_peer_active(const crm_node_t * node) node 297 lib/cluster/membership.c if(node == NULL) { node 301 lib/cluster/membership.c if (is_set(node->flags, crm_remote_node)) { node 308 lib/cluster/membership.c return crm_is_corosync_peer_active(node); node 313 lib/cluster/membership.c return crm_is_heartbeat_peer_active(node); node 323 lib/cluster/membership.c crm_node_t *node = value; node 329 lib/cluster/membership.c } else if (search->id && node->id != search->id) { node 332 lib/cluster/membership.c } else if (search->id == 0 && safe_str_neq(node->uname, search->uname)) { node 337 lib/cluster/membership.c (node->uname? node->uname : "unknown"), node->id); node 385 lib/cluster/membership.c crm_node_t *node = value; node 387 lib/cluster/membership.c if (crm_is_peer_active(node)) { node 406 lib/cluster/membership.c crm_node_t *node = data; node 408 lib/cluster/membership.c crm_trace("Destroying entry for node %u: %s", node->id, node->uname); node 410 lib/cluster/membership.c free(node->addr); node 411 lib/cluster/membership.c free(node->uname); node 412 lib/cluster/membership.c free(node->state); node 413 lib/cluster/membership.c free(node->uuid); node 414 lib/cluster/membership.c free(node->expected); node 415 lib/cluster/membership.c free(node); node 485 lib/cluster/membership.c crm_node_t *node = NULL; node 488 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, (gpointer *) &id, (gpointer *) &node)) { node 489 lib/cluster/membership.c do_crm_log(level, "%s: Node %u/%s = %p - %s", caller, node->id, node->uname, node, id); node 504 lib/cluster/membership.c crm_node_t *node = NULL; node 511 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, uname); node 514 lib/cluster/membership.c if (node == NULL && (flags & CRM_GET_PEER_CLUSTER)) { node 515 lib/cluster/membership.c node = crm_find_peer(id, uname); node 517 lib/cluster/membership.c return node; node 523 lib/cluster/membership.c crm_node_t *node = NULL; node 530 lib/cluster/membership.c node = g_hash_table_lookup(crm_remote_peer_cache, uname); node 533 lib/cluster/membership.c if (node == NULL && (flags & CRM_GET_PEER_CLUSTER)) { node 534 lib/cluster/membership.c node = crm_get_peer(id, uname); node 536 lib/cluster/membership.c return node; node 543 lib/cluster/membership.c crm_node_t *node = NULL; node 553 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 554 lib/cluster/membership.c if(node->uname && strcasecmp(node->uname, uname) == 0) { node 555 lib/cluster/membership.c crm_trace("Name match: %s = %p", node->uname, node); node 556 lib/cluster/membership.c by_name = node; node 564 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) { node 565 lib/cluster/membership.c if(node->id == id) { node 566 lib/cluster/membership.c crm_trace("ID match: %u = %p", node->id, node); node 567 lib/cluster/membership.c by_id = node; node 573 lib/cluster/membership.c node = by_id; /* Good default */ node 585 lib/cluster/membership.c node = NULL; /* Create a new one */ node 588 lib/cluster/membership.c node = by_name; node 630 lib/cluster/membership.c return node; node 635 lib/cluster/membership.c crm_remove_conflicting_peer(crm_node_t *node) node 641 lib/cluster/membership.c if (node->id == 0 || node->uname == NULL) { node 654 lib/cluster/membership.c && existing_node->id != node->id node 656 lib/cluster/membership.c && strcasecmp(existing_node->uname, node->uname) == 0) { node 663 lib/cluster/membership.c existing_node->id, existing_node->uname, node->id); node 678 lib/cluster/membership.c crm_node_t *node = NULL; node 685 lib/cluster/membership.c node = crm_find_peer(id, uname); node 689 lib/cluster/membership.c if ((node == NULL || node->uname == NULL) && (uname == NULL)) { node 698 lib/cluster/membership.c if (node == NULL) { node 699 lib/cluster/membership.c node = crm_find_peer(id, uname); node 704 lib/cluster/membership.c if (node == NULL) { node 707 lib/cluster/membership.c node = calloc(1, sizeof(crm_node_t)); node 708 lib/cluster/membership.c CRM_ASSERT(node); node 711 lib/cluster/membership.c uniqueid, node, uname, id, 1 + g_hash_table_size(crm_peer_cache)); node 712 lib/cluster/membership.c g_hash_table_replace(crm_peer_cache, uniqueid, node); node 715 lib/cluster/membership.c if(id > 0 && uname && (node->id == 0 || node->uname == NULL)) { node 719 lib/cluster/membership.c if(id > 0 && node->id == 0) { node 720 lib/cluster/membership.c node->id = id; node 723 lib/cluster/membership.c if (uname && (node->uname == NULL)) { node 724 lib/cluster/membership.c crm_update_peer_uname(node, uname); node 727 lib/cluster/membership.c if(node->uuid == NULL) { node 728 lib/cluster/membership.c const char *uuid = crm_peer_uuid(node); node 734 lib/cluster/membership.c crm_info("Cannot obtain a UUID for node %u/%s", id, node->uname); node 740 lib/cluster/membership.c return node; node 763 lib/cluster/membership.c crm_node_t *node = NULL; node 766 lib/cluster/membership.c node = crm_get_peer(id, uname); node 768 lib/cluster/membership.c CRM_ASSERT(node != NULL); node 770 lib/cluster/membership.c if (node->uuid == NULL) { node 773 lib/cluster/membership.c crm_peer_uuid(node); node 776 lib/cluster/membership.c node->uuid = strdup(uuid); node 781 lib/cluster/membership.c if (crm_update_peer_proc(source, node, children, state) == NULL) { node 787 lib/cluster/membership.c if (crm_update_peer_state(source, node, state, seen) == NULL) { node 793 lib/cluster/membership.c node->born = born; node 800 lib/cluster/membership.c node->born = born; node 803 lib/cluster/membership.c if (votes > 0 && node->votes != votes) { node 805 lib/cluster/membership.c node->votes = votes; node 809 lib/cluster/membership.c if (node->addr == NULL || crm_str_eq(node->addr, addr, FALSE) == FALSE) { node 811 lib/cluster/membership.c free(node->addr); node 812 lib/cluster/membership.c node->addr = strdup(addr); node 817 lib/cluster/membership.c " proc=%.32x", source, node->uname, node->id, node->state, node 818 lib/cluster/membership.c node->addr, addr_changed ? " (new)" : "", node->votes, node 819 lib/cluster/membership.c votes_changed ? " (new)" : "", node->born, node->last_seen, node->processes); node 823 lib/cluster/membership.c return node; node 838 lib/cluster/membership.c crm_update_peer_uname(crm_node_t *node, const char *uname) node 842 lib/cluster/membership.c CRM_CHECK(node != NULL, node 846 lib/cluster/membership.c if (safe_str_eq(uname, node->uname)) { node 859 lib/cluster/membership.c free(node->uname); node 860 lib/cluster/membership.c node->uname = strdup(uname); node 861 lib/cluster/membership.c CRM_ASSERT(node->uname != NULL); node 864 lib/cluster/membership.c crm_status_callback(crm_status_uname, node, NULL); node 868 lib/cluster/membership.c if (is_openais_cluster() && !is_set(node->flags, crm_remote_node)) { node 869 lib/cluster/membership.c crm_remove_conflicting_peer(node); node 891 lib/cluster/membership.c crm_update_peer_proc(const char *source, crm_node_t * node, uint32_t flag, const char *status) node 896 lib/cluster/membership.c CRM_CHECK(node != NULL, crm_err("%s: Could not set %s to %s for NULL", node 900 lib/cluster/membership.c if (is_set(node->flags, crm_remote_node)) { node 901 lib/cluster/membership.c return node; node 904 lib/cluster/membership.c last = node->processes; node 906 lib/cluster/membership.c node->processes = flag; node 907 lib/cluster/membership.c if (node->processes != last) { node 912 lib/cluster/membership.c if ((node->processes & flag) != flag) { node 913 lib/cluster/membership.c set_bit(node->processes, flag); node 918 lib/cluster/membership.c if (flag > 0 && node->processes != flag) { node 919 lib/cluster/membership.c node->processes = flag; node 924 lib/cluster/membership.c } else if (node->processes & flag) { node 925 lib/cluster/membership.c clear_bit(node->processes, flag); node 931 lib/cluster/membership.c crm_info("%s: Node %s[%u] - all processes are now offline", source, node->uname, node 932 lib/cluster/membership.c node->id); node 934 lib/cluster/membership.c crm_info("%s: Node %s[%u] - %s is now %s", source, node->uname, node->id, node 942 lib/cluster/membership.c crm_status_callback(crm_status_processes, node, &last); node 953 lib/cluster/membership.c node = crm_update_peer_state(__FUNCTION__, node, node 954 lib/cluster/membership.c is_set(node->processes, crm_get_cluster_proc())? node 958 lib/cluster/membership.c crm_trace("%s: Node %s[%u] - %s is unchanged (%s)", source, node->uname, node->id, node 961 lib/cluster/membership.c return node; node 965 lib/cluster/membership.c crm_update_peer_expected(const char *source, crm_node_t * node, const char *expected) node 970 lib/cluster/membership.c CRM_CHECK(node != NULL, crm_err("%s: Could not set 'expected' to %s", source, expected); node 974 lib/cluster/membership.c if (is_set(node->flags, crm_remote_node)) { node 978 lib/cluster/membership.c last = node->expected; node 979 lib/cluster/membership.c if (expected != NULL && safe_str_neq(node->expected, expected)) { node 980 lib/cluster/membership.c node->expected = strdup(expected); node 985 lib/cluster/membership.c crm_info("%s: Node %s[%u] - expected state is now %s (was %s)", source, node->uname, node->id, node 989 lib/cluster/membership.c crm_trace("%s: Node %s[%u] - expected state is unchanged (%s)", source, node->uname, node 990 lib/cluster/membership.c node->id, expected); node 1011 lib/cluster/membership.c crm_update_peer_state_iter(const char *source, crm_node_t * node, const char *state, int membership, GHashTableIter *iter) node 1015 lib/cluster/membership.c CRM_CHECK(node != NULL, node 1022 lib/cluster/membership.c node->last_seen = membership; node 1025 lib/cluster/membership.c if (state && safe_str_neq(node->state, state)) { node 1026 lib/cluster/membership.c char *last = node->state; node 1027 lib/cluster/membership.c enum crm_status_type status_type = is_set(node->flags, crm_remote_node)? node 1030 lib/cluster/membership.c node->state = strdup(state); node 1032 lib/cluster/membership.c " nodeid=%u previous=%s source=%s", node->uname, state, node 1033 lib/cluster/membership.c node->id, (last? last : "unknown"), source); node 1035 lib/cluster/membership.c crm_status_callback(status_type, node, last); node 1039 lib/cluster/membership.c if (crm_autoreap && !is_member && !is_set(node->flags, crm_remote_node)) { node 1045 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 1049 lib/cluster/membership.c reap_crm_member(node->id, node->uname); node 1051 lib/cluster/membership.c node = NULL; node 1056 lib/cluster/membership.c " nodeid=%u source=%s", node->uname, state, node->id, source); node 1058 lib/cluster/membership.c return node; node 1077 lib/cluster/membership.c crm_update_peer_state(const char *source, crm_node_t * node, const char *state, int membership) node 1079 lib/cluster/membership.c return crm_update_peer_state_iter(source, node, state, membership, NULL); node 1092 lib/cluster/membership.c crm_node_t *node = NULL; node 1096 lib/cluster/membership.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *)&node)) { node 1097 lib/cluster/membership.c if (node->last_seen != membership) { node 1098 lib/cluster/membership.c if (node->state) { node 1104 lib/cluster/membership.c crm_update_peer_state_iter(__FUNCTION__, node, CRM_NODE_LOST, membership, &iter); node 1108 lib/cluster/membership.c node->uname, node->id); node 200 lib/common/operations.c generate_transition_key(int transition_id, int action_id, int target_rc, const char *node) node 205 lib/common/operations.c CRM_CHECK(node != NULL, return NULL); node 207 lib/common/operations.c len += strlen(node); node 211 lib/common/operations.c snprintf(fail_state, len, "%d:%d:%d:%-*s", action_id, transition_id, target_rc, 36, node); node 458 lib/common/operations.c int target_rc, const char * node, const char * origin, int level) node 561 lib/common/operations.c crm_xml_add(xml_op, XML_LRM_ATTR_TARGET, node); /* For context during triage */ node 326 lib/common/xml.c pcmkDeregisterNode(xmlNodePtr node) node 328 lib/common/xml.c __xml_private_free(node->_private); node 332 lib/common/xml.c pcmkRegisterNode(xmlNodePtr node) node 336 lib/common/xml.c switch(node->type) { node 345 lib/common/xml.c node->_private = p; node 353 lib/common/xml.c crm_trace("Ignoring %p %d", node, node->type); node 354 lib/common/xml.c CRM_LOG_ASSERT(node->type == XML_ELEMENT_NODE); node 358 lib/common/xml.c if(p && TRACKING_CHANGES(node)) { node 362 lib/common/xml.c set_doc_flag(node, xpf_dirty); node 363 lib/common/xml.c __xml_node_dirty(node); node 2389 lib/common/xml.c getDocPtr(xmlNode * node) node 2393 lib/common/xml.c CRM_CHECK(node != NULL, return NULL); node 2395 lib/common/xml.c doc = node->doc; node 2398 lib/common/xml.c xmlDocSetRootElement(doc, node); node 2399 lib/common/xml.c xmlSetTreeDoc(node, doc); node 2490 lib/common/xml.c crm_xml_add(xmlNode * node, const char *name, const char *value) node 2495 lib/common/xml.c CRM_CHECK(node != NULL, return NULL); node 2505 lib/common/xml.c old_value = crm_element_value(node, name); node 2513 lib/common/xml.c if(TRACKING_CHANGES(node)) { node 2514 lib/common/xml.c const char *old = crm_element_value(node, name); node 2521 lib/common/xml.c if(dirty && __xml_acl_check(node, name, xpf_acl_create) == FALSE) { node 2522 lib/common/xml.c crm_trace("Cannot add %s=%s to %s", name, value, node->name); node 2526 lib/common/xml.c attr = xmlSetProp(node, (const xmlChar *)name, (const xmlChar *)value); node 2536 lib/common/xml.c crm_xml_replace(xmlNode * node, const char *name, const char *value) node 2542 lib/common/xml.c CRM_CHECK(node != NULL, return NULL); node 2545 lib/common/xml.c old_value = crm_element_value(node, name); node 2550 lib/common/xml.c if(__xml_acl_check(node, name, xpf_acl_write) == FALSE) { node 2552 lib/common/xml.c crm_trace("Cannot replace %s=%s to %s", name, value, node->name); node 2556 lib/common/xml.c xml_remove_prop(node, name); node 2563 lib/common/xml.c if(TRACKING_CHANGES(node)) { node 2569 lib/common/xml.c attr = xmlSetProp(node, (const xmlChar *)name, (const xmlChar *)value); node 2578 lib/common/xml.c crm_xml_add_int(xmlNode * node, const char *name, int value) node 2581 lib/common/xml.c const char *added = crm_xml_add(node, name, number); node 2591 lib/common/xml.c xmlNode *node = NULL; node 2600 lib/common/xml.c node = xmlNewDocRawNode(doc, NULL, (const xmlChar *)name, NULL); node 2601 lib/common/xml.c xmlDocSetRootElement(doc, node); node 2605 lib/common/xml.c node = xmlNewDocRawNode(doc, NULL, (const xmlChar *)name, NULL); node 2606 lib/common/xml.c xmlAddChild(parent, node); node 2608 lib/common/xml.c crm_node_created(node); node 2609 lib/common/xml.c return node; node 267 lib/fencing/st_client.c const char *node, const char *pattern, node 273 lib/fencing/st_client.c CRM_CHECK(node || pattern || (attr && value), return -EINVAL); node 278 lib/fencing/st_client.c if (node) { node 279 lib/fencing/st_client.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 297 lib/fencing/st_client.c stonith_api_remove_level(stonith_t * st, int options, const char *node, int level) node 299 lib/fencing/st_client.c return stonith_api_remove_level_full(st, options, node, node 319 lib/fencing/st_client.c create_level_registration_xml(const char *node, const char *pattern, node 327 lib/fencing/st_client.c CRM_CHECK(node || pattern || (attr && value), return NULL); node 336 lib/fencing/st_client.c if (node) { node 337 lib/fencing/st_client.c crm_xml_add(data, XML_ATTR_STONITH_TARGET, node); node 372 lib/fencing/st_client.c stonith_api_register_level_full(stonith_t * st, int options, const char *node, node 378 lib/fencing/st_client.c xmlNode *data = create_level_registration_xml(node, pattern, attr, value, node 389 lib/fencing/st_client.c stonith_api_register_level(stonith_t * st, int options, const char *node, int level, node 392 lib/fencing/st_client.c return stonith_api_register_level_full(st, options, node, NULL, NULL, NULL, node 1512 lib/fencing/st_client.c stonith_api_fence(stonith_t * stonith, int call_options, const char *node, const char *action, node 1519 lib/fencing/st_client.c crm_xml_add(data, F_STONITH_TARGET, node); node 1537 lib/fencing/st_client.c stonith_api_history(stonith_t * stonith, int call_options, const char *node, node 1547 lib/fencing/st_client.c if (node) { node 1549 lib/fencing/st_client.c crm_xml_add(data, F_STONITH_TARGET, node); node 221 lib/lrmd/lrmd_alerts.c const char *node, uint32_t nodeid, node 231 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, CRM_alert_node, node); node 258 lib/lrmd/lrmd_alerts.c const char *node, uint32_t nodeid, const char *state) node 267 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, CRM_alert_node, node); node 328 lib/lrmd/lrmd_alerts.c const char *node, lrmd_event_data_t *op) node 350 lib/lrmd/lrmd_alerts.c params = alert_key2param(params, CRM_alert_node, node); node 564 lib/pengine/clone.c node_t *node = (node_t *)nIter->data; node 566 lib/pengine/clone.c if (pe_find_node(rsc->running_on, node->details->uname) == NULL) { node 567 lib/pengine/clone.c stopped_list = add_list_element(stopped_list, node->details->uname); node 440 lib/pengine/common.c pe_node_attribute_calculated(pe_node_t *node, const char *name, resource_t *rsc) node 444 lib/pengine/common.c if(node == NULL) { node 448 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 453 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 463 lib/pengine/common.c CRM_ASSERT(node->details->remote_rsc); node 464 lib/pengine/common.c CRM_ASSERT(node->details->remote_rsc->container); node 466 lib/pengine/common.c if(node->details->remote_rsc->container->running_on) { node 467 lib/pengine/common.c pe_node_t *host = node->details->remote_rsc->container->running_on->data; node 473 lib/pengine/common.c rsc->id, name, node->details->remote_rsc->container->id); node 478 lib/pengine/common.c pe_node_attribute_raw(pe_node_t *node, const char *name) node 480 lib/pengine/common.c if(node == NULL) { node 483 lib/pengine/common.c return g_hash_table_lookup(node->details->attrs, name); node 132 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) node 137 lib/pengine/complex.c if (node) { node 138 lib/pengine/complex.c node_hash = node->details->attrs; node 175 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) node 179 lib/pengine/complex.c if (node) { node 180 lib/pengine/complex.c node_hash = node->details->attrs; node 188 lib/pengine/complex.c get_rsc_attributes(meta_hash, rsc->parent, node, data_set); node 200 lib/pengine/complex.c node_t * node, pe_working_set_t * data_set) node 204 lib/pengine/complex.c if (node) { node 205 lib/pengine/complex.c node_hash = node->details->attrs; node 213 lib/pengine/complex.c pe_get_versioned_attributes(meta_hash, rsc->parent, node, data_set); node 860 lib/pengine/complex.c node_t *node = NULL; node 862 lib/pengine/complex.c node = pe_hash_table_lookup(rsc->allowed_nodes, id); node 863 lib/pengine/complex.c if (node != NULL) { node 864 lib/pengine/complex.c pe_rsc_trace(rsc, "Updating score for %s on %s: %d + %d", rsc->id, id, node->weight, score); node 865 lib/pengine/complex.c node->weight = merge_weights(node->weight, score); node 530 lib/pengine/container.c node_t *node = NULL; node 578 lib/pengine/container.c node = pe_find_node(data_set->nodes, uname); node 579 lib/pengine/container.c if (node == NULL) { node 580 lib/pengine/container.c node = pe_create_node(uname, uname, "remote", "-INFINITY", node 583 lib/pengine/container.c node->weight = -INFINITY; node 585 lib/pengine/container.c node->rsc_discover_mode = pe_discover_never; node 608 lib/pengine/container.c tuple->node = node_copy(node); node 609 lib/pengine/container.c tuple->node->weight = 500; node 610 lib/pengine/container.c tuple->node->rsc_discover_mode = pe_discover_exclusive; node 615 lib/pengine/container.c g_hash_table_insert(tuple->child->allowed_nodes, (gpointer) tuple->node->details->id, node_copy(tuple->node)); node 618 lib/pengine/container.c node_t *copy = node_copy(tuple->node); node 620 lib/pengine/container.c g_hash_table_insert(tuple->child->parent->allowed_nodes, (gpointer) tuple->node->details->id, copy); node 628 lib/pengine/container.c while (g_hash_table_iter_next(&gIter, NULL, (void **)&node)) { node 629 lib/pengine/container.c if(is_remote_node(node)) { node 631 lib/pengine/container.c node->weight = -INFINITY; node 635 lib/pengine/container.c tuple->node->details->remote_rsc = tuple->remote; node 641 lib/pengine/container.c g_hash_table_insert(tuple->node->details->attrs, node 795 lib/pengine/container.c pe_node_t *node = NULL; node 807 lib/pengine/container.c node = tuple->docker->allocated_to; node 808 lib/pengine/container.c if(node == NULL && tuple->docker->running_on) { node 812 lib/pengine/container.c node = tuple->docker->running_on->data; node 815 lib/pengine/container.c if(node == NULL) { node 820 lib/pengine/container.c crm_trace("Fixing addr for %s on %s", rsc->id, node->details->uname); node 822 lib/pengine/container.c crm_xml_add(xml, field, node->details->uname); node 825 lib/pengine/container.c return node->details->uname; node 1168 lib/pengine/container.c find_container_child(const char *stem, resource_t * rsc, node_t *node) node 1182 lib/pengine/container.c if(tuple->node->details == node->details) { node 1273 lib/pengine/container.c node_t *node = NULL; node 1293 lib/pengine/container.c node = tuple->docker->running_on->data; node 1295 lib/pengine/container.c common_print(rsc, pre_text, buffer, node, options, print_data); node 1371 lib/pengine/container.c if(tuple->node) { node 1372 lib/pengine/container.c free(tuple->node); node 1373 lib/pengine/container.c tuple->node = NULL; node 73 lib/pengine/failcounts.c block_failure(node_t *node, resource_t *rsc, xmlNode *xml_op, node 117 lib/pengine/failcounts.c node->details->uname, xml_name, node 237 lib/pengine/failcounts.c pe_get_failcount(node_t *node, resource_t *rsc, time_t *last_failure, node 250 lib/pengine/failcounts.c g_hash_table_iter_init(&iter, node->details->attrs); node 268 lib/pengine/failcounts.c && block_failure(node, rsc, xml_op, data_set)) { node 283 lib/pengine/failcounts.c rsc->id, node->details->uname, rsc->failure_timeout); node 295 lib/pengine/failcounts.c failcount += pe_get_failcount(node, filler, &filler_last_failure, node 307 lib/pengine/failcounts.c rsc->id, score, node->details->uname); node 315 lib/pengine/failcounts.c rsc->id, score, node->details->uname); node 32 lib/pengine/native.c native_add_running(resource_t * rsc, node_t * node, pe_working_set_t * data_set) node 36 lib/pengine/native.c CRM_CHECK(node != NULL, return); node 41 lib/pengine/native.c if (safe_str_eq(a_node->details->id, node->details->id)) { node 46 lib/pengine/native.c pe_rsc_trace(rsc, "Adding %s to %s %s", rsc->id, node->details->uname, node 49 lib/pengine/native.c rsc->running_on = g_list_append(rsc->running_on, node); node 51 lib/pengine/native.c node->details->running_rsc = g_list_append(node->details->running_rsc, rsc); node 54 lib/pengine/native.c if (rsc->variant == pe_native && node->details->maintenance) { node 62 lib/pengine/native.c resource_location(rsc, node, INFINITY, "not_managed_default", data_set); node 64 lib/pengine/native.c while(p && node->details->online) { node 66 lib/pengine/native.c p->running_on = g_list_append(p->running_on, node); node 112 lib/pengine/native.c rsc->id, g_list_length(rsc->running_on), node->details->uname, node 116 lib/pengine/native.c pe_rsc_trace(rsc, "Resource %s is active on: %s", rsc->id, node->details->uname); node 120 lib/pengine/native.c native_add_running(rsc->parent, node, data_set); node 162 lib/pengine/native.c rsc_is_on_node(resource_t *rsc, node_t *node, int flags) node 165 lib/pengine/native.c rsc->id, node->details->uname); node 172 lib/pengine/native.c if (loc->details == node->details) { node 181 lib/pengine/native.c && (rsc->allocated_to->details == node->details)) { node 242 lib/pengine/native.c native_parameter(resource_t * rsc, node_t * node, gboolean create, const char *name, node 256 lib/pengine/native.c if (node != NULL) { node 257 lib/pengine/native.c pe_rsc_trace(rsc, "Creating hash with node %s", node->details->uname); node 264 lib/pengine/native.c get_rsc_attributes(local_hash, rsc, node, data_set); node 457 lib/pengine/native.c node_t *node = (node_t *) gIter->data; node 460 lib/pengine/native.c node->details->uname, node->details->id, node 461 lib/pengine/native.c node->details->online ? "false" : "true"); node 479 lib/pengine/native.c common_print(resource_t * rsc, const char *pre_text, const char *name, node_t *node, long options, void *print_data) node 514 lib/pengine/native.c node = NULL; node 561 lib/pengine/native.c if(node) { node 562 lib/pengine/native.c offset += snprintf(buffer + offset, LINE_MAX - offset, " %s", node->details->uname); node 564 lib/pengine/native.c if (node->details->online == FALSE && node->details->unclean) { node 729 lib/pengine/native.c node_t *node = NULL; node 738 lib/pengine/native.c node = rsc->running_on->data; node 740 lib/pengine/native.c common_print(rsc, pre_text, rsc_printable_id(rsc), node, options, print_data); node 792 lib/pengine/native.c node_t *node = (node_t *) gIter->data; node 794 lib/pengine/native.c if (*list == NULL || pe_find_node_id(*list, node->details->id) == NULL) { node 795 lib/pengine/native.c *list = g_list_append(*list, node); node 847 lib/pengine/native.c node_t *node = (node_t *) gIter2->data; node 850 lib/pengine/native.c if (node->details->unclean == FALSE && node->details->online == FALSE) { node 854 lib/pengine/native.c node_table = g_hash_table_lookup(active_table, node->details->uname); node 857 lib/pengine/native.c g_hash_table_insert(active_table, strdup(node->details->uname), node_table); node 27 lib/pengine/remote.c node_t *node; node 35 lib/pengine/remote.c node = pe_find_node(data_set->nodes, rsc->id); node 36 lib/pengine/remote.c if (node == NULL) { node 40 lib/pengine/remote.c return is_baremetal_remote_node(node); node 44 lib/pengine/remote.c is_baremetal_remote_node(node_t *node) node 46 lib/pengine/remote.c if (is_remote_node(node) && (node->details->remote_rsc == NULL || node->details->remote_rsc->container == FALSE)) { node 53 lib/pengine/remote.c is_container_remote_node(node_t *node) node 55 lib/pengine/remote.c if (is_remote_node(node) && (node->details->remote_rsc && node->details->remote_rsc->container)) { node 62 lib/pengine/remote.c is_remote_node(node_t *node) node 64 lib/pengine/remote.c if (node && node->details->type == node_remote) { node 807 lib/pengine/rules.c xmlNode *node = expr; node 810 lib/pengine/rules.c free_xml(node); node 148 lib/pengine/status.c node_t *node = (node_t *) iterator->data; node 149 lib/pengine/status.c struct node_shared_s *details = node->details; node 154 lib/pengine/status.c print_node("delete", node, FALSE); node 171 lib/pengine/status.c free(node); node 290 lib/pengine/status.c node_t *node = (node_t *) gIter->data; node 292 lib/pengine/status.c if (node && safe_str_eq(node->details->id, id)) { node 293 lib/pengine/status.c return node; node 306 lib/pengine/status.c node_t *node = (node_t *) gIter->data; node 308 lib/pengine/status.c if (node && safe_str_eq(node->details->uname, uname)) { node 309 lib/pengine/status.c return node; node 45 lib/pengine/unpack.c gboolean unpack_rsc_op(resource_t * rsc, node_t * node, xmlNode * xml_op, xmlNode ** last_failure, node 53 lib/pengine/unpack.c is_dangling_container_remote_node(node_t *node) node 58 lib/pengine/unpack.c if (is_remote_node(node) && node 59 lib/pengine/unpack.c node->details->remote_rsc && node 60 lib/pengine/unpack.c node->details->remote_rsc->container == NULL && node 61 lib/pengine/unpack.c is_set(node->details->remote_rsc->flags, pe_rsc_orphan_container_filler)) { node 77 lib/pengine/unpack.c pe_fence_node(pe_working_set_t * data_set, node_t * node, const char *reason) node 79 lib/pengine/unpack.c CRM_CHECK(node, return); node 82 lib/pengine/unpack.c if (is_container_remote_node(node)) { node 83 lib/pengine/unpack.c resource_t *rsc = node->details->remote_rsc->container; node 90 lib/pengine/unpack.c node->details->uname, reason, rsc->id); node 94 lib/pengine/unpack.c node->details->uname, rsc->id, reason); node 100 lib/pengine/unpack.c node->details->remote_requires_reset = TRUE; node 105 lib/pengine/unpack.c } else if (is_dangling_container_remote_node(node)) { node 109 lib/pengine/unpack.c node->details->uname, reason); node 110 lib/pengine/unpack.c set_bit(node->details->remote_rsc->flags, pe_rsc_failed); node 112 lib/pengine/unpack.c } else if (is_baremetal_remote_node(node)) { node 113 lib/pengine/unpack.c resource_t *rsc = node->details->remote_rsc; node 118 lib/pengine/unpack.c node->details->uname, reason); node 119 lib/pengine/unpack.c } else if(node->details->remote_requires_reset == FALSE) { node 120 lib/pengine/unpack.c node->details->remote_requires_reset = TRUE; node 122 lib/pengine/unpack.c node->details->uname, node 123 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", node 126 lib/pengine/unpack.c node->details->unclean = TRUE; node 127 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, data_set); node 129 lib/pengine/unpack.c } else if (node->details->unclean) { node 131 lib/pengine/unpack.c node->details->uname, node 132 lib/pengine/unpack.c pe_can_fence(data_set, node)? "would also be fenced" : "also is unclean", node 137 lib/pengine/unpack.c node->details->uname, node 138 lib/pengine/unpack.c pe_can_fence(data_set, node)? "will be fenced" : "is unclean", node 140 lib/pengine/unpack.c node->details->unclean = TRUE; node 141 lib/pengine/unpack.c pe_fence_op(node, NULL, TRUE, reason, data_set); node 1661 lib/pengine/unpack.c node_t *node; node 1664 lib/pengine/unpack.c node = pe_find_node(data_set->nodes, rsc_id); node 1665 lib/pengine/unpack.c if (node == NULL) { node 1666 lib/pengine/unpack.c node = pe_create_node(rsc_id, rsc_id, "remote", NULL, data_set); node 1670 lib/pengine/unpack.c if (node) { node 1672 lib/pengine/unpack.c node->details->shutdown = TRUE; node 1689 lib/pengine/unpack.c find_anonymous_clone(pe_working_set_t * data_set, node_t * node, resource_t * parent, node 1701 lib/pengine/unpack.c pe_rsc_trace(parent, "Looking for %s on %s in %s", rsc_id, node->details->uname, parent->id); node 1716 lib/pengine/unpack.c if (childnode->details == node->details) { node 1729 lib/pengine/unpack.c parent->id, node->details->uname); node 1769 lib/pengine/unpack.c node->details->uname); node 1774 lib/pengine/unpack.c rsc_id, node->details->uname, rsc->id, node 1782 lib/pengine/unpack.c unpack_find_resource(pe_working_set_t * data_set, node_t * node, const char *rsc_id, node 1818 lib/pengine/unpack.c rsc = find_container_child(rsc_id, rsc, node); node 1824 lib/pengine/unpack.c rsc = find_anonymous_clone(data_set, node, parent, base); node 1839 lib/pengine/unpack.c process_orphan_resource(xmlNode * rsc_entry, node_t * node, pe_working_set_t * data_set) node 1844 lib/pengine/unpack.c crm_debug("Detected orphan resource %s on %s", rsc_id, node->details->uname); node 1860 lib/pengine/unpack.c process_rsc_state(resource_t * rsc, node_t * node, node 1869 lib/pengine/unpack.c rsc->id, role2text(rsc->role), node->details->uname, fail2text(on_fail)); node 1876 lib/pengine/unpack.c if (g_hash_table_lookup(iter->known_on, node->details->id) == NULL) { node 1877 lib/pengine/unpack.c node_t *n = node_copy(node); node 1892 lib/pengine/unpack.c && node->details->online == FALSE node 1893 lib/pengine/unpack.c && node->details->maintenance == FALSE node 1905 lib/pengine/unpack.c if (is_container_remote_node(node)) { node 1910 lib/pengine/unpack.c if (is_baremetal_remote_node(node) && node->details->remote_rsc node 1911 lib/pengine/unpack.c && is_not_set(node->details->remote_rsc->flags, pe_rsc_failed)) { node 1918 lib/pengine/unpack.c node->details->unseen = TRUE; node 1931 lib/pengine/unpack.c pe_fence_node(data_set, node, reason); node 1936 lib/pengine/unpack.c if (node->details->unclean) { node 1953 lib/pengine/unpack.c pe_fence_node(data_set, node, reason); node 1958 lib/pengine/unpack.c node->details->standby = TRUE; node 1959 lib/pengine/unpack.c node->details->standby_onfail = TRUE; node 1974 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__action_migration_auto__", data_set); node 1984 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 1992 lib/pengine/unpack.c stop_action(rsc->container, node, FALSE); node 1994 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 2018 lib/pengine/unpack.c stop_action(rsc, node, FALSE); node 2044 lib/pengine/unpack.c rsc->id, node->details->uname); node 2048 lib/pengine/unpack.c rsc->id, node->details->uname); node 2052 lib/pengine/unpack.c native_add_running(rsc, node, data_set); node 2067 lib/pengine/unpack.c GListPtr possible_matches = find_actions(rsc->actions, key, node); node 2083 lib/pengine/unpack.c process_recurring(node_t * node, resource_t * rsc, node 2105 lib/pengine/unpack.c if (node->details->online == FALSE) { node 2106 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: node is offline", rsc->id, node->details->uname); node 2111 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: resource is not active", id, node->details->uname); node 2115 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: old %d", id, node->details->uname, counter); node 2122 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: non-recurring", id, node->details->uname); node 2128 lib/pengine/unpack.c pe_rsc_trace(rsc, "Skipping %s/%s: status", id, node->details->uname); node 2134 lib/pengine/unpack.c pe_rsc_trace(rsc, "Creating %s/%s", key, node->details->uname); node 2135 lib/pengine/unpack.c custom_action(rsc, key, task, node, TRUE, TRUE, data_set); node 2188 lib/pengine/unpack.c unpack_lrm_rsc_state(node_t * node, xmlNode * rsc_entry, pe_working_set_t * data_set) node 2210 lib/pengine/unpack.c crm_element_name(rsc_entry), rsc_id, node->details->uname); node 2228 lib/pengine/unpack.c rsc = unpack_find_resource(data_set, node, rsc_id, rsc_entry); node 2230 lib/pengine/unpack.c rsc = process_orphan_resource(rsc_entry, node, data_set); node 2248 lib/pengine/unpack.c unpack_rsc_op(rsc, node, rsc_op, &last_failure, &on_fail, data_set); node 2253 lib/pengine/unpack.c process_recurring(node, rsc, start_index, stop_index, sorted_op_list, data_set); node 2258 lib/pengine/unpack.c process_rsc_state(rsc, node, on_fail, migrate_op, data_set); node 2322 lib/pengine/unpack.c unpack_lrm_resources(node_t * node, xmlNode * lrm_rsc_list, pe_working_set_t * data_set) node 2327 lib/pengine/unpack.c CRM_CHECK(node != NULL, return FALSE); node 2329 lib/pengine/unpack.c crm_trace("Unpacking resources on %s", node->details->uname); node 2335 lib/pengine/unpack.c resource_t *rsc = unpack_lrm_rsc_state(node, rsc_entry, data_set); node 2369 lib/pengine/unpack.c node_t *node = value; node 2372 lib/pengine/unpack.c node->weight = *score; node 2377 lib/pengine/unpack.c find_lrm_op(const char *resource, const char *op, const char *node, const char *source, node 2383 lib/pengine/unpack.c offset += snprintf(xpath + offset, STATUS_PATH_MAX - offset, "//node_state[@uname='%s']", node); node 2410 lib/pengine/unpack.c unpack_rsc_migration(resource_t *rsc, node_t *node, xmlNode *xml_op, pe_working_set_t * data_set) node 2429 lib/pengine/unpack.c find_lrm_op(rsc->id, CRMD_ACTION_STOP, node->details->id, NULL, data_set); node 2468 lib/pengine/unpack.c rsc->dangling_migrations = g_list_prepend(rsc->dangling_migrations, node); node 2502 lib/pengine/unpack.c unpack_rsc_migration_failure(resource_t *rsc, node_t *node, xmlNode *xml_op, pe_working_set_t * data_set) node 2570 lib/pengine/unpack.c rsc->dangling_migrations = g_list_prepend(rsc->dangling_migrations, node); node 2576 lib/pengine/unpack.c record_failed_op(xmlNode *op, node_t* node, resource_t *rsc, pe_working_set_t * data_set) node 2581 lib/pengine/unpack.c if (node->details->online == FALSE) { node 2589 lib/pengine/unpack.c if(safe_str_eq(op_key, key) && safe_str_eq(uname, node->details->uname)) { node 2590 lib/pengine/unpack.c crm_trace("Skipping duplicate entry %s on %s", op_key, node->details->uname); node 2595 lib/pengine/unpack.c crm_trace("Adding entry %s on %s", op_key, node->details->uname); node 2596 lib/pengine/unpack.c crm_xml_add(op, XML_ATTR_UNAME, node->details->uname); node 2611 lib/pengine/unpack.c unpack_rsc_op_failure(resource_t * rsc, node_t * node, int rc, xmlNode * xml_op, xmlNode ** last_failure, node 2634 lib/pengine/unpack.c task, rsc->id, node->details->uname, services_ocf_exitcode_str(rc), node 2637 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 2641 lib/pengine/unpack.c task, rsc->id, node->details->uname, services_ocf_exitcode_str(rc), node 2656 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__stop_fail__", data_set); node 2659 lib/pengine/unpack.c unpack_rsc_migration_failure(rsc, node, xml_op, data_set); node 2684 lib/pengine/unpack.c crm_warn("Compatibility handling for failed op %s on %s", key, node->details->uname); node 2685 lib/pengine/unpack.c resource_location(rsc, node, -INFINITY, "__legacy_start__", data_set); node 2700 lib/pengine/unpack.c node->details->unclean ? "true" : "false", node 2735 lib/pengine/unpack.c resource_t *rsc, int rc, int target_rc, node_t * node, xmlNode * xml_op, enum action_fail_response * on_fail, pe_working_set_t * data_set) node 2754 lib/pengine/unpack.c key, node->details->uname, node 2767 lib/pengine/unpack.c task, rsc->id, node->details->uname); node 2796 lib/pengine/unpack.c task, rsc->id, node->details->uname); node 2810 lib/pengine/unpack.c key, rsc->id, node->details->uname); node 2834 lib/pengine/unpack.c } else if (pe_can_fence(data_set, node) == FALSE node 2848 lib/pengine/unpack.c key, rc, node->details->uname); node 2856 lib/pengine/unpack.c static bool check_operation_expiry(resource_t *rsc, node_t *node, int rc, xmlNode *xml_op, pe_working_set_t * data_set) node 2909 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, &last_failure, pe_fc_default, node 2912 lib/pengine/unpack.c if (pe_get_failcount(node, rsc, &last_failure, pe_fc_effective, node 2930 lib/pengine/unpack.c digest_data = rsc_action_digest_cmp(rsc, xml_op, node, data_set); node 2934 lib/pengine/unpack.c key, node->details->id); node 2937 lib/pengine/unpack.c crm_trace("Ignoring rsc op %s/%s on node %s", rsc->id, key, node->details->id); node 2947 lib/pengine/unpack.c node, FALSE, TRUE, data_set); node 2952 lib/pengine/unpack.c rsc->id, node->details->uname, clear_reason, clear_op->uuid); node 3001 lib/pengine/unpack.c update_resource_state(resource_t * rsc, node_t * node, xmlNode * xml_op, const char * task, int rc, node 3050 lib/pengine/unpack.c unpack_rsc_migration(rsc, node, xml_op, data_set); node 3053 lib/pengine/unpack.c pe_rsc_trace(rsc, "%s active on %s", rsc->id, node->details->uname); node 3091 lib/pengine/unpack.c unpack_rsc_op(resource_t * rsc, node_t * node, xmlNode * xml_op, xmlNode ** last_failure, node 3110 lib/pengine/unpack.c CRM_CHECK(node != NULL, return FALSE); node 3138 lib/pengine/unpack.c task_key, task, task_id, status, rc, node->details->uname, role2text(rsc->role)); node 3140 lib/pengine/unpack.c if (node->details->unclean) { node 3143 lib/pengine/unpack.c node->details->uname, rsc->id); node 3152 lib/pengine/unpack.c expired = check_operation_expiry(rsc, node, rc, xml_op, data_set); node 3160 lib/pengine/unpack.c if ((node->details->shutdown == FALSE) || (node->details->online == TRUE)) { node 3162 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 3169 lib/pengine/unpack.c if ((node->details->shutdown == FALSE) || (node->details->online == TRUE)) { node 3171 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 3179 lib/pengine/unpack.c key, node->details->uname, node 3185 lib/pengine/unpack.c task_key, rc, magic, node->details->uname); node 3188 lib/pengine/unpack.c } else if(node->details->online && node->details->unclean == FALSE) { node 3190 lib/pengine/unpack.c task_key, rc, magic, node->details->uname); node 3198 lib/pengine/unpack.c status = determine_op_status(rsc, rc, target_rc, node, xml_op, on_fail, data_set); node 3216 lib/pengine/unpack.c } else if (safe_str_eq(task, CRMD_ACTION_MIGRATE) && node->details->unclean) { node 3242 lib/pengine/unpack.c pe_rsc_trace(rsc, "%s/%s completed on %s", rsc->id, task, node->details->uname); node 3243 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, rc, *last_failure, on_fail, data_set); node 3251 lib/pengine/unpack.c task_key, status, rc, node->details->uname); node 3255 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); node 3256 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); node 3271 lib/pengine/unpack.c task_key, rc, node->details->uname); node 3273 lib/pengine/unpack.c update_resource_state(rsc, node, xml_op, task, target_rc, *last_failure, on_fail, data_set); node 3274 lib/pengine/unpack.c crm_xml_add(xml_op, XML_ATTR_UNAME, node->details->uname); node 3277 lib/pengine/unpack.c record_failed_op(xml_op, node, rsc, data_set); node 3284 lib/pengine/unpack.c unpack_rsc_op_failure(rsc, node, rc, xml_op, last_failure, on_fail, data_set); node 3289 lib/pengine/unpack.c parent->id, node->details->uname, node 3292 lib/pengine/unpack.c resource_location(parent, node, -INFINITY, "hard-error", data_set); node 3310 lib/pengine/unpack.c add_node_attrs(xmlNode * xml_obj, node_t * node, gboolean overwrite, pe_working_set_t * data_set) node 3314 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3315 lib/pengine/unpack.c strdup(CRM_ATTR_UNAME), strdup(node->details->uname)); node 3317 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, strdup(CRM_ATTR_ID), node 3318 lib/pengine/unpack.c strdup(node->details->id)); node 3319 lib/pengine/unpack.c if (safe_str_eq(node->details->id, data_set->dc_uuid)) { node 3320 lib/pengine/unpack.c data_set->dc_node = node; node 3321 lib/pengine/unpack.c node->details->is_dc = TRUE; node 3322 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3325 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3331 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, strdup(CRM_ATTR_CLUSTER_NAME), node 3336 lib/pengine/unpack.c node->details->attrs, NULL, overwrite, data_set->now); node 3338 lib/pengine/unpack.c if (pe_node_attribute_raw(node, CRM_ATTR_SITE_NAME) == NULL) { node 3339 lib/pengine/unpack.c const char *site_name = pe_node_attribute_raw(node, "site-name"); node 3342 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3348 lib/pengine/unpack.c g_hash_table_insert(node->details->attrs, node 3357 lib/pengine/unpack.c extract_operations(const char *node, const char *rsc, xmlNode * rsc_entry, gboolean active_filter) node 3376 lib/pengine/unpack.c crm_xml_add(rsc_op, XML_ATTR_UNAME, node); node 3418 lib/pengine/unpack.c find_operations(const char *rsc, const char *node, gboolean active_filter, node 3437 lib/pengine/unpack.c if (node != NULL && safe_str_neq(uname, node)) { node 37 lib/pengine/unpack.h extern gboolean unpack_lrm_resources(node_t * node, xmlNode * lrm_state, node 40 lib/pengine/unpack.h extern gboolean add_node_attrs(xmlNode * attrs, node_t * node, gboolean overwrite, node 100 lib/pengine/utils.c bool pe_can_fence(pe_working_set_t * data_set, node_t *node) node 114 lib/pengine/utils.c } else if(node == NULL) { node 117 lib/pengine/utils.c } else if(node->details->online) { node 118 lib/pengine/utils.c crm_notice("We can fence %s without quorum because they're in our membership", node->details->uname); node 122 lib/pengine/utils.c crm_trace("Cannot fence %s", node->details->uname); node 155 lib/pengine/utils.c node_t *node = NULL; node 158 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 160 lib/pengine/utils.c other_node = pe_find_node_id(list, node->details->id); node 162 lib/pengine/utils.c node->weight = -INFINITY; node 164 lib/pengine/utils.c node->weight = merge_weights(node->weight, other_node->weight); node 169 lib/pengine/utils.c node_t *node = (node_t *) gIter->data; node 171 lib/pengine/utils.c other_node = pe_hash_table_lookup(result, node->details->id); node 174 lib/pengine/utils.c node_t *new_node = node_copy(node); node 189 lib/pengine/utils.c node_t *node = (node_t *) gIter->data; node 190 lib/pengine/utils.c node_t *n = node_copy(node); node 239 lib/pengine/utils.c node_t *node = NULL; node 261 lib/pengine/utils.c node_t *node = (node_t *) gIter->data; node 263 lib/pengine/utils.c score2char_stack(node->weight, score, len); node 267 lib/pengine/utils.c comment, rsc->id, node->details->uname, score); node 269 lib/pengine/utils.c printf("%s: %s = %s\n", comment, node->details->uname, score); node 279 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 281 lib/pengine/utils.c score2char_stack(node->weight, score, len); node 286 lib/pengine/utils.c node->details->uname, score); node 289 lib/pengine/utils.c node->details->uname, score); node 322 lib/pengine/utils.c dump_node_capacity(int level, const char *comment, node_t * node) node 327 lib/pengine/utils.c len = strlen(comment) + strlen(": ") + strlen(node->details->uname) + strlen(" capacity:") + 1; node 329 lib/pengine/utils.c sprintf(dump_text, "%s: %s capacity:", comment, node->details->uname); node 331 lib/pengine/utils.c g_hash_table_foreach(node->details->utilization, append_dump_text, &dump_text); node 343 lib/pengine/utils.c dump_rsc_utilization(int level, const char *comment, resource_t * rsc, node_t * node) node 349 lib/pengine/utils.c + strlen(node->details->uname) + strlen(":") + 1; node 351 lib/pengine/utils.c sprintf(dump_text, "%s: %s utilization on %s:", comment, rsc->id, node->details->uname); node 475 lib/pengine/utils.c action->node = node_copy(on_node); node 538 lib/pengine/utils.c && action->node != NULL && action->op_entry != NULL) { node 541 lib/pengine/utils.c action->node->details->attrs, node 548 lib/pengine/utils.c } else if (action->node == NULL) { node 559 lib/pengine/utils.c } else if (action->node->details->online == FALSE node 560 lib/pengine/utils.c && (!is_container_remote_node(action->node) || action->node->details->remote_requires_reset)) { node 563 lib/pengine/utils.c action->uuid, action->node->details->uname); node 566 lib/pengine/utils.c && action->node->details->unclean == FALSE) { node 567 lib/pengine/utils.c pe_fence_node(data_set, action->node, "resource actions are unrunnable"); node 570 lib/pengine/utils.c } else if (action->node->details->pending) { node 573 lib/pengine/utils.c action->uuid, action->node->details->uname); node 591 lib/pengine/utils.c crm_debug("%s\t%s (cancelled : quorum)", action->node->details->uname, action->uuid); node 599 lib/pengine/utils.c action->node->details->uname, action->uuid); node 1240 lib/pengine/utils.c print_node(const char *pre_text, node_t * node, gboolean details) node 1242 lib/pengine/utils.c if (node == NULL) { node 1247 lib/pengine/utils.c CRM_ASSERT(node->details); node 1251 lib/pengine/utils.c node->details->online ? "" : "Unavailable/Unclean ", node 1252 lib/pengine/utils.c node->details->uname, node->weight, node->fixed ? "True" : "False"); node 1256 lib/pengine/utils.c GListPtr gIter = node->details->running_rsc; node 1259 lib/pengine/utils.c g_hash_table_foreach(node->details->attrs, print_str_str, pe_mutable); node 1322 lib/pengine/utils.c free(action->node); node 1349 lib/pengine/utils.c } else if (action->node == NULL) { node 1351 lib/pengine/utils.c } else if (action->node->details != not_on_node->details) { node 1403 lib/pengine/utils.c } else if (action->node == NULL) { node 1406 lib/pengine/utils.c } else if (on_node->details == action->node->details) { node 1433 lib/pengine/utils.c } else if (action->node == NULL) { node 1437 lib/pengine/utils.c action->node = node_copy(on_node); node 1440 lib/pengine/utils.c } else if (on_node->details == action->node->details) { node 1446 lib/pengine/utils.c key, action->node->details->uname, node 1470 lib/pengine/utils.c } else if (on_node == NULL || action->node == NULL) { node 1471 lib/pengine/utils.c crm_trace("on_node=%p, action->node=%p", on_node, action->node); node 1474 lib/pengine/utils.c } else if (safe_str_eq(on_node->details->id, action->node->details->id)) { node 1477 lib/pengine/utils.c crm_trace("Node mismatch: %s vs. %s", on_node->details->id, action->node->details->id); node 1484 lib/pengine/utils.c resource_node_score(resource_t * rsc, node_t * node, int score, const char *tag) node 1488 lib/pengine/utils.c if ((rsc->exclusive_discover || (node->rsc_discover_mode == pe_discover_never)) node 1502 lib/pengine/utils.c resource_node_score(child_rsc, node, score, tag); node 1506 lib/pengine/utils.c pe_rsc_trace(rsc, "Setting %s for %s on %s: %d", tag, rsc->id, node->details->uname, score); node 1507 lib/pengine/utils.c match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 1509 lib/pengine/utils.c match = node_copy(node); node 1516 lib/pengine/utils.c resource_location(resource_t * rsc, node_t * node, int score, const char *tag, node 1519 lib/pengine/utils.c if (node != NULL) { node 1520 lib/pengine/utils.c resource_node_score(rsc, node, score, tag); node 1541 lib/pengine/utils.c if (node == NULL && score == -INFINITY) { node 1890 lib/pengine/utils.c node_t * node, xmlNode * xml_op, pe_working_set_t * data_set) node 1894 lib/pengine/utils.c data = g_hash_table_lookup(node->details->digest_cache, key); node 1897 lib/pengine/utils.c action_t *action = custom_action(rsc, strdup(key), task, node, TRUE, FALSE, data_set); node 1910 lib/pengine/utils.c get_rsc_attributes(local_rsc_params, rsc, node, data_set); node 1912 lib/pengine/utils.c pe_get_versioned_attributes(local_versioned_params, rsc, node, data_set); node 1919 lib/pengine/utils.c crm_trace("Fixed addr for %s on %s", rsc->id, node->details->uname); node 1973 lib/pengine/utils.c g_hash_table_insert(node->details->digest_cache, strdup(key), data); node 1980 lib/pengine/utils.c rsc_action_digest_cmp(resource_t * rsc, xmlNode * xml_op, node_t * node, node 1995 lib/pengine/utils.c CRM_ASSERT(node != NULL); node 2003 lib/pengine/utils.c data = rsc_action_digest(rsc, task, key, node, xml_op, data_set); node 2008 lib/pengine/utils.c key, node->details->uname, node 2019 lib/pengine/utils.c key, node->details->uname, node 2033 lib/pengine/utils.c fencing_action_digest_cmp(resource_t * rsc, node_t * node, pe_working_set_t * data_set) node 2036 lib/pengine/utils.c op_digest_cache_t *data = rsc_action_digest(rsc, STONITH_DIGEST_TASK, key, node, NULL, data_set); node 2038 lib/pengine/utils.c const char *digest_all = pe_node_attribute_raw(node, CRM_ATTR_DIGESTS_ALL); node 2039 lib/pengine/utils.c const char *digest_secure = pe_node_attribute_raw(node, CRM_ATTR_DIGESTS_SECURE); node 2061 lib/pengine/utils.c rsc->id, node->details->uname); node 2070 lib/pengine/utils.c rsc->id, node->details->uname, rsc->id, node 2139 lib/pengine/utils.c pe_fence_op(node_t * node, const char *op, bool optional, const char *reason, pe_working_set_t * data_set) node 2148 lib/pengine/utils.c op_key = crm_strdup_printf("%s-%s-%s", CRM_OP_FENCE, node->details->uname, op); node 2155 lib/pengine/utils.c stonith_op = custom_action(NULL, op_key, CRM_OP_FENCE, node, TRUE, TRUE, data_set); node 2157 lib/pengine/utils.c add_hash_param(stonith_op->meta, XML_LRM_ATTR_TARGET, node->details->uname); node 2158 lib/pengine/utils.c add_hash_param(stonith_op->meta, XML_LRM_ATTR_TARGET_UUID, node->details->id); node 2161 lib/pengine/utils.c if(is_remote_node(node) && is_set(data_set->flags, pe_flag_enable_unfencing)) { node 2180 lib/pengine/utils.c op_digest_cache_t *data = fencing_action_digest_cmp(match, node, data_set); node 2184 lib/pengine/utils.c crm_notice("Unfencing %s (remote): because the definition of %s changed", node->details->uname, match->id); node 2187 lib/pengine/utils.c fprintf(stdout, " notice: Unfencing %s (remote): because the definition of %s changed\n", node->details->uname, match->id); node 2211 lib/pengine/utils.c if(optional == FALSE && pe_can_fence(data_set, node)) { node 2222 lib/pengine/utils.c resource_t * rsc, node_t *node, const char *reason, action_t *dependency, pe_working_set_t * data_set) node 2232 lib/pengine/utils.c } else if(node node 2233 lib/pengine/utils.c && node->details->online node 2234 lib/pengine/utils.c && node->details->unclean == FALSE node 2235 lib/pengine/utils.c && node->details->shutdown == FALSE) { node 2236 lib/pengine/utils.c action_t *unfence = pe_fence_op(node, "on", FALSE, reason, data_set); node 2246 lib/pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 2247 lib/pengine/utils.c if(node->details->online && node->details->unclean == FALSE && node->details->shutdown == FALSE) { node 2248 lib/pengine/utils.c trigger_unfencing(rsc, node, reason, dependency, data_set); node 63 lib/pengine/variant.h node_t *node; node 564 mcp/pacemaker.c crm_node_t *node = NULL; node 572 mcp/pacemaker.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 575 mcp/pacemaker.c crm_xml_add_int(xml, "id", node->id); node 576 mcp/pacemaker.c crm_xml_add(xml, "uname", node->uname); node 577 mcp/pacemaker.c crm_xml_add(xml, "state", node->state); node 578 mcp/pacemaker.c crm_xml_add_int(xml, "processes", node->processes); node 637 mcp/pacemaker.c crm_node_t *node = crm_get_peer(id, uname); node 640 mcp/pacemaker.c if (procs != node->processes) { node 642 mcp/pacemaker.c node->uname, procs, node->processes); node 643 mcp/pacemaker.c node->processes = procs; node 653 mcp/pacemaker.c crm_trace("Node %s still has process list: %.32x", node->uname, procs); node 43 mcp/pacemaker.h gboolean update_node_processes(uint32_t node, const char *uname, uint32_t procs); node 38 pengine/allocate.c extern void ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set); node 39 pengine/allocate.c extern gboolean DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set); node 41 pengine/allocate.c static enum remote_connection_state get_remote_node_state(pe_node_t *node); node 145 pengine/allocate.c action->uuid, action->node ? action->node->details->uname : "[none]", node 153 pengine/allocate.c check_rsc_parameters(resource_t * rsc, node_t * node, xmlNode * rsc_entry, node 179 pengine/allocate.c trigger_unfencing(rsc, node, "Device definition changed", NULL, data_set); node 183 pengine/allocate.c rsc->id, node->details->uname, attr_list[attr_lpc], node 189 pengine/allocate.c stop_action(rsc, node, FALSE); node 376 pengine/allocate.c check_actions_for(xmlNode * rsc_entry, resource_t * rsc, node_t * node, pe_working_set_t * data_set) node 393 pengine/allocate.c CRM_CHECK(node != NULL, return); node 401 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 407 pengine/allocate.c } else if (pe_find_node_id(rsc->running_on, node->details->id) == NULL) { node 408 pengine/allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, FALSE, data_set)) { node 409 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 412 pengine/allocate.c rsc->id, node->details->uname); node 416 pengine/allocate.c pe_rsc_trace(rsc, "Processing %s on %s", rsc->id, node->details->uname); node 418 pengine/allocate.c if (check_rsc_parameters(rsc, node, rsc_entry, TRUE, data_set)) { node 419 pengine/allocate.c DeleteRsc(rsc, node, FALSE, data_set); node 456 pengine/allocate.c (is_set(rsc->flags, pe_rsc_maintenance) || node->details->maintenance)) { node 457 pengine/allocate.c CancelXmlOp(rsc, rsc_op, node, "maintenance mode", data_set); node 461 pengine/allocate.c did_change = check_action_definition(rsc, node, rsc_op, data_set); node 464 pengine/allocate.c if (did_change && pe_get_failcount(node, rsc, NULL, pe_fc_effective, node 472 pengine/allocate.c custom_action(rsc, key, CRM_OP_CLEAR_FAILCOUNT, node, FALSE, TRUE, data_set); node 477 pengine/allocate.c rsc->id, node->details->uname, action_clear->uuid); node 546 pengine/allocate.c node_t *node = NULL; node 559 pengine/allocate.c node = pe_find_node_id(data_set->nodes, id); node 561 pengine/allocate.c if (node == NULL) { node 565 pengine/allocate.c } else if (can_run_resources(node) == FALSE && node->details->maintenance == FALSE) { node 567 pengine/allocate.c node->details->uname); node 571 pengine/allocate.c crm_trace("Processing node %s", node->details->uname); node 572 pengine/allocate.c if (node->details->online || is_set(data_set->flags, pe_flag_stonith_enabled)) { node 593 pengine/allocate.c check_actions_for(rsc_entry, rsc, node, data_set); node 622 pengine/allocate.c failcount_clear_action_exists(node_t * node, resource_t * rsc) node 626 pengine/allocate.c GListPtr list = find_actions_exact(rsc->actions, key, node); node 646 pengine/allocate.c check_migration_threshold(resource_t *rsc, node_t *node, node 663 pengine/allocate.c fail_count = pe_get_failcount(node, rsc, NULL, node 680 pengine/allocate.c resource_location(failed, node, -INFINITY, "__fail_limit__", data_set); node 682 pengine/allocate.c failed->id, node->details->uname, fail_count, node 686 pengine/allocate.c failed->id, countdown, node->details->uname); node 691 pengine/allocate.c common_apply_stickiness(resource_t * rsc, node_t * node, pe_working_set_t * data_set) node 699 pengine/allocate.c common_apply_stickiness(child_rsc, node, data_set); node 706 pengine/allocate.c node_t *current = pe_find_node_id(rsc->running_on, node->details->id); node 707 pengine/allocate.c node_t *match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 714 pengine/allocate.c resource_location(sticky_rsc, node, rsc->stickiness, "stickiness", data_set); node 717 pengine/allocate.c node->details->uname, rsc->stickiness); node 723 pengine/allocate.c " and node %s is not explicitly allowed", rsc->id, node->details->uname); node 735 pengine/allocate.c if (failcount_clear_action_exists(node, rsc) == FALSE) { node 736 pengine/allocate.c check_migration_threshold(rsc, node, data_set); node 845 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 848 pengine/allocate.c g_hash_table_foreach(node->details->attrs, calculate_system_health, &system_health); node 851 pengine/allocate.c node->details->uname, system_health); node 863 pengine/allocate.c rsc2node_new(health_strategy, rsc, system_health, NULL, node, data_set); node 901 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 902 pengine/allocate.c const char *probed = pe_node_attribute_raw(node, CRM_OP_PROBED); node 904 pengine/allocate.c if (node->details->online == FALSE) { node 906 pengine/allocate.c if (is_baremetal_remote_node(node) && node->details->remote_rsc node 907 pengine/allocate.c && (get_remote_node_state(node) == remote_state_failed)) { node 909 pengine/allocate.c pe_fence_node(data_set, node, "the connection is unrecoverable"); node 913 pengine/allocate.c } else if (node->details->unclean) { node 916 pengine/allocate.c } else if (node->details->rsc_discovery_enabled == FALSE) { node 922 pengine/allocate.c action_t *probe_op = custom_action(NULL, crm_strdup_printf("%s-%s", CRM_OP_REPROBE, node->details->uname), node 923 pengine/allocate.c CRM_OP_REPROBE, node, FALSE, TRUE, data_set); node 932 pengine/allocate.c rsc->cmds->create_probe(rsc, node, probe_node_complete, FALSE, data_set); node 939 pengine/allocate.c rsc_discover_filter(resource_t *rsc, node_t *node) node 951 pengine/allocate.c rsc_discover_filter(child_rsc, node); node 954 pengine/allocate.c match = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 975 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 977 pengine/allocate.c if (node == NULL) { node 980 pengine/allocate.c } else if (node->weight >= 0.0 /* global weight */ node 981 pengine/allocate.c && node->details->online && node->details->type != node_ping) { node 991 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 997 pengine/allocate.c common_apply_stickiness(rsc, node, data_set); node 998 pengine/allocate.c rsc_discover_filter(rsc, node); node 1122 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 1129 pengine/allocate.c r1_node = g_hash_table_lookup(r1_nodes, node->details->id); node 1137 pengine/allocate.c r2_node = g_hash_table_lookup(r2_nodes, node->details->id); node 1249 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 1251 pengine/allocate.c if (node->details->online node 1252 pengine/allocate.c && pe_get_failcount(node, rsc, NULL, pe_fc_effective, NULL, node 1257 pengine/allocate.c node, FALSE, TRUE, data_set); node 1264 pengine/allocate.c rsc->id, node->details->uname, clear_op->uuid); node 1294 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 1296 pengine/allocate.c dump_node_capacity(show_utilization ? 0 : utilization_log_level, "Original", node); node 1306 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 1308 pengine/allocate.c dump_node_capacity(show_utilization ? 0 : utilization_log_level, "Remaining", node); node 1414 pengine/allocate.c fence_guest(pe_node_t *node, pe_action_t *done, pe_working_set_t *data_set) node 1416 pengine/allocate.c resource_t *container = node->details->remote_rsc->container; node 1442 pengine/allocate.c stonith_op = pe_fence_op(node, fence_action, FALSE, "guest is unclean", data_set); node 1451 pengine/allocate.c pe_action_t *parent_stonith_op = pe_fence_op(stop->node, NULL, FALSE, NULL, data_set); node 1453 pengine/allocate.c node->details->uname, stonith_op->id, stop->node->details->uname); node 1462 pengine/allocate.c node->details->uname, stonith_op->id, node 1466 pengine/allocate.c node->details->uname, stonith_op->id); node 1472 pengine/allocate.c stonith_constraints(node, stonith_op, data_set); node 1512 pengine/allocate.c node_t *node = (node_t *) gIter->data; node 1517 pengine/allocate.c if (is_container_remote_node(node)) { node 1518 pengine/allocate.c if (node->details->remote_requires_reset && need_stonith) { node 1519 pengine/allocate.c fence_guest(node, done, data_set); node 1526 pengine/allocate.c if (node->details->unclean node 1527 pengine/allocate.c && need_stonith && pe_can_fence(data_set, node)) { node 1529 pengine/allocate.c stonith_op = pe_fence_op(node, NULL, FALSE, "node is unclean", data_set); node 1530 pengine/allocate.c pe_warn("Scheduling Node %s for STONITH", node->details->uname); node 1532 pengine/allocate.c stonith_constraints(node, stonith_op, data_set); node 1534 pengine/allocate.c if (node->details->is_dc) { node 1549 pengine/allocate.c } else if (node->details->online && node->details->shutdown && node 1553 pengine/allocate.c is_remote_node(node) == FALSE) { node 1557 pengine/allocate.c crm_notice("Scheduling Node %s for shutdown", node->details->uname); node 1559 pengine/allocate.c down_op = custom_action(NULL, crm_strdup_printf("%s-%s", CRM_OP_SHUTDOWN, node->details->uname), node 1560 pengine/allocate.c CRM_OP_SHUTDOWN, node, FALSE, TRUE, data_set); node 1562 pengine/allocate.c shutdown_constraints(node, down_op, data_set); node 1565 pengine/allocate.c if (node->details->is_dc) { node 1570 pengine/allocate.c if (node->details->unclean && stonith_op == NULL) { node 1572 pengine/allocate.c pe_warn("Node %s is unclean!", node->details->uname); node 1591 pengine/allocate.c dc_down->task, dc_down->node->details->uname); node 1600 pengine/allocate.c } else if (node_stop->node->details->is_dc) { node 1605 pengine/allocate.c node_stop->node->details->uname, node 1606 pengine/allocate.c dc_down->task, dc_down->node->details->uname); node 1831 pengine/allocate.c CRM_ASSERT(action->node); node 1832 pengine/allocate.c CRM_ASSERT(is_remote_node(action->node)); node 1834 pengine/allocate.c remote_rsc = action->node->details->remote_rsc; node 1841 pengine/allocate.c pe_fence_node(data_set, action->node, "container failed"); node 1914 pengine/allocate.c get_remote_node_state(pe_node_t *node) node 1919 pengine/allocate.c CRM_ASSERT(node); node 1921 pengine/allocate.c remote_rsc = node->details->remote_rsc; node 1952 pengine/allocate.c && node->details->remote_was_fenced) { node 1994 pengine/allocate.c enum remote_connection_state state = get_remote_node_state(action->node); node 2002 pengine/allocate.c CRM_ASSERT(action->node); node 2003 pengine/allocate.c CRM_ASSERT(is_remote_node(action->node)); node 2005 pengine/allocate.c remote_rsc = action->node->details->remote_rsc; node 2055 pengine/allocate.c pe_fence_node(data_set, action->node, "resources are active and the connection is unrecoverable"); node 2091 pengine/allocate.c pe_fence_node(data_set, action->node, "resources are in an unknown state and the connection is unrecoverable"); node 2150 pengine/allocate.c if (action->node == NULL) { node 2154 pengine/allocate.c if (is_remote_node(action->node) == FALSE) { node 2168 pengine/allocate.c remote = action->node->details->remote_rsc; node 2448 pengine/allocate.c && action->node node 2449 pengine/allocate.c && action->node->details->shutdown node 2462 pengine/allocate.c action->node->details->unclean ? "fence" : "shut down", node 2463 pengine/allocate.c action->node->details->uname, action->rsc->id, node 2495 pengine/allocate.c if (is_container_remote_node(action->node)) { node 2496 pengine/allocate.c node_name = crm_strdup_printf("%s (resource: %s)", action->node->details->uname, action->node->details->remote_rsc->container->id); node 2497 pengine/allocate.c } else if(action->node) { node 2498 pengine/allocate.c node_name = crm_strdup_printf("%s", action->node->details->uname); node 76 pengine/allocate.h extern enum pe_action_flags native_action_flags(action_t * action, node_t * node); node 81 pengine/allocate.h extern gboolean native_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 93 pengine/allocate.h extern enum pe_action_flags group_action_flags(action_t * action, node_t * node); node 107 pengine/allocate.h extern enum pe_action_flags container_action_flags(action_t * action, node_t * node); node 109 pengine/allocate.h extern gboolean container_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 122 pengine/allocate.h extern enum pe_action_flags clone_action_flags(action_t * action, node_t * node); node 124 pengine/allocate.h extern gboolean clone_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 164 pengine/allocate.h extern enum pe_graph_flags native_update_actions(action_t * first, action_t * then, node_t * node, node 168 pengine/allocate.h extern enum pe_graph_flags group_update_actions(action_t * first, action_t * then, node_t * node, node 171 pengine/allocate.h extern enum pe_graph_flags container_update_actions(action_t * first, action_t * then, node_t * node, node 46 pengine/clone.c parent_node_instance(const resource_t * rsc, node_t * node) node 50 pengine/clone.c if (node != NULL && rsc->parent) { node 51 pengine/clone.c ret = pe_hash_table_lookup(rsc->parent->allowed_nodes, node->details->id); node 52 pengine/clone.c } else if(node != NULL) { node 53 pengine/clone.c ret = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 364 pengine/clone.c can_run_instance(resource_t * rsc, node_t * node, int limit) node 368 pengine/clone.c if (node == NULL && rsc->allowed_nodes) { node 377 pengine/clone.c if (can_run_resources(node) == FALSE) { node 384 pengine/clone.c local_node = parent_node_instance(rsc, node); node 387 pengine/clone.c crm_warn("%s cannot run on %s: node not allowed", rsc->id, node->details->uname); node 391 pengine/clone.c common_update_score(rsc, node->details->id, local_node->weight); node 393 pengine/clone.c rsc->id, node->details->uname); node 397 pengine/clone.c rsc->id, node->details->uname, local_node->count); node 402 pengine/clone.c rsc->id, node->details->uname, local_node->count, limit); node 406 pengine/clone.c if (node) { node 407 pengine/clone.c common_update_score(rsc, node->details->id, -INFINITY); node 518 pengine/clone.c pe_node_t *node = nIter->data; node 520 pengine/clone.c node->count = 0; node 521 pengine/clone.c if (can_run_resources(node)) { node 929 pengine/clone.c assign_node(resource_t * rsc, node_t * node, gboolean force) node 938 pengine/clone.c changed |= assign_node(child_rsc, node, force); node 948 pengine/clone.c native_assign_node(rsc, NULL, node, force); node 955 pengine/clone.c node_t *node = NULL; node 960 pengine/clone.c node = child_rsc->fns->location(child_rsc, NULL, current); node 968 pengine/clone.c if (node && local_node && node->details == local_node->details) { node 971 pengine/clone.c } else if (node) { node 972 pengine/clone.c crm_trace("%s - %s vs %s", child_rsc->id, node->details->uname, node 999 pengine/clone.c node_t *node = (node_t *) gIter->data; node 1001 pengine/clone.c pair = find_compatible_child_by_node(local_child, node, rsc, filter, current); node 1142 pengine/clone.c summary_action_flags(action_t * action, GListPtr children, node_t * node) node 1155 pengine/clone.c child_action = find_first_action(child->actions, NULL, task_s, child->children ? NULL : node); node 1157 pengine/clone.c node ? node->details->uname : "none", child_action?child_action->uuid:"NA"); node 1159 pengine/clone.c enum pe_action_flags child_flags = child->cmds->action_flags(child_action, node); node 1177 pengine/clone.c if (node == NULL) { node 1186 pengine/clone.c clone_action_flags(action_t * action, node_t * node) node 1188 pengine/clone.c return summary_action_flags(action, action->rsc->children, node); node 1297 pengine/clone.c node_t *node = (node_t *) gIter->data; node 1299 pengine/clone.c if (*list == NULL || pe_find_node_id(*list, node->details->id) == NULL) { node 1300 pengine/clone.c *list = g_list_prepend(*list, node); node 1310 pengine/clone.c find_instance_on(resource_t * rsc, node_t * node) node 1326 pengine/clone.c if (node->details == known->details) { node 1338 pengine/clone.c clone_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 1355 pengine/clone.c node_t *allowed = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 1364 pengine/clone.c g_hash_table_remove(rsc->allowed_nodes, node->details->id); node 1377 pengine/clone.c child = find_instance_on(rsc, node); node 1379 pengine/clone.c return child->cmds->create_probe(child, node, complete, force, data_set); node 1394 pengine/clone.c if (local_node->details == node->details) { node 1395 pengine/clone.c return child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set); node 1402 pengine/clone.c return child->cmds->create_probe(child, node, complete, force, data_set); node 1409 pengine/clone.c if (child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set)) { node 736 pengine/constraints.c const char *node = crm_element_value(xml_obj, XML_CIB_TAG_NODE); node 749 pengine/constraints.c if (node != NULL && score != NULL) { node 751 pengine/constraints.c node_t *match = pe_find_node(data_set->nodes, node); node 959 pengine/constraints.c get_node_score(const char *rule, const char *score, gboolean raw, node_t * node, resource_t *rsc) node 970 pengine/constraints.c const char *attr_score = pe_node_attribute_calculated(node, score, rsc); node 974 pengine/constraints.c rule, node->details->uname, score); node 979 pengine/constraints.c rule, node->details->uname, attr_score, score); node 1060 pengine/constraints.c node_t *node = (node_t *) gIter->data; node 1062 pengine/constraints.c node->weight = get_node_score(rule_id, score, raw_score, node, rsc); node 1068 pengine/constraints.c node_t *node = (node_t *) gIter->data; node 1070 pengine/constraints.c accept = pe_test_rule_full(rule_xml, node->details->attrs, RSC_ROLE_UNKNOWN, data_set->now, match_data); node 1073 pengine/constraints.c node->details->uname); node 1075 pengine/constraints.c score_f = get_node_score(rule_id, score, raw_score, node, rsc); node 1081 pengine/constraints.c node_t *local = pe_find_node_id(match_L, node->details->id); node 1087 pengine/constraints.c local = node_copy(node); node 1094 pengine/constraints.c crm_trace("node %s now has weight %d", node->details->uname, local->weight); node 1098 pengine/constraints.c node_t *delete = pe_find_node_id(match_L, node->details->id); node 1102 pengine/constraints.c crm_trace("node %s did not match", node->details->uname); node 30 pengine/container.c is_child_container_node(container_variant_data_t *data, pe_node_t *node) node 34 pengine/container.c if(node->details == tuple->node->details) { node 78 pengine/container.c migration_threshold_reached(resource_t *rsc, node_t *node, node 94 pengine/container.c fail_count = pe_get_failcount(node, rsc, NULL, node 106 pengine/container.c rsc->id, node->details->uname, fail_count, node 112 pengine/container.c rsc->id, countdown, node->details->uname); node 164 pengine/container.c pe_node_t *node = NULL; node 167 pengine/container.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 168 pengine/container.c if(node->details != tuple->node->details) { node 169 pengine/container.c node->weight = -INFINITY; node 170 pengine/container.c } else if(migration_threshold_reached(tuple->child, node, data_set) == FALSE) { node 171 pengine/container.c node->weight = INFINITY; node 176 pengine/container.c tuple->child->cmds->allocate(tuple->child, tuple->node, data_set); node 182 pengine/container.c pe_node_t *node = NULL; node 185 pengine/container.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & node)) { node 186 pengine/container.c if(is_child_container_node(container_data, node)) { node 187 pengine/container.c node->weight = 0; node 189 pengine/container.c node->weight = -INFINITY; node 386 pengine/container.c node_t *node = (node_t *) gIter->data; node 388 pengine/container.c pair = find_compatible_tuple_by_node(rsc_lh, node, rsc, filter, current); node 503 pengine/container.c container_action_flags(action_t * action, node_t * node) node 520 pengine/container.c return summary_action_flags(action, data->child->children, node); node 527 pengine/container.c flags = summary_action_flags(action, containers, node); node 566 pengine/container.c tuple_for_docker(resource_t *rsc, resource_t *docker, node_t *node) node 575 pengine/container.c && node->details == tuple->node->details) { node 584 pengine/container.c container_update_interleave_actions(action_t * first, action_t * then, node_t * node, enum pe_action_flags flags, node 628 pengine/container.c container_grouping_t *first_tuple = tuple_for_docker(first->rsc, first_child, node); node 629 pengine/container.c container_grouping_t *then_tuple = tuple_for_docker(then->rsc, then_child, node); node 637 pengine/container.c first_action = find_first_action(first_tuple->child->actions, NULL, task2text(task), node); node 639 pengine/container.c first_action = find_first_action(first_child->actions, NULL, task2text(task), node); node 650 pengine/container.c then_action = find_first_action(then_tuple->child->actions, NULL, then->task, node); node 652 pengine/container.c then_action = find_first_action(then_child->actions, NULL, then->task, node); node 693 pengine/container.c changed |= then_child->cmds->update_actions(first_action, then_action, node, node 694 pengine/container.c first_child->cmds->action_flags(first_action, node), node 742 pengine/container.c container_update_actions(action_t * first, action_t * then, node_t * node, enum pe_action_flags flags, node 750 pengine/container.c changed = container_update_interleave_actions(first, then, node, flags, filter, type); node 757 pengine/container.c changed |= native_update_actions(first, then, node, flags, filter, type); node 764 pengine/container.c action_t *then_child_action = find_first_action(then_child->actions, NULL, then->task, node); node 767 pengine/container.c enum pe_action_flags then_child_flags = then_child->cmds->action_flags(then_child_action, node); node 771 pengine/container.c then_child->cmds->update_actions(first, then_child_action, node, flags, filter, type); node 859 pengine/container.c container_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 873 pengine/container.c any_created |= tuple->ip->cmds->create_probe(tuple->ip, node, complete, force, data_set); node 875 pengine/container.c if(tuple->child && node->details == tuple->node->details) { node 876 pengine/container.c any_created |= tuple->child->cmds->create_probe(tuple->child, node, complete, force, data_set); node 879 pengine/container.c bool created = tuple->docker->cmds->create_probe(tuple->docker, node, complete, force, data_set); node 910 pengine/container.c && tuple->remote->cmds->create_probe(tuple->remote, node, complete, node 917 pengine/container.c action_t *probe = find_first_action(tuple->remote->actions, probe_uuid, NULL, node); node 923 pengine/container.c tuple->remote->id, node->details->uname); node 36 pengine/graph.c get_action_flags(action_t * action, node_t * node) node 43 pengine/graph.c if (pe_rsc_is_clone(action->rsc) && node) { node 46 pengine/graph.c enum pe_action_flags clone_flags = action->rsc->cmds->action_flags(action, node); node 185 pengine/graph.c graph_update_action(action_t * first, action_t * then, node_t * node, node 210 pengine/graph.c node = first->node; node 219 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags & pe_action_optional, node 239 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, restart, pe_order_restart); node 251 pengine/graph.c first->rsc->cmds->update_actions(first, then, node, first_flags, node 276 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags & pe_action_optional, node 294 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 329 pengine/graph.c changed |= then->rsc->cmds->update_actions(first, then, node, first_flags, node 344 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 364 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 378 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 392 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 406 pengine/graph.c then->rsc->cmds->update_actions(first, then, node, first_flags, node 531 pengine/graph.c pe_action_pseudo) ? "pseudo" : then->node ? then->node->details->uname : ""); node 560 pengine/graph.c node_t *then_node = then->node; node 561 pengine/graph.c node_t *first_node = first->node; node 620 pengine/graph.c pe_action_pseudo) ? "pseudo" : then->node ? then->node->details-> node 625 pengine/graph.c pe_action_pseudo) ? "pseudo" : first->node ? first->node->details-> node 642 pengine/graph.c node_t *node = then->node; node 643 pengine/graph.c changed |= graph_update_action(first, then, node, first_flags, then_flags, other); node 670 pengine/graph.c pe_action_pseudo) ? "pseudo" : first->node ? first->node->details-> node 695 pengine/graph.c pe_action_pseudo) ? "pseudo" : then->node ? then->node->details-> node 713 pengine/graph.c shutdown_constraints(node_t * node, action_t * shutdown_op, pe_working_set_t * data_set) node 723 pengine/graph.c if (action->rsc == NULL || action->node == NULL) { node 725 pengine/graph.c } else if (action->node->details != node->details) { node 730 pengine/graph.c } else if (node->details->maintenance) { node 732 pengine/graph.c action->uuid, node->details->uname); node 746 pengine/graph.c node->details->uname); node 769 pengine/graph.c stonith_constraints(node_t * node, action_t * stonith_op, pe_working_set_t * data_set) node 787 pengine/graph.c if (safe_str_eq(action->task, CRM_OP_FENCE) || is_remote_node(action->node) == FALSE) { node 791 pengine/graph.c CRM_ASSERT(action->node->details->remote_rsc != NULL); node 793 pengine/graph.c if (action->node->details->remote_rsc->running_on) { node 794 pengine/graph.c began_on = action->node->details->remote_rsc->running_on->data; node 796 pengine/graph.c ended_on = action->node->details->remote_rsc->allocated_to; node 867 pengine/graph.c add_node_to_xml(const node_t *node, void *xml) node 869 pengine/graph.c add_node_to_xml_by_id(node->details->id, (xmlNode *) xml); node 889 pengine/graph.c node_t *node = (node_t *) gIter->data; node 890 pengine/graph.c struct node_shared_s *details = node->details; node 892 pengine/graph.c if (!(is_remote_node(node))) { node 899 pengine/graph.c add_node_to_xml_by_id(node->details->id, maintenance), node 944 pengine/graph.c CRM_CHECK(xml && action && action->node && data_set, return); node 950 pengine/graph.c add_node_to_xml_by_id(action->node->details->id, downed); node 959 pengine/graph.c add_node_to_xml_by_id(action->node->details->id, downed); node 960 pengine/graph.c pe_foreach_guest_node(data_set, action->node, add_node_to_xml, downed); node 1067 pengine/graph.c if (needs_node_info && action->node != NULL) { node 1070 pengine/graph.c crm_xml_add(action_xml, XML_LRM_ATTR_TARGET, action->node->details->uname); node 1071 pengine/graph.c crm_xml_add(action_xml, XML_LRM_ATTR_TARGET_UUID, action->node->details->id); node 1076 pengine/graph.c g_hash_table_insert(action->meta, strdup(XML_LRM_ATTR_TARGET), strdup(action->node->details->uname)); node 1077 pengine/graph.c g_hash_table_insert(action->meta, strdup(XML_LRM_ATTR_TARGET_UUID), strdup(action->node->details->id)); node 1158 pengine/graph.c if (action->rsc != NULL && action->node) { node 1161 pengine/graph.c get_rsc_attributes(p, action->rsc, action->node, data_set); node 1170 pengine/graph.c action->node, data_set); node 1212 pengine/graph.c if (isolated && action->node) { node 1214 pengine/graph.c crm_xml_add(args_xml, nodeattr, action->node->details->uname); node 1222 pengine/graph.c if(is_container_remote_node(action->node)) { node 1237 pengine/graph.c if(action->node->details->remote_rsc->container->running_on) { node 1238 pengine/graph.c host = action->node->details->remote_rsc->container->running_on->data; node 1246 pengine/graph.c if(action->node->details->remote_rsc->container->allocated_to) { node 1247 pengine/graph.c host = action->node->details->remote_rsc->container->allocated_to; node 1261 pengine/graph.c } else if (safe_str_eq(action->task, CRM_OP_FENCE) && action->node) { node 1268 pengine/graph.c g_hash_table_foreach(action->node->details->attrs, hash2metafield, args_xml); node 1275 pengine/graph.c if (needs_node_info && (action->node != NULL)) { node 1363 pengine/graph.c if (action->node == NULL) { node 1368 pengine/graph.c } else if(is_container_remote_node(action->node) && action->node->details->remote_requires_reset == FALSE) { node 1369 pengine/graph.c crm_trace("Assuming action %s for %s will be runnable", action->uuid, action->node->details->uname); node 1371 pengine/graph.c } else if (action->node->details->online == FALSE) { node 1379 pengine/graph.c } else if (action->node->details->unclean == FALSE) { node 1430 pengine/graph.c && wrapper->action->rsc && wrapper->action->node node 1431 pengine/graph.c && wrapper->action->node->details->remote_rsc node 1432 pengine/graph.c && (wrapper->action->node->details->remote_rsc->container == action->rsc)) { node 1489 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", action->uuid, node 1490 pengine/graph.c action->node ? action->node->details->uname : ""); node 1502 pengine/graph.c if (wrapper->action->node == NULL || action->rsc->allocated_to == NULL node 1503 pengine/graph.c || wrapper->action->node->details != action->rsc->allocated_to->details) { node 1510 pengine/graph.c } else if (wrapper->action->node == NULL || action->node == NULL node 1511 pengine/graph.c || wrapper->action->node->details != action->node->details) { node 1527 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", node 1529 pengine/graph.c action->node ? action->node->details->uname : ""); node 1531 pengine/graph.c if (wrapper->action->node && action->node node 1532 pengine/graph.c && wrapper->action->node->details != action->node->details) { node 1575 pengine/graph.c wrapper->action->id, wrapper->action->uuid, wrapper->action->node, node 1597 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", node 1599 pengine/graph.c action->node ? action->node->details->uname : "", node 1618 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", node 1620 pengine/graph.c action->node ? action->node->details->uname : "", node 1626 pengine/graph.c action->node ? action->node->details->uname : "", node 1628 pengine/graph.c init_action->node ? init_action->node->details->uname : ""); node 1664 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", node 1666 pengine/graph.c action->node ? action->node->details->uname : ""); node 1676 pengine/graph.c wrapper->action->node ? wrapper->action->node->details->uname : "", node 1678 pengine/graph.c action->node ? action->node->details->uname : ""); node 1688 pengine/graph.c wrapper->action->node, node 33 pengine/group.c node_t *node = NULL; node 73 pengine/group.c node = child_rsc->cmds->allocate(child_rsc, prefer, data_set); node 75 pengine/group.c group_node = node; node 374 pengine/group.c group_action_flags(action_t * action, node_t * node) node 383 pengine/group.c action_t *child_action = find_first_action(child->actions, NULL, task_s, node); node 386 pengine/group.c enum pe_action_flags child_flags = child->cmds->action_flags(child_action, node); node 415 pengine/group.c group_update_actions(action_t * first, action_t * then, node_t * node, enum pe_action_flags flags, node 422 pengine/group.c changed |= native_update_actions(first, then, node, flags, filter, type); node 426 pengine/group.c action_t *child_action = find_first_action(child->actions, NULL, then->task, node); node 429 pengine/group.c changed |= child->cmds->update_actions(first, child_action, node, flags, filter, type); node 165 pengine/master.c node_t *node = NULL; node 190 pengine/master.c node = rsc->fns->location(rsc, NULL, FALSE); node 191 pengine/master.c if (node == NULL) { node 198 pengine/master.c rsc->id, node->details->uname); node 208 pengine/master.c } else if (can_run_resources(node) == FALSE) { node 209 pengine/master.c crm_trace("Node can't run any resources: %s", node->details->uname); node 214 pengine/master.c local_node = pe_hash_table_lookup(parent->allowed_nodes, node->details->id); node 217 pengine/master.c crm_err("%s cannot run on %s: node not allowed", rsc->id, node->details->uname); node 225 pengine/master.c pe_rsc_trace(rsc, "%s cannot be master on %s: node full", rsc->id, node->details->uname); node 276 pengine/master.c node_t *node = NULL; node 308 pengine/master.c node = (node_t *) pe_hash_table_lookup(rsc->allowed_nodes, chosen->details->id); node 309 pengine/master.c CRM_ASSERT(node != NULL); node 313 pengine/master.c node->details->uname, child->id); node 314 pengine/master.c node->weight = merge_weights(child->sort_index, node->weight); node 385 pengine/master.c node = (node_t *) pe_hash_table_lookup(rsc->allowed_nodes, chosen->details->id); node 386 pengine/master.c CRM_ASSERT(node != NULL); node 388 pengine/master.c child->sort_index = node->weight; node 398 pengine/master.c filter_anonymous_instance(resource_t * rsc, node_t * node) node 406 pengine/master.c resource_t *active = parent->fns->find_rsc(child, key, node, pe_find_clone|pe_find_current); node 413 pengine/master.c pe_rsc_trace(rsc, "Found %s for %s active on %s: done", active->id, key, node->details->uname); node 417 pengine/master.c pe_rsc_trace(rsc, "Found %s for %s on %s: not %s", active->id, key, node->details->uname, rsc->id); node 421 pengine/master.c pe_rsc_trace(rsc, "%s on %s: not active", key, node->details->uname); node 439 pengine/master.c pe_rsc_trace(rsc, "Checking %s for %s on %s", rsc->id, key, node->details->uname); node 440 pengine/master.c if (g_hash_table_lookup(rsc->known_on, node->details->id)) { node 451 pengine/master.c lookup_master_score(resource_t * rsc, node_t *node, const char *name) node 455 pengine/master.c if (node && name) { node 458 pengine/master.c attr_value = pe_node_attribute_calculated(node, attr_name, rsc); node 465 pengine/master.c master_score(resource_t * rsc, node_t * node, int not_set_value) node 472 pengine/master.c CRM_CHECK(node != NULL, return not_set_value); node 479 pengine/master.c int c_score = master_score(child, node, not_set_value); node 490 pengine/master.c if (is_not_set(rsc->flags, pe_rsc_unique) && filter_anonymous_instance(rsc, node)) { node 491 pengine/master.c pe_rsc_trace(rsc, "Anonymous clone %s is allowed on %s", rsc->id, node->details->uname); node 500 pengine/master.c node_t *known = pe_hash_table_lookup(rsc->known_on, node->details->id); node 502 pengine/master.c match = pe_find_node_id(rsc->running_on, node->details->id); node 505 pengine/master.c rsc->id, rsc->clone_name, node->details->uname); node 510 pengine/master.c match = pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 527 pengine/master.c attr_value = lookup_master_score(rsc, node, name); node 529 pengine/master.c name, node->details->uname, crm_str(attr_value)); node 538 pengine/master.c attr_value = lookup_master_score(rsc, node, name); node 540 pengine/master.c name, node->details->uname, crm_str(attr_value)); node 570 pengine/master.c node_t *node = NULL; node 574 pengine/master.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 575 pengine/master.c if (can_run_resources(node) == FALSE) { node 583 pengine/master.c score = master_score(child_rsc, node, 0); node 585 pengine/master.c new_score = merge_weights(node->weight, score); node 586 pengine/master.c if (new_score != node->weight) { node 588 pengine/master.c child_rsc->id, node->details->uname, node->weight, new_score); node 589 pengine/master.c node->weight = new_score; node 658 pengine/master.c node_t *node = NULL; node 685 pengine/master.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 686 pengine/master.c node->count = 0; node 967 pengine/master.c node_t *node = NULL; node 979 pengine/master.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 980 pengine/master.c const char *tmp = pe_node_attribute_raw(node, attr); node 983 pengine/master.c crm_trace("%s: %d + %d", node->details->uname, node->weight, other->weight); node 984 pengine/master.c node->weight = merge_weights(node->weight, score); node 42 pengine/native.c void Recurring(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set); node 43 pengine/native.c void RecurringOp(resource_t * rsc, action_t * start, node_t * node, node 45 pengine/native.c void Recurring_Stopped(resource_t * rsc, action_t * start, node_t * node, node 47 pengine/native.c void RecurringOp_Stopped(resource_t * rsc, action_t * start, node_t * node, node 50 pengine/native.c void ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set); node 51 pengine/native.c gboolean DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set); node 203 pengine/native.c node_t *node = NULL; node 212 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 213 pengine/native.c int weight = node->weight; node 215 pengine/native.c if (can_run_resources(node) == FALSE) { node 219 pengine/native.c const char *tmp = pe_node_attribute_raw(node, attr); node 223 pengine/native.c best_node = node->details->uname; node 243 pengine/native.c node_t *node = NULL; node 250 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 254 pengine/native.c CRM_LOG_ASSERT(node != NULL); node 255 pengine/native.c if(node == NULL) { continue; }; node 257 pengine/native.c score = node_list_attr_score(list2, attr, pe_node_attribute_raw(node, attr)); node 264 pengine/native.c new_score = merge_weights(weight, node->weight); node 274 pengine/native.c node->details->uname, node->weight, factor, score); node 276 pengine/native.c } else if (node->weight == INFINITY_HACK) { node 278 pengine/native.c node->details->uname, node->weight, factor, score); node 280 pengine/native.c } else if (only_positive && new_score < 0 && node->weight > 0) { node 281 pengine/native.c node->weight = INFINITY_HACK; node 283 pengine/native.c node->details->uname, node->weight, factor, score); node 285 pengine/native.c } else if (only_positive && new_score < 0 && node->weight == 0) { node 287 pengine/native.c node->details->uname, node->weight, factor, score); node 290 pengine/native.c crm_trace("%s: %d + %f*%d", node->details->uname, node->weight, factor, score); node 291 pengine/native.c node->weight = new_score; node 413 pengine/native.c node_t *node = NULL; node 417 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 418 pengine/native.c if (node->weight == INFINITY_HACK) { node 419 pengine/native.c node->weight = 1; node 629 pengine/native.c RecurringOp(resource_t * rsc, action_t * start, node_t * node, node 652 pengine/native.c node ? node->details->uname : "n/a"); node 654 pengine/native.c if (node != NULL) { node 655 pengine/native.c node_uname = node->details->uname; node 697 pengine/native.c possible_matches = find_actions_exact(rsc->actions, key, node); node 728 pengine/native.c mon = custom_action(rsc, local_key, RSC_CANCEL, node, FALSE, TRUE, data_set); node 773 pengine/native.c mon = custom_action(rsc, key, name, node, is_optional, TRUE, data_set); node 784 pengine/native.c } else if (node == NULL || node->details->online == FALSE || node->details->unclean) { node 801 pengine/native.c if (node == NULL || is_set(rsc->flags, pe_rsc_managed)) { node 824 pengine/native.c Recurring(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set) node 827 pengine/native.c (node == NULL || node->details->maintenance == FALSE)) { node 833 pengine/native.c RecurringOp(rsc, start, node, operation, data_set); node 840 pengine/native.c RecurringOp_Stopped(resource_t * rsc, action_t * start, node_t * node, node 868 pengine/native.c if (node != NULL) { node 869 pengine/native.c node_uname = node->details->uname; node 901 pengine/native.c if (node != NULL) { node 902 pengine/native.c possible_matches = find_actions_exact(rsc->actions, key, node); node 909 pengine/native.c cancel_op = custom_action(rsc, local_key, RSC_CANCEL, node, FALSE, TRUE, data_set); node 1048 pengine/native.c Recurring_Stopped(resource_t * rsc, action_t * start, node_t * node, pe_working_set_t * data_set) node 1051 pengine/native.c (node == NULL || node->details->maintenance == FALSE)) { node 1057 pengine/native.c RecurringOp_Stopped(rsc, start, node, operation, data_set); node 1343 pengine/native.c node_t *node = NULL; node 1345 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1346 pengine/native.c if (node->details->remote_rsc) { node 1347 pengine/native.c node->weight = -INFINITY; node 1378 pengine/native.c node_t *node = NULL; node 1382 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1383 pengine/native.c action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, data_set); node 1442 pengine/native.c if (load_stopped->node == NULL) { node 1443 pengine/native.c load_stopped->node = node_copy(current); node 1456 pengine/native.c if (load_stopped->node == NULL) { node 1457 pengine/native.c load_stopped->node = node_copy(next); node 1494 pengine/native.c node_t *node = NULL; node 1496 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1497 pengine/native.c if (node->details->remote_rsc != remote_rsc) { node 1498 pengine/native.c node->weight = -INFINITY; node 1690 pengine/native.c node_t *node = NULL; node 1710 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 1711 pengine/native.c tmp = pe_node_attribute_raw(node, attribute); node 1715 pengine/native.c node->details->uname, constraint->score); node 1716 pengine/native.c node->weight = merge_weights(constraint->score, node->weight); node 1721 pengine/native.c node->details->uname, constraint->score, node 1723 pengine/native.c node->weight = merge_weights(-constraint->score, node->weight); node 1844 pengine/native.c node_t *node = (node_t *) gIter->data; node 1846 pengine/native.c pe_fence_node(data_set, node, "deadman ticket was lost"); node 1876 pengine/native.c native_action_flags(action_t * action, node_t * node) node 1882 pengine/native.c native_update_actions(action_t * first, action_t * then, node_t * node, enum pe_action_flags flags, node 1891 pengine/native.c first->uuid, first->node ? first->node->details->uname : "[none]", node 1905 pengine/native.c && then->node node 1908 pengine/native.c && then->node->details == ((node_t *) then_rsc->running_on->data)->details) { node 2048 pengine/native.c then->uuid, then->node ? then->node->details->uname : "[none]", then->flags, node 2061 pengine/native.c first->uuid, first->node ? first->node->details->uname : "[none]", node 2073 pengine/native.c node_t *node = NULL; node 2104 pengine/native.c node_t *node = (node_t *) gIter->data; node 2107 pengine/native.c other_node = (node_t *) pe_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 2111 pengine/native.c node->details->uname, node 2112 pengine/native.c other_node->details->uname, node->weight, other_node->weight); node 2113 pengine/native.c other_node->weight = merge_weights(other_node->weight, node->weight); node 2116 pengine/native.c other_node = node_copy(node); node 2132 pengine/native.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 2133 pengine/native.c pe_rsc_trace(rsc, "%s + %s : %d", rsc->id, node->details->uname, node->weight); node 2439 pengine/native.c node_t *node = (node_t *) gIter->data; node 2442 pengine/native.c possible_matches = find_actions(rsc->actions, key, node); node 2452 pengine/native.c LogAction("Stop", rsc, node, NULL, stop_op, node 2651 pengine/native.c DeleteRsc(resource_t * rsc, node_t * node, gboolean optional, pe_working_set_t * data_set) node 2654 pengine/native.c pe_rsc_trace(rsc, "Resource %s not deleted from %s: failed", rsc->id, node->details->uname); node 2657 pengine/native.c } else if (node == NULL) { node 2661 pengine/native.c } else if (node->details->unclean || node->details->online == FALSE) { node 2663 pengine/native.c node->details->uname); node 2667 pengine/native.c crm_notice("Removing %s from %s", rsc->id, node->details->uname); node 2669 pengine/native.c delete_action(rsc, node, optional); node 2752 pengine/native.c probe_anon_group_member(resource_t *rsc, node_t *node, node 2781 pengine/native.c running = pe_hash_table_lookup(peer->known_on, node->details->id); node 2798 pengine/native.c native_create_probe(resource_t * rsc, node_t * node, action_t * complete, node 2816 pengine/native.c CRM_CHECK(node != NULL, return FALSE); node 2822 pengine/native.c if (is_remote_node(node)) { node 2828 pengine/native.c rsc->id, node->details->id); node 2830 pengine/native.c } else if (is_container_remote_node(node) && rsc_contains_remote_node(data_set, rsc)) { node 2833 pengine/native.c rsc->id, node->details->id); node 2838 pengine/native.c rsc->id, node->details->id); node 2850 pengine/native.c any_created = child_rsc->cmds->create_probe(child_rsc, node, complete, force, data_set) node 2866 pengine/native.c running = g_hash_table_lookup(rsc->known_on, node->details->id); node 2870 pengine/native.c running = g_hash_table_lookup(rsc->parent->known_on, node->details->id); node 2874 pengine/native.c running = probe_anon_group_member(rsc, node, data_set); node 2880 pengine/native.c pe_rsc_trace(rsc, "Skipping known: %s on %s", rsc->id, node->details->uname); node 2884 pengine/native.c allowed = g_hash_table_lookup(rsc->allowed_nodes, node->details->id); node 2889 pengine/native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, A", rsc->id, node->details->id); node 2894 pengine/native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, B", rsc->id, node->details->id); node 2899 pengine/native.c if(allowed == NULL && node->rsc_discover_mode == pe_discover_never) { node 2905 pengine/native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, C", rsc->id, node->details->id); node 2911 pengine/native.c pe_rsc_trace(rsc, "Skipping probe for %s on node %s, discovery mode", rsc->id, node->details->id); node 2915 pengine/native.c if(is_container_remote_node(node)) { node 2916 pengine/native.c resource_t *remote = node->details->remote_rsc->container; node 2947 pengine/native.c rsc->id, node->details->id, remote->id); node 2953 pengine/native.c } else if(node->details->remote_requires_reset node 2954 pengine/native.c || node->details->unclean node 2968 pengine/native.c rsc->id, node->details->id, remote->id); node 2977 pengine/native.c probe = custom_action(rsc, key, RSC_STATUS, node, FALSE, TRUE, data_set); node 2994 pengine/native.c action_t *unfence = pe_fence_op(node, "on", TRUE, NULL, data_set); node 3002 pengine/native.c running = pe_find_node_id(rsc->running_on, node->details->id); node 3010 pengine/native.c crm_debug("Probing %s on %s (%s) %d %p", rsc->id, node->details->uname, role2text(rsc->role), node 3020 pengine/native.c crm_trace("Probing %s on %s (%s) as %s", rsc->id, node->details->uname, role2text(rsc->role), top->id); node 3061 pengine/native.c CRM_CHECK(stonith_op && stonith_op->node, return); node 3062 pengine/native.c target = stonith_op->node; node 3109 pengine/native.c CRM_CHECK(stonith_op && stonith_op->node, return); node 3110 pengine/native.c target = stonith_op->node; node 3220 pengine/native.c if (action->node->details->online == FALSE || action->node->details->unclean == TRUE node 3276 pengine/native.c ReloadRsc(resource_t * rsc, node_t *node, pe_working_set_t * data_set) node 3285 pengine/native.c ReloadRsc(child_rsc, node, data_set); node 3299 pengine/native.c stop_action(rsc, node, FALSE); /* Force a full restart, overkill? */ node 3302 pengine/native.c } else if (node == NULL) { node 3311 pengine/native.c rsc, reload_key(rsc), CRMD_ACTION_RELOAD, node, FALSE, TRUE, data_set); node 27 pengine/notif.c node_t *node; node 62 pengine/notif.c if (entry_a->node == NULL && entry_b->node == NULL) { node 65 pengine/notif.c if (entry_a->node == NULL) { node 68 pengine/notif.c if (entry_b->node == NULL) { node 72 pengine/notif.c return strcmp(entry_a->node->details->id, entry_b->node->details->id); node 81 pengine/notif.c dup->node = entry->node; node 104 pengine/notif.c node_t *node = (node_t *) gIter->data; node 106 pengine/notif.c if (node->details->uname == NULL) { node 109 pengine/notif.c len = 2 + strlen(node->details->uname); node 116 pengine/notif.c sprintf(node_list + existing_len, "%s%s", existing_len == 0 ? "":" ", node->details->uname); node 124 pengine/notif.c if(node->details->remote_rsc node 125 pengine/notif.c && node->details->remote_rsc->container node 126 pengine/notif.c && node->details->remote_rsc->container->running_on) { node 127 pengine/notif.c node = node->details->remote_rsc->container->running_on->data; node 130 pengine/notif.c if (node->details->uname == NULL) { node 133 pengine/notif.c len = 2 + strlen(node->details->uname); node 135 pengine/notif.c sprintf(metal_list + existing_len, "%s%s", existing_len == 0 ? "":" ", node->details->uname); node 182 pengine/notif.c CRM_LOG_ASSERT(node_list == NULL || entry->node != NULL); node 183 pengine/notif.c if(node_list != NULL && entry->node == NULL) { node 210 pengine/notif.c if (entry->node != NULL) { node 211 pengine/notif.c uname = entry->node->details->uname; node 237 pengine/notif.c pe_notify(resource_t * rsc, node_t * node, action_t * op, action_t * confirm, node 251 pengine/notif.c CRM_CHECK(node != NULL, return NULL); node 253 pengine/notif.c if (node->details->online == FALSE) { node 267 pengine/notif.c trigger = custom_action(rsc, key, op->task, node, node 282 pengine/notif.c pe_post_notify(resource_t * rsc, node_t * node, notify_data_t * n_data, pe_working_set_t * data_set) node 292 pengine/notif.c notify = pe_notify(rsc, node, n_data->post, n_data->post_done, n_data, data_set); node 462 pengine/notif.c entry->node = rsc->running_on->data; node 500 pengine/notif.c if (is_set(op->flags, pe_action_optional) == FALSE && op->node != NULL) { node 503 pengine/notif.c entry->node = op->node; node 663 pengine/notif.c if (is_set(op->flags, pe_action_optional) == FALSE && op->node != NULL) { node 759 pengine/notif.c strdup(action->node->details->uname)); node 122 pengine/pengine.h extern gboolean shutdown_constraints(node_t * node, action_t * shutdown_op, node 125 pengine/pengine.h extern gboolean stonith_constraints(node_t * node, action_t * stonith_op, node 98 pengine/ptest.c if (action->node) { node 99 pengine/ptest.c action_host = action->node->details->uname; node 136 pengine/utilization.c node_t *node; node 149 pengine/utilization.c remaining = crm_parse_int(g_hash_table_lookup(data->node->details->utilization, key), "0"); node 153 pengine/utilization.c CRM_ASSERT(data->node); node 156 pengine/utilization.c data->node->details->uname, (char *)key, data->rsc_id, required, remaining); node 162 pengine/utilization.c have_enough_capacity(node_t * node, const char * rsc_id, GHashTable * utilization) node 166 pengine/utilization.c data.node = node; node 348 pengine/utilization.c node_t *node = NULL; node 359 pengine/utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 360 pengine/utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 364 pengine/utilization.c if (have_enough_capacity(node, rscs_id, unallocated_utilization)) { node 369 pengine/utilization.c compare_capacity(node, most_capable_node) < 0) { node 371 pengine/utilization.c most_capable_node = node; node 377 pengine/utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 378 pengine/utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 382 pengine/utilization.c if (have_enough_capacity(node, rscs_id, unallocated_utilization) == FALSE) { node 386 pengine/utilization.c rsc->id, node->details->uname); node 387 pengine/utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); node 405 pengine/utilization.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 406 pengine/utilization.c if (can_run_resources(node) == FALSE || node->weight < 0) { node 410 pengine/utilization.c if (have_enough_capacity(node, rsc->id, rsc->utilization) == FALSE) { node 414 pengine/utilization.c rsc->id, node->details->uname); node 415 pengine/utilization.c resource_location(rsc, node, -INFINITY, "__limit_utilization__", data_set); node 111 pengine/utils.c can_run_resources(const node_t * node) node 113 pengine/utils.c if (node == NULL) { node 117 pengine/utils.c if (node->weight < 0) { node 122 pengine/utils.c if (node->details->online == FALSE node 123 pengine/utils.c || node->details->shutdown || node->details->unclean node 124 pengine/utils.c || node->details->standby || node->details->maintenance) { node 126 pengine/utils.c node->details->uname, node->details->online, node 127 pengine/utils.c node->details->unclean, node->details->standby, node->details->maintenance); node 339 pengine/utils.c } else if (action->node != NULL) { node 340 pengine/utils.c node_uname = action->node->details->uname; node 341 pengine/utils.c node_uuid = action->node->details->id; node 416 pengine/utils.c node_t *node = NULL; node 423 pengine/utils.c while (g_hash_table_iter_next(&iter, NULL, (void **)&node)) { node 424 pengine/utils.c if (can_run_resources(node) && node->weight >= 0) { node 27 pengine/utils.h const char *discovery_mode, node_t * node, node 44 pengine/utils.h extern gboolean can_run_resources(const node_t * node); node 58 pengine/utils.h bool assign_node(resource_t * rsc, node_t * node, gboolean force); node 59 pengine/utils.h enum pe_action_flags summary_action_flags(action_t * action, GListPtr children, node_t * node); node 92 replace/uuid_parse.c __u8 node[6]; node 128 replace/uuid_parse.c memcpy(out + 10, uu->node, 6); node 155 replace/uuid_parse.c memcpy(uu->node, ptr, 6); node 179 replace/uuid_parse.c return memcmp(uuid1.node, uuid2.node, 6); node 239 replace/uuid_parse.c uuid.node[i] = strtoul(buf, NULL, 16); node 257 replace/uuid_parse.c uuid.node[0], uuid.node[1], uuid.node[2], uuid.node[3], uuid.node[4], uuid.node[5]); node 503 replace/uuid_parse.c memcpy(uu.node, node_id, 6); node 59 tools/crm_mon.c static char *get_node_display_name(node_t *node); node 896 tools/crm_mon.c node_t *node = (node_t *) gIter->data; node 898 tools/crm_mon.c if (node->details->standby && node->details->online) { node 900 tools/crm_mon.c } else if (node->details->maintenance && node->details->online) { node 902 tools/crm_mon.c } else if (node->details->online) { node 905 tools/crm_mon.c mon_warn(" offline node: %s", node->details->uname); node 1014 tools/crm_mon.c print_node_start(FILE *stream, node_t *node) node 1021 tools/crm_mon.c node_name = get_node_display_name(node); node 1028 tools/crm_mon.c node_name = get_node_display_name(node); node 1034 tools/crm_mon.c fprintf(stream, " <node name=\"%s\">\n", node->details->uname); node 1246 tools/crm_mon.c print_rsc_history_start(FILE *stream, pe_working_set_t *data_set, node_t *node, node 1251 tools/crm_mon.c pe_get_failcount(node, rsc, &last_failure, pe_fc_default, node 1412 tools/crm_mon.c print_op_history(FILE *stream, pe_working_set_t *data_set, node_t *node, node 1510 tools/crm_mon.c print_rsc_history(FILE *stream, pe_working_set_t *data_set, node_t *node, node 1522 tools/crm_mon.c print_rsc_history_start(stream, data_set, node, rsc, rsc_id, FALSE); node 1556 tools/crm_mon.c print_rsc_history_start(stream, data_set, node, rsc, rsc_id, TRUE); node 1560 tools/crm_mon.c print_op_history(stream, data_set, node, xml_op, task, interval, rc); node 1585 tools/crm_mon.c node_t *node = pe_find_node_id(data_set->nodes, ID(node_state)); node 1589 tools/crm_mon.c if (node && node->details && node->details->online) { node 1590 tools/crm_mon.c print_node_start(stream, node); node 1600 tools/crm_mon.c print_rsc_history(stream, data_set, node, rsc_entry, operations); node 1620 tools/crm_mon.c print_attr_msg(FILE *stream, node_t * node, GListPtr rsc_list, const char *attrname, const char *attrvalue) node 1629 tools/crm_mon.c if (print_attr_msg(stream, node, rsc->children, attrname, attrvalue)) { node 1723 tools/crm_mon.c node_t *node; node 1732 tools/crm_mon.c value = pe_node_attribute_raw(data->node, name); node 1758 tools/crm_mon.c print_attr_msg(data->stream, data->node, data->node->details->running_rsc, node 1945 tools/crm_mon.c get_node_display_name(node_t *node) node 1952 tools/crm_mon.c CRM_ASSERT((node != NULL) && (node->details != NULL) && (node->details->uname != NULL)); node 1955 tools/crm_mon.c if (is_container_remote_node(node)) { node 1956 tools/crm_mon.c if (node->details->remote_rsc->running_on) { node 1961 tools/crm_mon.c node_t *host_node = (node_t *) node->details->remote_rsc->running_on->data; node 1973 tools/crm_mon.c if (print_clone_detail && safe_str_neq(node->details->uname, node->details->id)) { node 1974 tools/crm_mon.c node_id = node->details->id; node 1978 tools/crm_mon.c name_len = strlen(node->details->uname) + 1; node 1989 tools/crm_mon.c strcpy(node_name, node->details->uname); node 2010 tools/crm_mon.c static void print_ban(FILE *stream, node_t *node, rsc_to_node_t *location) node 2017 tools/crm_mon.c node_name = get_node_display_name(node); node 2026 tools/crm_mon.c node_name = get_node_display_name(node); node 2036 tools/crm_mon.c location->id, location->rsc_lh->id, node->details->uname, node->weight, node 2083 tools/crm_mon.c node_t *node = (node_t *) gIter2->data; node 2085 tools/crm_mon.c if (node->weight < 0) { node 2086 tools/crm_mon.c print_ban(stream, node, location); node 2165 tools/crm_mon.c data.node = (node_t *) gIter->data; node 2167 tools/crm_mon.c if (data.node && data.node->details && data.node->details->online) { node 2168 tools/crm_mon.c print_node_start(stream, data.node); node 2169 tools/crm_mon.c g_hash_table_foreach(data.node->details->attrs, create_attr_list, NULL); node 2737 tools/crm_mon.c const char *node = crm_element_value(xml_op, XML_ATTR_UNAME); node 2760 tools/crm_mon.c op_key, node, services_ocf_exitcode_str(rc), rc, node 2767 tools/crm_mon.c op_key, node, services_ocf_exitcode_str(rc), rc, node 2774 tools/crm_mon.c op_key_attr, op_key, node); node 2937 tools/crm_mon.c node_t *node = (node_t *) gIter->data; node 2939 tools/crm_mon.c char *node_name = get_node_display_name(node); node 2942 tools/crm_mon.c if (node->details->unclean) { node 2943 tools/crm_mon.c if (node->details->online) { node 2946 tools/crm_mon.c } else if (node->details->pending) { node 2953 tools/crm_mon.c } else if (node->details->pending) { node 2956 tools/crm_mon.c } else if (node->details->standby_onfail && node->details->online) { node 2959 tools/crm_mon.c } else if (node->details->standby) { node 2960 tools/crm_mon.c if (node->details->online) { node 2966 tools/crm_mon.c } else if (node->details->maintenance) { node 2967 tools/crm_mon.c if (node->details->online) { node 2973 tools/crm_mon.c } else if (node->details->online) { node 2976 tools/crm_mon.c if (is_container_remote_node(node)) { node 2978 tools/crm_mon.c } else if (is_baremetal_remote_node(node)) { node 2989 tools/crm_mon.c if (is_baremetal_remote_node(node)) { node 2991 tools/crm_mon.c } else if (is_container_remote_node(node)) { node 3004 tools/crm_mon.c if (is_container_remote_node(node)) { node 3006 tools/crm_mon.c } else if (is_baremetal_remote_node(node)) { node 3014 tools/crm_mon.c print_rscs_brief(node->details->running_rsc, "\t", print_opts | pe_print_rsconly, node 3019 tools/crm_mon.c for (gIter2 = node->details->running_rsc; gIter2 != NULL; gIter2 = gIter2->next) { node 3110 tools/crm_mon.c node_t *node = (node_t *) gIter->data; node 3113 tools/crm_mon.c switch (node->details->type) { node 3125 tools/crm_mon.c fprintf(stream, " <node name=\"%s\" ", node->details->uname); node 3126 tools/crm_mon.c fprintf(stream, "id=\"%s\" ", node->details->id); node 3127 tools/crm_mon.c fprintf(stream, "online=\"%s\" ", node->details->online ? "true" : "false"); node 3128 tools/crm_mon.c fprintf(stream, "standby=\"%s\" ", node->details->standby ? "true" : "false"); node 3129 tools/crm_mon.c fprintf(stream, "standby_onfail=\"%s\" ", node->details->standby_onfail ? "true" : "false"); node 3130 tools/crm_mon.c fprintf(stream, "maintenance=\"%s\" ", node->details->maintenance ? "true" : "false"); node 3131 tools/crm_mon.c fprintf(stream, "pending=\"%s\" ", node->details->pending ? "true" : "false"); node 3132 tools/crm_mon.c fprintf(stream, "unclean=\"%s\" ", node->details->unclean ? "true" : "false"); node 3133 tools/crm_mon.c fprintf(stream, "shutdown=\"%s\" ", node->details->shutdown ? "true" : "false"); node 3134 tools/crm_mon.c fprintf(stream, "expected_up=\"%s\" ", node->details->expected_up ? "true" : "false"); node 3135 tools/crm_mon.c fprintf(stream, "is_dc=\"%s\" ", node->details->is_dc ? "true" : "false"); node 3136 tools/crm_mon.c fprintf(stream, "resources_running=\"%d\" ", g_list_length(node->details->running_rsc)); node 3138 tools/crm_mon.c if (is_container_remote_node(node)) { node 3139 tools/crm_mon.c fprintf(stream, "id_as_resource=\"%s\" ", node->details->remote_rsc->container->id); node 3146 tools/crm_mon.c for (lpc2 = node->details->running_rsc; lpc2 != NULL; lpc2 = lpc2->next) { node 3239 tools/crm_mon.c node_t *node = (node_t *) gIter->data; node 3240 tools/crm_mon.c char *node_name = get_node_display_name(node); node 3243 tools/crm_mon.c if (node->details->standby_onfail && node->details->online) { node 3245 tools/crm_mon.c } else if (node->details->standby && node->details->online) { node 3247 tools/crm_mon.c } else if (node->details->standby) { node 3249 tools/crm_mon.c } else if (node->details->maintenance && node->details->online) { node 3251 tools/crm_mon.c } else if (node->details->maintenance) { node 3253 tools/crm_mon.c } else if (node->details->online) { node 3260 tools/crm_mon.c print_rscs_brief(node->details->running_rsc, NULL, print_opts | pe_print_rsconly, node 3268 tools/crm_mon.c for (lpc2 = node->details->running_rsc; lpc2 != NULL; lpc2 = lpc2->next) { node 3426 tools/crm_mon.c send_snmp_trap(const char *node, const char *rsc, const char *task, int target_rc, int rc, node 3466 tools/crm_mon.c add_snmp_field(trap_pdu, snmp_crm_oid_node, node); node 3599 tools/crm_mon.c send_custom_trap(const char *node, const char *rsc, const char *task, int target_rc, int rc, node 3617 tools/crm_mon.c setenv("CRM_notify_node", node, 1); node 3642 tools/crm_mon.c send_smtp_trap(const char *node, const char *rsc, const char *task, int target_rc, int rc, node 3659 tools/crm_mon.c if (node == NULL) { node 3660 tools/crm_mon.c node = "-"; node 3686 tools/crm_mon.c len += strlen(node); node 3693 tools/crm_mon.c rsc, node, desc); node 3700 tools/crm_mon.c "Completed operation %s for resource %s on %s\r\n", task, rsc, node); node 3703 tools/crm_mon.c "Operation %s for resource %s on %s failed: %s\r\n", task, rsc, node, desc); node 3807 tools/crm_mon.c const char *node = NULL; node 3845 tools/crm_mon.c node = crm_element_value(rsc_op, XML_LRM_ATTR_TARGET); node 3851 tools/crm_mon.c if(node == NULL && n) { node 3852 tools/crm_mon.c node = crm_element_value(n, XML_ATTR_UNAME); node 3855 tools/crm_mon.c if (node == NULL && n) { node 3856 tools/crm_mon.c node = ID(n); node 3859 tools/crm_mon.c if (node == NULL) { node 3860 tools/crm_mon.c node = node_id; node 3863 tools/crm_mon.c if (node == NULL) { node 3871 tools/crm_mon.c crm_notice("%s of %s on %s completed: %s", task, rsc, node, desc); node 3878 tools/crm_mon.c crm_warn("%s of %s on %s failed: %s", task, rsc, node, desc); node 3882 tools/crm_mon.c crm_warn("%s of %s on %s failed: %s", task, rsc, node, desc); node 3886 tools/crm_mon.c send_snmp_trap(node, rsc, task, target_rc, rc, status, desc); node 3889 tools/crm_mon.c send_smtp_trap(node, rsc, task, target_rc, rc, status, desc); node 3892 tools/crm_mon.c send_custom_trap(node, rsc, task, target_rc, rc, status, desc); node 3935 tools/crm_mon.c const char *node = NULL; node 3973 tools/crm_mon.c node = crm_element_value(state, XML_ATTR_UNAME); node 3974 tools/crm_mon.c if (node == NULL) { node 3975 tools/crm_mon.c node = ID(state); node 3977 tools/crm_mon.c handle_rsc_op(state, node); node 3984 tools/crm_mon.c node = crm_element_value(state, XML_ATTR_UNAME); node 3985 tools/crm_mon.c if (node == NULL) { node 3986 tools/crm_mon.c node = ID(state); node 3988 tools/crm_mon.c handle_rsc_op(state, node); node 3992 tools/crm_mon.c node = crm_element_value(match, XML_ATTR_UNAME); node 3993 tools/crm_mon.c if (node == NULL) { node 3994 tools/crm_mon.c node = ID(match); node 3996 tools/crm_mon.c handle_rsc_op(match, node); node 3999 tools/crm_mon.c node = ID(match); node 4000 tools/crm_mon.c handle_rsc_op(match, node); node 93 tools/crm_node.c xmlNode *node = NULL; node 102 tools/crm_node.c node = create_xml_node(NULL, XML_CIB_TAG_NODE); node 105 tools/crm_node.c crm_xml_add(node, XML_ATTR_UNAME, name); node 108 tools/crm_node.c crm_xml_set_id(node, "%u", id); node 109 tools/crm_node.c crm_xml_add(node_state, XML_ATTR_ID, ID(node)); node 115 tools/crm_node.c rc = cib->cmds->delete(cib, XML_CIB_TAG_NODES, node, cib_sync_call); node 129 tools/crm_node.c int tools_remove_node_cache(const char *node, const char *target); node 131 tools/crm_node.c int tools_remove_node_cache(const char *node, const char *target) node 167 tools/crm_node.c n = strtol(node, &endptr, 10); node 168 tools/crm_node.c if (errno != 0 || endptr == node || *endptr != '\0') { node 171 tools/crm_node.c name = strdup(node); node 176 tools/crm_node.c crm_trace("Removing %s aka. %s (%u) from the membership cache", name, node, n); node 234 tools/crm_node.c xmlNode *node = NULL; node 248 tools/crm_node.c for (node = __xml_first_child(msg); node != NULL; node = __xml_next(node)) { node 252 tools/crm_node.c peer->uname = (char*)crm_element_value_copy(node, "uname"); node 253 tools/crm_node.c peer->state = (char*)crm_element_value_copy(node, "state"); node 254 tools/crm_node.c crm_element_value_int(node, "id", (int*)&peer->id); node 447 tools/crm_node.c int (*ccm_api_is_my_nodeid) (const oc_ev_t * token, const oc_node_t * node) = node 586 tools/crm_node.c cman_node_t node; node 639 tools/crm_node.c memset(&node, 0, sizeof(cman_node_t)); node 640 tools/crm_node.c rc = cman_get_node(cman_handle, CMAN_NODEID_US, &node); node 645 tools/crm_node.c fprintf(stdout, "%u\n", node.cn_nodeid); node 683 tools/crm_node.c crm_node_t *node = value; node 685 tools/crm_node.c if (node->uname != NULL) { node 686 tools/crm_node.c *list = g_list_insert_sorted(*list, node, member_sort); node 724 tools/crm_node.c crm_node_t *node = (crm_node_t *) lpc->data; node 726 tools/crm_node.c fprintf(stdout, "%u %s %s\n", node->id, node->uname, node->state); node 736 tools/crm_node.c crm_node_t *node = (crm_node_t *) lpc->data; node 738 tools/crm_node.c if (node->uname && safe_str_eq(node->state, CRM_NODE_MEMBER)) { node 739 tools/crm_node.c fprintf(stdout, "%s ", node->uname); node 1104 tools/crm_resource.c const char *node = crm_element_value(xml_op, XML_ATTR_UNAME); node 1111 tools/crm_resource.c } else if(host_uname && safe_str_neq(host_uname, node)) { node 1122 tools/crm_resource.c task, rsc->id, resource_name, node); node 1123 tools/crm_resource.c rc = cli_resource_delete(crmd_channel, node, rsc, task, node 1164 tools/crm_resource.c node_t *node = pe_find_node(data_set.nodes, host_uname); node 1166 tools/crm_resource.c if (node && is_remote_node(node)) { node 1167 tools/crm_resource.c if (node->details->remote_rsc == NULL || node->details->remote_rsc->running_on == NULL) { node 1172 tools/crm_resource.c node = node->details->remote_rsc->running_on->data; node 1173 tools/crm_resource.c router_node = node->details->uname; node 101 tools/crm_resource.h node_t *node); node 223 tools/crm_resource_print.c node_t *node = (node_t *) lpc2->data; node 224 tools/crm_resource_print.c char *score = score2char(node->weight); node 227 tools/crm_resource_print.c prefix ? prefix : " ", 71 - offset, node->details->uname, score, cons->id); node 35 tools/crm_resource_runtime.c node_t *node = (node_t *) lpc->data; node 38 tools/crm_resource_runtime.c fprintf(stdout, "%s\n", node->details->uname); node 45 tools/crm_resource_runtime.c fprintf(stdout, "resource %s is running on: %s %s\n", rsc, node->details->uname, state); node 473 tools/crm_resource_runtime.c node_t *node = pe_find_node(data_set->nodes, host_uname); node 475 tools/crm_resource_runtime.c if (node && is_remote_node(node)) { node 476 tools/crm_resource_runtime.c if (node->details->remote_rsc == NULL || node->details->remote_rsc->running_on == NULL) { node 480 tools/crm_resource_runtime.c node = node->details->remote_rsc->running_on->data; node 481 tools/crm_resource_runtime.c router_node = node->details->uname; node 567 tools/crm_resource_runtime.c node_t *node = NULL; node 597 tools/crm_resource_runtime.c pe_node_t *node = NULL; node 600 tools/crm_resource_runtime.c while (g_hash_table_iter_next(&iter, NULL, (void**)&node)) { node 601 tools/crm_resource_runtime.c if(node->weight >= 0) { node 602 tools/crm_resource_runtime.c nodes = g_list_prepend(nodes, node); node 611 tools/crm_resource_runtime.c node = (node_t *) lpc->data; node 613 tools/crm_resource_runtime.c if (node->details->online) { node 614 tools/crm_resource_runtime.c cli_resource_delete(crmd_channel, node->details->uname, rsc, node 623 tools/crm_resource_runtime.c node = pe_find_node(data_set->nodes, host_uname); node 625 tools/crm_resource_runtime.c if (node == NULL) { node 631 tools/crm_resource_runtime.c if (!node->details->rsc_discovery_enabled) { node 668 tools/crm_resource_runtime.c if (is_remote_node(node)) { node 790 tools/crm_resource_runtime.c pe_node_t *node = (pe_node_t *) hIter->data; node 792 tools/crm_resource_runtime.c if(strcmp(host, node->details->uname) == 0) { node 795 tools/crm_resource_runtime.c } else if(strcmp(host, node->details->id) == 0) { node 1391 tools/crm_resource_runtime.c if (a->node) { node 1392 tools/crm_resource_runtime.c fprintf(stderr, "\ton %s", a->node->details->uname); node 1758 tools/crm_resource_runtime.c cli_resource_why_without_rsc_with_host(cib_t *cib_conn,GListPtr resources,node_t *node) node 1760 tools/crm_resource_runtime.c const char* host_uname = node->details->uname; node 1761 tools/crm_resource_runtime.c GListPtr allResources = node->details->allocated_rsc; node 1762 tools/crm_resource_runtime.c GListPtr activeResources = node->details->running_rsc; node 1797 tools/crm_resource_runtime.c node_t *node) node 1799 tools/crm_resource_runtime.c const char *host_uname = (node == NULL)? NULL : node->details->uname; node 1809 tools/crm_resource_runtime.c cli_resource_why_without_rsc_with_host(cib_conn, resources, node); node 96 tools/crm_simulate.c node_t *node = (node_t *) gIter->data; node 100 tools/crm_simulate.c if (is_container_remote_node(node)) { node 101 tools/crm_simulate.c node_name = crm_strdup_printf("%s:%s", node->details->uname, node->details->remote_rsc->container->id); node 103 tools/crm_simulate.c node_name = crm_strdup_printf("%s", node->details->uname); node 106 tools/crm_simulate.c if (node->details->unclean) { node 107 tools/crm_simulate.c if (node->details->online && node->details->unclean) { node 110 tools/crm_simulate.c } else if (node->details->pending) { node 117 tools/crm_simulate.c } else if (node->details->pending) { node 120 tools/crm_simulate.c } else if (node->details->standby_onfail && node->details->online) { node 123 tools/crm_simulate.c } else if (node->details->standby) { node 124 tools/crm_simulate.c if (node->details->online) { node 130 tools/crm_simulate.c } else if (node->details->maintenance) { node 131 tools/crm_simulate.c if (node->details->online) { node 137 tools/crm_simulate.c } else if (node->details->online) { node 138 tools/crm_simulate.c if (is_container_remote_node(node)) { node 140 tools/crm_simulate.c } else if (is_baremetal_remote_node(node)) { node 149 tools/crm_simulate.c if (is_baremetal_remote_node(node)) { node 151 tools/crm_simulate.c } else if (is_container_remote_node(node)) { node 160 tools/crm_simulate.c if (is_container_remote_node(node)) { node 162 tools/crm_simulate.c } else if (is_baremetal_remote_node(node)) { node 164 tools/crm_simulate.c } else if (safe_str_eq(node->details->uname, node->details->id)) { node 167 tools/crm_simulate.c printf("Node %s (%s): %s\n", node_name, node->details->id, node_mode); node 215 tools/crm_simulate.c if (action->node) { node 216 tools/crm_simulate.c action_host = action->node->details->uname; node 546 tools/crmadmin.c xmlNode *node = NULL; node 549 tools/crmadmin.c for (node = __xml_first_child(nodes); node != NULL; node = __xml_next(node)) { node 550 tools/crmadmin.c if (crm_str_eq((const char *)node->name, XML_CIB_TAG_NODE, TRUE)) { node 554 tools/crmadmin.c crm_element_value(node, XML_ATTR_UNAME), node 555 tools/crmadmin.c crm_element_value(node, XML_ATTR_ID)); node 558 tools/crmadmin.c crm_element_value(node, XML_ATTR_TYPE), node 559 tools/crmadmin.c crm_element_value(node, XML_ATTR_UNAME), node 560 tools/crmadmin.c crm_element_value(node, XML_ATTR_ID)); node 116 tools/fake_transition.c create_node_entry(cib_t * cib_conn, const char *node) node 119 tools/fake_transition.c int max = strlen(new_node_template) + strlen(node) + 1; node 124 tools/fake_transition.c snprintf(xpath, max, new_node_template, node); node 131 tools/fake_transition.c crm_xml_add(cib_object, XML_ATTR_ID, node); node 132 tools/fake_transition.c crm_xml_add(cib_object, XML_ATTR_UNAME, node); node 184 tools/fake_transition.c inject_node_state(cib_t * cib_conn, const char *node, const char *uuid) node 188 tools/fake_transition.c char *xpath = crm_strdup_printf(node_template, node); node 191 tools/fake_transition.c create_node_entry(cib_conn, node); node 209 tools/fake_transition.c query_node_uuid(cib_conn, node, &found_uuid, NULL); node 216 tools/fake_transition.c crm_xml_add(cib_object, XML_ATTR_UNAME, node); node 224 tools/fake_transition.c crm_trace("injecting node state for %s. rc is %d", node, rc); node 233 tools/fake_transition.c modify_node(cib_t * cib_conn, char *node, gboolean up) node 235 tools/fake_transition.c xmlNode *cib_node = inject_node_state(cib_conn, node, NULL); node 259 tools/fake_transition.c const char *node = crm_element_value(cib_node, XML_ATTR_UNAME); node 260 tools/fake_transition.c int max = strlen(rsc_template) + strlen(node) + strlen(resource) + 1; node 264 tools/fake_transition.c snprintf(xpath, max, rsc_template, node, resource); node 452 tools/fake_transition.c char *node = (char *)gIter->data; node 454 tools/fake_transition.c quiet_log(" + Bringing node %s online\n", node); node 455 tools/fake_transition.c cib_node = modify_node(cib, node, TRUE); node 466 tools/fake_transition.c char *node = (char *)gIter->data; node 468 tools/fake_transition.c quiet_log(" + Taking node %s offline\n", node); node 469 tools/fake_transition.c cib_node = modify_node(cib, node, FALSE); node 477 tools/fake_transition.c snprintf(xpath, STATUS_PATH_MAX, "//node_state[@uname='%s']/%s", node, XML_CIB_TAG_LRM); node 481 tools/fake_transition.c snprintf(xpath, STATUS_PATH_MAX, "//node_state[@uname='%s']/%s", node, node 489 tools/fake_transition.c char *node = (char *)gIter->data; node 491 tools/fake_transition.c quiet_log(" + Failing node %s\n", node); node 492 tools/fake_transition.c cib_node = modify_node(cib, node, TRUE); node 550 tools/fake_transition.c char *node = NULL; node 563 tools/fake_transition.c node = calloc(1, strlen(spec) + 1); node 564 tools/fake_transition.c rc = sscanf(spec, "%[^@]@%[^=]=%d", key, node, &outcome); node 568 tools/fake_transition.c free(node); node 582 tools/fake_transition.c cib_node = inject_node_state(cib, node, NULL); node 602 tools/fake_transition.c free(node); node 610 tools/fake_transition.c const char *node = crm_element_value(action->xml, XML_LRM_ATTR_TARGET); node 615 tools/fake_transition.c quiet_log(" * Pseudo action: %s%s%s\n", task, node ? " on " : "", node ? node : ""); node 640 tools/fake_transition.c char *node = crm_element_value_copy(action->xml, XML_LRM_ATTR_TARGET); node 646 tools/fake_transition.c crm_info("Skipping %s op for %s", operation, node); node 652 tools/fake_transition.c free(node); free(uuid); node 670 tools/fake_transition.c quiet_log(" * Resource action: %-15s %s on %s\n", resource, operation, node); node 689 tools/fake_transition.c cib_node = inject_node_state(fake_cib, node, uname_is_uuid ? node : uuid); node 698 tools/fake_transition.c node); node 700 tools/fake_transition.c quiet_log(" * Resource action: %-15s %s on %s\n", resource, op->op_type, node); node 708 tools/fake_transition.c snprintf(key, strlen(spec), "%s_%s_%d@%s=", resource, op->op_type, op->interval, node); node 739 tools/fake_transition.c free(node); free(uuid); node 749 tools/fake_transition.c const char *node = crm_element_value(action->xml, XML_LRM_ATTR_TARGET); node 756 tools/fake_transition.c quiet_log(" * Cluster action: %s for %s on %s\n", task, ID(rsc), node); node 758 tools/fake_transition.c quiet_log(" * Cluster action: %s on %s\n", task, node);