diff options
Diffstat (limited to 'tools/crm_resource_print.c')
| -rw-r--r-- | tools/crm_resource_print.c | 818 |
1 files changed, 818 insertions, 0 deletions
diff --git a/tools/crm_resource_print.c b/tools/crm_resource_print.c new file mode 100644 index 0000000..c1be53c --- /dev/null +++ b/tools/crm_resource_print.c @@ -0,0 +1,818 @@ +/* + * Copyright 2004-2023 the Pacemaker project contributors + * + * The version control history for this file may have further details. + * + * This source code is licensed under the GNU General Public License version 2 + * or later (GPLv2+) WITHOUT ANY WARRANTY. + */ + +#include <crm_internal.h> + +#include <stdint.h> + +#include <crm_resource.h> +#include <crm/common/lists_internal.h> +#include <crm/common/output.h> +#include <crm/common/results.h> + +#define cons_string(x) x?x:"NA" +static int +print_constraint(xmlNode *xml_obj, void *userdata) +{ + pe_working_set_t *data_set = (pe_working_set_t *) userdata; + pcmk__output_t *out = data_set->priv; + xmlNode *lifetime = NULL; + const char *id = crm_element_value(xml_obj, XML_ATTR_ID); + + if (id == NULL) { + return pcmk_rc_ok; + } + + // @COMPAT lifetime is deprecated + lifetime = first_named_child(xml_obj, "lifetime"); + if (pe_evaluate_rules(lifetime, NULL, data_set->now, NULL) == FALSE) { + return pcmk_rc_ok; + } + + if (!pcmk__str_eq(XML_CONS_TAG_RSC_DEPEND, crm_element_name(xml_obj), pcmk__str_casei)) { + return pcmk_rc_ok; + } + + out->info(out, "Constraint %s %s %s %s %s %s %s", + crm_element_name(xml_obj), + cons_string(crm_element_value(xml_obj, XML_ATTR_ID)), + cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_SOURCE)), + cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_TARGET)), + cons_string(crm_element_value(xml_obj, XML_RULE_ATTR_SCORE)), + cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_SOURCE_ROLE)), + cons_string(crm_element_value(xml_obj, XML_COLOC_ATTR_TARGET_ROLE))); + + return pcmk_rc_ok; +} + +void +cli_resource_print_cts_constraints(pe_working_set_t * data_set) +{ + pcmk__xe_foreach_child(pcmk_find_cib_element(data_set->input, XML_CIB_TAG_CONSTRAINTS), + NULL, print_constraint, data_set); +} + +void +cli_resource_print_cts(pe_resource_t * rsc, pcmk__output_t *out) +{ + const char *host = NULL; + bool needs_quorum = TRUE; + const char *rtype = crm_element_value(rsc->xml, XML_ATTR_TYPE); + const char *rprov = crm_element_value(rsc->xml, XML_AGENT_ATTR_PROVIDER); + const char *rclass = crm_element_value(rsc->xml, XML_AGENT_ATTR_CLASS); + pe_node_t *node = pe__current_node(rsc); + + if (pcmk__str_eq(rclass, PCMK_RESOURCE_CLASS_STONITH, pcmk__str_casei)) { + needs_quorum = FALSE; + } else { + // @TODO check requires in resource meta-data and rsc_defaults + } + + if (node != NULL) { + host = node->details->uname; + } + + out->info(out, "Resource: %s %s %s %s %s %s %s %s %d %lld %#.16llx", + crm_element_name(rsc->xml), rsc->id, + rsc->clone_name ? rsc->clone_name : rsc->id, rsc->parent ? rsc->parent->id : "NA", + rprov ? rprov : "NA", rclass, rtype, host ? host : "NA", needs_quorum, rsc->flags, + rsc->flags); + + g_list_foreach(rsc->children, (GFunc) cli_resource_print_cts, out); +} + +// \return Standard Pacemaker return code +int +cli_resource_print_operations(const char *rsc_id, const char *host_uname, + bool active, pe_working_set_t * data_set) +{ + pcmk__output_t *out = data_set->priv; + int rc = pcmk_rc_no_output; + GList *ops = find_operations(rsc_id, host_uname, active, data_set); + + if (!ops) { + return rc; + } + + out->begin_list(out, NULL, NULL, "Resource Operations"); + rc = pcmk_rc_ok; + + for (GList *lpc = ops; lpc != NULL; lpc = lpc->next) { + xmlNode *xml_op = (xmlNode *) lpc->data; + out->message(out, "node-and-op", data_set, xml_op); + } + + out->end_list(out); + return rc; +} + +// \return Standard Pacemaker return code +int +cli_resource_print(pe_resource_t *rsc, pe_working_set_t *data_set, bool expanded) +{ + pcmk__output_t *out = data_set->priv; + uint32_t show_opts = pcmk_show_pending; + GList *all = NULL; + + all = g_list_prepend(all, (gpointer) "*"); + + out->begin_list(out, NULL, NULL, "Resource Config"); + out->message(out, crm_map_element_name(rsc->xml), show_opts, rsc, all, all); + out->message(out, "resource-config", rsc, !expanded); + out->end_list(out); + + g_list_free(all); + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("attribute-list", "pe_resource_t *", "const char *", "const char *") +static int +attribute_list_default(pcmk__output_t *out, va_list args) { + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + const char *attr = va_arg(args, char *); + const char *value = va_arg(args, const char *); + + if (value != NULL) { + out->begin_list(out, NULL, NULL, "Attributes"); + out->list_item(out, attr, "%s", value); + out->end_list(out); + return pcmk_rc_ok; + } else { + out->err(out, "Attribute '%s' not found for '%s'", attr, rsc->id); + } + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("agent-status", "int", "const char *", "const char *", "const char *", + "const char *", "const char *", "crm_exit_t", "const char *") +static int +agent_status_default(pcmk__output_t *out, va_list args) { + int status = va_arg(args, int); + const char *action = va_arg(args, const char *); + const char *name = va_arg(args, const char *); + const char *class = va_arg(args, const char *); + const char *provider = va_arg(args, const char *); + const char *type = va_arg(args, const char *); + crm_exit_t rc = va_arg(args, crm_exit_t); + const char *exit_reason = va_arg(args, const char *); + + if (status == PCMK_EXEC_DONE) { + /* Operation <action> [for <resource>] (<class>[:<provider>]:<agent>) + * returned <exit-code> (<exit-description>[: <exit-reason>]) + */ + out->info(out, "Operation %s%s%s (%s%s%s:%s) returned %d (%s%s%s)", + action, + ((name == NULL)? "" : " for "), ((name == NULL)? "" : name), + class, + ((provider == NULL)? "" : ":"), + ((provider == NULL)? "" : provider), + type, (int) rc, services_ocf_exitcode_str((int) rc), + ((exit_reason == NULL)? "" : ": "), + ((exit_reason == NULL)? "" : exit_reason)); + } else { + /* Operation <action> [for <resource>] (<class>[:<provider>]:<agent>) + * could not be executed (<execution-status>[: <exit-reason>]) + */ + out->err(out, + "Operation %s%s%s (%s%s%s:%s) could not be executed (%s%s%s)", + action, + ((name == NULL)? "" : " for "), ((name == NULL)? "" : name), + class, + ((provider == NULL)? "" : ":"), + ((provider == NULL)? "" : provider), + type, pcmk_exec_status_str(status), + ((exit_reason == NULL)? "" : ": "), + ((exit_reason == NULL)? "" : exit_reason)); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("agent-status", "int", "const char *", "const char *", "const char *", + "const char *", "const char *", "crm_exit_t", "const char *") +static int +agent_status_xml(pcmk__output_t *out, va_list args) { + int status = va_arg(args, int); + const char *action G_GNUC_UNUSED = va_arg(args, const char *); + const char *name G_GNUC_UNUSED = va_arg(args, const char *); + const char *class G_GNUC_UNUSED = va_arg(args, const char *); + const char *provider G_GNUC_UNUSED = va_arg(args, const char *); + const char *type G_GNUC_UNUSED = va_arg(args, const char *); + crm_exit_t rc = va_arg(args, crm_exit_t); + const char *exit_reason = va_arg(args, const char *); + + char *exit_str = pcmk__itoa(rc); + char *status_str = pcmk__itoa(status); + + pcmk__output_create_xml_node(out, "agent-status", + "code", exit_str, + "message", services_ocf_exitcode_str((int) rc), + "execution_code", status_str, + "execution_message", pcmk_exec_status_str(status), + "reason", exit_reason, + NULL); + + free(exit_str); + free(status_str); + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("attribute-list", "pe_resource_t *", "const char *", "const char *") +static int +attribute_list_text(pcmk__output_t *out, va_list args) { + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + const char *attr = va_arg(args, char *); + const char *value = va_arg(args, const char *); + + if (value != NULL) { + pcmk__formatted_printf(out, "%s\n", value); + return pcmk_rc_ok; + } else { + out->err(out, "Attribute '%s' not found for '%s'", attr, rsc->id); + } + return pcmk_rc_ok; +} +PCMK__OUTPUT_ARGS("override", "const char *", "const char *", "const char *") +static int +override_default(pcmk__output_t *out, va_list args) { + const char *rsc_name = va_arg(args, const char *); + const char *name = va_arg(args, const char *); + const char *value = va_arg(args, const char *); + + if (rsc_name == NULL) { + out->list_item(out, NULL, "Overriding the cluster configuration with '%s' = '%s'", + name, value); + } else { + out->list_item(out, NULL, "Overriding the cluster configuration for '%s' with '%s' = '%s'", + rsc_name, name, value); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("override", "const char *", "const char *", "const char *") +static int +override_xml(pcmk__output_t *out, va_list args) { + const char *rsc_name = va_arg(args, const char *); + const char *name = va_arg(args, const char *); + const char *value = va_arg(args, const char *); + + xmlNodePtr node = pcmk__output_create_xml_node(out, "override", + "name", name, + "value", value, + NULL); + + if (rsc_name != NULL) { + crm_xml_add(node, "rsc", rsc_name); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("property-list", "pe_resource_t *", "const char *") +static int +property_list_default(pcmk__output_t *out, va_list args) { + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + const char *attr = va_arg(args, char *); + + const char *value = crm_element_value(rsc->xml, attr); + + if (value != NULL) { + out->begin_list(out, NULL, NULL, "Properties"); + out->list_item(out, attr, "%s", value); + out->end_list(out); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("property-list", "pe_resource_t *", "const char *") +static int +property_list_text(pcmk__output_t *out, va_list args) { + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + const char *attr = va_arg(args, const char *); + + const char *value = crm_element_value(rsc->xml, attr); + + if (value != NULL) { + pcmk__formatted_printf(out, "%s\n", value); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-agent-action", "int", "const char *", "const char *", + "const char *", "const char *", "const char *", "GHashTable *", + "crm_exit_t", "int", "const char *", "const char *", "const char *") +static int +resource_agent_action_default(pcmk__output_t *out, va_list args) { + int verbose = va_arg(args, int); + + const char *class = va_arg(args, const char *); + const char *provider = va_arg(args, const char *); + const char *type = va_arg(args, const char *); + const char *rsc_name = va_arg(args, const char *); + const char *action = va_arg(args, const char *); + GHashTable *overrides = va_arg(args, GHashTable *); + crm_exit_t rc = va_arg(args, crm_exit_t); + int status = va_arg(args, int); + const char *exit_reason = va_arg(args, const char *); + const char *stdout_data = va_arg(args, const char *); + const char *stderr_data = va_arg(args, const char *); + + if (overrides) { + GHashTableIter iter; + const char *name = NULL; + const char *value = NULL; + + out->begin_list(out, NULL, NULL, "overrides"); + + g_hash_table_iter_init(&iter, overrides); + while (g_hash_table_iter_next(&iter, (gpointer *) &name, (gpointer *) &value)) { + out->message(out, "override", rsc_name, name, value); + } + + out->end_list(out); + } + + out->message(out, "agent-status", status, action, rsc_name, class, provider, + type, rc, exit_reason); + + /* hide output for validate-all if not in verbose */ + if (verbose == 0 && pcmk__str_eq(action, "validate-all", pcmk__str_casei)) { + return pcmk_rc_ok; + } + + if (stdout_data || stderr_data) { + xmlNodePtr doc = NULL; + + if (stdout_data != NULL) { + doc = string2xml(stdout_data); + } + if (doc != NULL) { + out->output_xml(out, "command", stdout_data); + xmlFreeNode(doc); + } else { + out->subprocess_output(out, rc, stdout_data, stderr_data); + } + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-agent-action", "int", "const char *", "const char *", + "const char *", "const char *", "const char *", "GHashTable *", + "crm_exit_t", "int", "const char *", "const char *", "const char *") +static int +resource_agent_action_xml(pcmk__output_t *out, va_list args) { + int verbose G_GNUC_UNUSED = va_arg(args, int); + + const char *class = va_arg(args, const char *); + const char *provider = va_arg(args, const char *); + const char *type = va_arg(args, const char *); + const char *rsc_name = va_arg(args, const char *); + const char *action = va_arg(args, const char *); + GHashTable *overrides = va_arg(args, GHashTable *); + crm_exit_t rc = va_arg(args, crm_exit_t); + int status = va_arg(args, int); + const char *exit_reason = va_arg(args, const char *); + const char *stdout_data = va_arg(args, const char *); + const char *stderr_data = va_arg(args, const char *); + + xmlNodePtr node = pcmk__output_xml_create_parent(out, "resource-agent-action", + "action", action, + "class", class, + "type", type, + NULL); + + if (rsc_name) { + crm_xml_add(node, "rsc", rsc_name); + } + + if (provider) { + crm_xml_add(node, "provider", provider); + } + + if (overrides) { + GHashTableIter iter; + const char *name = NULL; + const char *value = NULL; + + out->begin_list(out, NULL, NULL, "overrides"); + + g_hash_table_iter_init(&iter, overrides); + while (g_hash_table_iter_next(&iter, (gpointer *) &name, (gpointer *) &value)) { + out->message(out, "override", rsc_name, name, value); + } + + out->end_list(out); + } + + out->message(out, "agent-status", status, action, rsc_name, class, provider, + type, rc, exit_reason); + + if (stdout_data || stderr_data) { + xmlNodePtr doc = NULL; + + if (stdout_data != NULL) { + doc = string2xml(stdout_data); + } + if (doc != NULL) { + out->output_xml(out, "command", stdout_data); + xmlFreeNode(doc); + } else { + out->subprocess_output(out, rc, stdout_data, stderr_data); + } + } + + pcmk__output_xml_pop_parent(out); + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-check-list", "resource_checks_t *") +static int +resource_check_list_default(pcmk__output_t *out, va_list args) { + resource_checks_t *checks = va_arg(args, resource_checks_t *); + + const pe_resource_t *parent = pe__const_top_resource(checks->rsc, false); + + if (checks->flags == 0) { + return pcmk_rc_no_output; + } + + out->begin_list(out, NULL, NULL, "Resource Checks"); + + if (pcmk_is_set(checks->flags, rsc_remain_stopped)) { + out->list_item(out, "check", "Configuration specifies '%s' should remain stopped", + parent->id); + } + + if (pcmk_is_set(checks->flags, rsc_unpromotable)) { + out->list_item(out, "check", "Configuration specifies '%s' should not be promoted", + parent->id); + } + + if (pcmk_is_set(checks->flags, rsc_unmanaged)) { + out->list_item(out, "check", "Configuration prevents cluster from stopping or starting unmanaged '%s'", + parent->id); + } + + if (pcmk_is_set(checks->flags, rsc_locked)) { + out->list_item(out, "check", "'%s' is locked to node %s due to shutdown", + parent->id, checks->lock_node); + } + + if (pcmk_is_set(checks->flags, rsc_node_health)) { + out->list_item(out, "check", + "'%s' cannot run on unhealthy nodes due to " + PCMK__OPT_NODE_HEALTH_STRATEGY "='%s'", + parent->id, + pe_pref(checks->rsc->cluster->config_hash, + PCMK__OPT_NODE_HEALTH_STRATEGY)); + } + + out->end_list(out); + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-check-list", "resource_checks_t *") +static int +resource_check_list_xml(pcmk__output_t *out, va_list args) { + resource_checks_t *checks = va_arg(args, resource_checks_t *); + + const pe_resource_t *parent = pe__const_top_resource(checks->rsc, false); + + xmlNodePtr node = pcmk__output_create_xml_node(out, "check", + "id", parent->id, + NULL); + + if (pcmk_is_set(checks->flags, rsc_remain_stopped)) { + pcmk__xe_set_bool_attr(node, "remain_stopped", true); + } + + if (pcmk_is_set(checks->flags, rsc_unpromotable)) { + pcmk__xe_set_bool_attr(node, "promotable", false); + } + + if (pcmk_is_set(checks->flags, rsc_unmanaged)) { + pcmk__xe_set_bool_attr(node, "unmanaged", true); + } + + if (pcmk_is_set(checks->flags, rsc_locked)) { + crm_xml_add(node, "locked-to", checks->lock_node); + } + + if (pcmk_is_set(checks->flags, rsc_node_health)) { + pcmk__xe_set_bool_attr(node, "unhealthy", true); + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-search-list", "GList *", "const char *") +static int +resource_search_list_default(pcmk__output_t *out, va_list args) +{ + GList *nodes = va_arg(args, GList *); + const char *requested_name = va_arg(args, const char *); + + bool printed = false; + int rc = pcmk_rc_no_output; + + if (!out->is_quiet(out) && nodes == NULL) { + out->err(out, "resource %s is NOT running", requested_name); + return rc; + } + + for (GList *lpc = nodes; lpc != NULL; lpc = lpc->next) { + node_info_t *ni = (node_info_t *) lpc->data; + + if (!printed) { + out->begin_list(out, NULL, NULL, "Nodes"); + printed = true; + rc = pcmk_rc_ok; + } + + if (out->is_quiet(out)) { + out->list_item(out, "node", "%s", ni->node_name); + } else { + const char *role_text = ""; + + if (ni->promoted) { +#ifdef PCMK__COMPAT_2_0 + role_text = " " RSC_ROLE_PROMOTED_LEGACY_S; +#else + role_text = " " RSC_ROLE_PROMOTED_S; +#endif + } + out->list_item(out, "node", "resource %s is running on: %s%s", + requested_name, ni->node_name, role_text); + } + } + + if (printed) { + out->end_list(out); + } + + return rc; +} + +PCMK__OUTPUT_ARGS("resource-search-list", "GList *", "const char *") +static int +resource_search_list_xml(pcmk__output_t *out, va_list args) +{ + GList *nodes = va_arg(args, GList *); + const char *requested_name = va_arg(args, const char *); + + pcmk__output_xml_create_parent(out, "nodes", + "resource", requested_name, + NULL); + + for (GList *lpc = nodes; lpc != NULL; lpc = lpc->next) { + node_info_t *ni = (node_info_t *) lpc->data; + xmlNodePtr sub_node = pcmk__output_create_xml_text_node(out, "node", ni->node_name); + + if (ni->promoted) { + crm_xml_add(sub_node, "state", "promoted"); + } + } + + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-reasons-list", "GList *", "pe_resource_t *", + "pe_node_t *") +static int +resource_reasons_list_default(pcmk__output_t *out, va_list args) +{ + GList *resources = va_arg(args, GList *); + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + pe_node_t *node = va_arg(args, pe_node_t *); + + const char *host_uname = (node == NULL)? NULL : node->details->uname; + + out->begin_list(out, NULL, NULL, "Resource Reasons"); + + if ((rsc == NULL) && (host_uname == NULL)) { + GList *lpc = NULL; + GList *hosts = NULL; + + for (lpc = resources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + rsc->fns->location(rsc, &hosts, TRUE); + + if (hosts == NULL) { + out->list_item(out, "reason", "Resource %s is not running", rsc->id); + } else { + out->list_item(out, "reason", "Resource %s is running", rsc->id); + } + + cli_resource_check(out, rsc, NULL); + g_list_free(hosts); + hosts = NULL; + } + + } else if ((rsc != NULL) && (host_uname != NULL)) { + if (resource_is_running_on(rsc, host_uname)) { + out->list_item(out, "reason", "Resource %s is running on host %s", + rsc->id, host_uname); + } else { + out->list_item(out, "reason", "Resource %s is not running on host %s", + rsc->id, host_uname); + } + + cli_resource_check(out, rsc, node); + + } else if ((rsc == NULL) && (host_uname != NULL)) { + const char* host_uname = node->details->uname; + GList *allResources = node->details->allocated_rsc; + GList *activeResources = node->details->running_rsc; + GList *unactiveResources = pcmk__subtract_lists(allResources, activeResources, (GCompareFunc) strcmp); + GList *lpc = NULL; + + for (lpc = activeResources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + out->list_item(out, "reason", "Resource %s is running on host %s", + rsc->id, host_uname); + cli_resource_check(out, rsc, node); + } + + for(lpc = unactiveResources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + out->list_item(out, "reason", "Resource %s is assigned to host %s but not running", + rsc->id, host_uname); + cli_resource_check(out, rsc, node); + } + + g_list_free(allResources); + g_list_free(activeResources); + g_list_free(unactiveResources); + + } else if ((rsc != NULL) && (host_uname == NULL)) { + GList *hosts = NULL; + + rsc->fns->location(rsc, &hosts, TRUE); + out->list_item(out, "reason", "Resource %s is %srunning", + rsc->id, (hosts? "" : "not ")); + cli_resource_check(out, rsc, NULL); + g_list_free(hosts); + } + + out->end_list(out); + return pcmk_rc_ok; +} + +PCMK__OUTPUT_ARGS("resource-reasons-list", "GList *", "pe_resource_t *", + "pe_node_t *") +static int +resource_reasons_list_xml(pcmk__output_t *out, va_list args) +{ + GList *resources = va_arg(args, GList *); + pe_resource_t *rsc = va_arg(args, pe_resource_t *); + pe_node_t *node = va_arg(args, pe_node_t *); + + const char *host_uname = (node == NULL)? NULL : node->details->uname; + + xmlNodePtr xml_node = pcmk__output_xml_create_parent(out, "reason", NULL); + + if ((rsc == NULL) && (host_uname == NULL)) { + GList *lpc = NULL; + GList *hosts = NULL; + + pcmk__output_xml_create_parent(out, "resources", NULL); + + for (lpc = resources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + + rsc->fns->location(rsc, &hosts, TRUE); + + pcmk__output_xml_create_parent(out, "resource", + "id", rsc->id, + "running", pcmk__btoa(hosts != NULL), + NULL); + + cli_resource_check(out, rsc, NULL); + pcmk__output_xml_pop_parent(out); + g_list_free(hosts); + hosts = NULL; + } + + pcmk__output_xml_pop_parent(out); + + } else if ((rsc != NULL) && (host_uname != NULL)) { + if (resource_is_running_on(rsc, host_uname)) { + crm_xml_add(xml_node, "running_on", host_uname); + } + + cli_resource_check(out, rsc, node); + + } else if ((rsc == NULL) && (host_uname != NULL)) { + const char* host_uname = node->details->uname; + GList *allResources = node->details->allocated_rsc; + GList *activeResources = node->details->running_rsc; + GList *unactiveResources = pcmk__subtract_lists(allResources, activeResources, (GCompareFunc) strcmp); + GList *lpc = NULL; + + pcmk__output_xml_create_parent(out, "resources", NULL); + + for (lpc = activeResources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + + pcmk__output_xml_create_parent(out, "resource", + "id", rsc->id, + "running", "true", + "host", host_uname, + NULL); + + cli_resource_check(out, rsc, node); + pcmk__output_xml_pop_parent(out); + } + + for(lpc = unactiveResources; lpc != NULL; lpc = lpc->next) { + pe_resource_t *rsc = (pe_resource_t *) lpc->data; + + pcmk__output_xml_create_parent(out, "resource", + "id", rsc->id, + "running", "false", + "host", host_uname, + NULL); + + cli_resource_check(out, rsc, node); + pcmk__output_xml_pop_parent(out); + } + + pcmk__output_xml_pop_parent(out); + g_list_free(allResources); + g_list_free(activeResources); + g_list_free(unactiveResources); + + } else if ((rsc != NULL) && (host_uname == NULL)) { + GList *hosts = NULL; + + rsc->fns->location(rsc, &hosts, TRUE); + crm_xml_add(xml_node, "running", pcmk__btoa(hosts != NULL)); + cli_resource_check(out, rsc, NULL); + g_list_free(hosts); + } + + return pcmk_rc_ok; +} + +static void +add_resource_name(pe_resource_t *rsc, pcmk__output_t *out) { + if (rsc->children == NULL) { + out->list_item(out, "resource", "%s", rsc->id); + } else { + g_list_foreach(rsc->children, (GFunc) add_resource_name, out); + } +} + +PCMK__OUTPUT_ARGS("resource-names-list", "GList *") +static int +resource_names(pcmk__output_t *out, va_list args) { + GList *resources = va_arg(args, GList *); + + if (resources == NULL) { + out->err(out, "NO resources configured\n"); + return pcmk_rc_no_output; + } + + out->begin_list(out, NULL, NULL, "Resource Names"); + g_list_foreach(resources, (GFunc) add_resource_name, out); + out->end_list(out); + return pcmk_rc_ok; +} + +static pcmk__message_entry_t fmt_functions[] = { + { "agent-status", "default", agent_status_default }, + { "agent-status", "xml", agent_status_xml }, + { "attribute-list", "default", attribute_list_default }, + { "attribute-list", "text", attribute_list_text }, + { "override", "default", override_default }, + { "override", "xml", override_xml }, + { "property-list", "default", property_list_default }, + { "property-list", "text", property_list_text }, + { "resource-agent-action", "default", resource_agent_action_default }, + { "resource-agent-action", "xml", resource_agent_action_xml }, + { "resource-check-list", "default", resource_check_list_default }, + { "resource-check-list", "xml", resource_check_list_xml }, + { "resource-search-list", "default", resource_search_list_default }, + { "resource-search-list", "xml", resource_search_list_xml }, + { "resource-reasons-list", "default", resource_reasons_list_default }, + { "resource-reasons-list", "xml", resource_reasons_list_xml }, + { "resource-names-list", "default", resource_names }, + + { NULL, NULL, NULL } +}; + +void +crm_resource_register_messages(pcmk__output_t *out) { + pcmk__register_messages(out, fmt_functions); +} |