This source file includes following definitions.
- print_constraint
- cli_resource_print_cts_constraints
- cli_resource_print_cts
- cli_resource_print_operations
- cli_resource_print
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- PCMK__OUTPUT_ARGS
- add_resource_name
- PCMK__OUTPUT_ARGS
- crm_resource_register_messages
1
2
3
4
5
6
7
8
9
10 #include <crm_internal.h>
11
12 #include <stdint.h>
13
14 #include <crm_resource.h>
15 #include <crm/common/lists_internal.h>
16 #include <crm/common/output.h>
17 #include <crm/common/results.h>
18
19 #define cons_string(x) x?x:"NA"
20 static int
21 print_constraint(xmlNode *xml_obj, void *userdata)
22 {
23 pcmk_scheduler_t *scheduler = (pcmk_scheduler_t *) userdata;
24 pcmk__output_t *out = scheduler->priv->out;
25 const char *id = crm_element_value(xml_obj, PCMK_XA_ID);
26
27 if (id == NULL) {
28 return pcmk_rc_ok;
29 }
30
31 if (!pcmk__xe_is(xml_obj, PCMK_XE_RSC_COLOCATION)) {
32 return pcmk_rc_ok;
33 }
34
35 out->info(out, "Constraint %s %s %s %s %s %s %s",
36 xml_obj->name,
37 cons_string(crm_element_value(xml_obj, PCMK_XA_ID)),
38 cons_string(crm_element_value(xml_obj, PCMK_XA_RSC)),
39 cons_string(crm_element_value(xml_obj, PCMK_XA_WITH_RSC)),
40 cons_string(crm_element_value(xml_obj, PCMK_XA_SCORE)),
41 cons_string(crm_element_value(xml_obj, PCMK_XA_RSC_ROLE)),
42 cons_string(crm_element_value(xml_obj, PCMK_XA_WITH_RSC_ROLE)));
43
44 return pcmk_rc_ok;
45 }
46
47 void
48 cli_resource_print_cts_constraints(pcmk_scheduler_t *scheduler)
49 {
50 pcmk__xe_foreach_child(pcmk_find_cib_element(scheduler->input,
51 PCMK_XE_CONSTRAINTS),
52 NULL, print_constraint, scheduler);
53 }
54
55 void
56 cli_resource_print_cts(pcmk_resource_t *rsc, pcmk__output_t *out)
57 {
58 const char *host = NULL;
59 bool needs_quorum = TRUE;
60 const char *rtype = crm_element_value(rsc->priv->xml, PCMK_XA_TYPE);
61 const char *rprov = crm_element_value(rsc->priv->xml, PCMK_XA_PROVIDER);
62 const char *rclass = crm_element_value(rsc->priv->xml, PCMK_XA_CLASS);
63 pcmk_node_t *node = pcmk__current_node(rsc);
64
65 if (pcmk_is_set(rsc->flags, pcmk__rsc_fence_device)) {
66 needs_quorum = FALSE;
67 } else {
68
69 }
70
71 if (node != NULL) {
72 host = node->priv->name;
73 }
74
75 out->info(out, "Resource: %s %s %s %s %s %s %s %s %d %lld %#.16llx",
76 rsc->priv->xml->name, rsc->id,
77 pcmk__s(rsc->priv->history_id, rsc->id),
78 ((rsc->priv->parent == NULL)? "NA" : rsc->priv->parent->id),
79 rprov ? rprov : "NA", rclass, rtype, host ? host : "NA", needs_quorum, rsc->flags,
80 rsc->flags);
81
82 g_list_foreach(rsc->priv->children, (GFunc) cli_resource_print_cts, out);
83 }
84
85
86 int
87 cli_resource_print_operations(const char *rsc_id, const char *host_uname,
88 bool active, pcmk_scheduler_t *scheduler)
89 {
90 pcmk__output_t *out = scheduler->priv->out;
91 int rc = pcmk_rc_no_output;
92 GList *ops = find_operations(rsc_id, host_uname, active, scheduler);
93
94 if (!ops) {
95 return rc;
96 }
97
98 out->begin_list(out, NULL, NULL, "Resource Operations");
99 rc = pcmk_rc_ok;
100
101 for (GList *lpc = ops; lpc != NULL; lpc = lpc->next) {
102 xmlNode *xml_op = (xmlNode *) lpc->data;
103 out->message(out, "node-and-op", scheduler, xml_op);
104 }
105
106 out->end_list(out);
107 return rc;
108 }
109
110
111 int
112 cli_resource_print(pcmk_resource_t *rsc, bool expanded)
113 {
114 pcmk_scheduler_t *scheduler = NULL;
115 pcmk__output_t *out = NULL;
116 GList *all = NULL;
117
118 pcmk__assert(rsc != NULL);
119
120 scheduler = rsc->priv->scheduler;
121 out = scheduler->priv->out;
122 all = g_list_prepend(all, (gpointer) "*");
123
124 out->begin_list(out, NULL, NULL, "Resource Config");
125 out->message(out, (const char *) rsc->priv->xml->name, pcmk_show_pending,
126 rsc, all, all);
127 out->message(out, "resource-config", rsc, !expanded);
128 out->end_list(out);
129
130 g_list_free(all);
131 return pcmk_rc_ok;
132 }
133
134 PCMK__OUTPUT_ARGS("attribute-changed", "attr_update_data_t *")
135 static int
136 attribute_changed_default(pcmk__output_t *out, va_list args)
137 {
138 attr_update_data_t *ud = va_arg(args, attr_update_data_t *);
139
140 out->info(out, "Set '%s' option: "
141 PCMK_XA_ID "=%s%s%s%s%s value=%s",
142 ud->given_rsc_id, ud->found_attr_id,
143 ((ud->attr_set_id == NULL)? "" : " " PCMK__XA_SET "="),
144 pcmk__s(ud->attr_set_id, ""),
145 ((ud->attr_name == NULL)? "" : " " PCMK_XA_NAME "="),
146 pcmk__s(ud->attr_name, ""), ud->attr_value);
147
148 return pcmk_rc_ok;
149 }
150
151 PCMK__OUTPUT_ARGS("attribute-changed", "attr_update_data_t *")
152 static int
153 attribute_changed_xml(pcmk__output_t *out, va_list args)
154 {
155 attr_update_data_t *ud = va_arg(args, attr_update_data_t *);
156
157 pcmk__output_xml_create_parent(out,
158 (const char *) ud->rsc->priv->xml->name,
159 PCMK_XA_ID, ud->rsc->id,
160 NULL);
161
162 pcmk__output_xml_create_parent(out, ud->attr_set_type,
163 PCMK_XA_ID, ud->attr_set_id,
164 NULL);
165
166 pcmk__output_create_xml_node(out, PCMK_XE_NVPAIR,
167 PCMK_XA_ID, ud->found_attr_id,
168 PCMK_XA_VALUE, ud->attr_value,
169 PCMK_XA_NAME, ud->attr_name,
170 NULL);
171
172 pcmk__output_xml_pop_parent(out);
173 pcmk__output_xml_pop_parent(out);
174
175 return pcmk_rc_ok;
176 }
177
178 PCMK__OUTPUT_ARGS("attribute-changed-list", "GList *")
179 static int
180 attribute_changed_list_default(pcmk__output_t *out, va_list args)
181 {
182 GList *results = va_arg(args, GList *);
183
184 if (results == NULL) {
185 return pcmk_rc_no_output;
186 }
187
188 for (GList *iter = results; iter != NULL; iter = iter->next) {
189 attr_update_data_t *ud = iter->data;
190 out->message(out, "attribute-changed", ud);
191 }
192
193 return pcmk_rc_ok;
194 }
195
196 PCMK__OUTPUT_ARGS("attribute-changed-list", "GList *")
197 static int
198 attribute_changed_list_xml(pcmk__output_t *out, va_list args)
199 {
200 GList *results = va_arg(args, GList *);
201
202 if (results == NULL) {
203 return pcmk_rc_no_output;
204 }
205
206 pcmk__output_xml_create_parent(out, PCMK__XE_RESOURCE_SETTINGS, NULL);
207
208 for (GList *iter = results; iter != NULL; iter = iter->next) {
209 attr_update_data_t *ud = iter->data;
210 out->message(out, "attribute-changed", ud);
211 }
212
213 pcmk__output_xml_pop_parent(out);
214 return pcmk_rc_ok;
215 }
216
217 PCMK__OUTPUT_ARGS("attribute-list", "pcmk_resource_t *", "const char *",
218 "const char *")
219 static int
220 attribute_list_default(pcmk__output_t *out, va_list args) {
221 pcmk_resource_t *rsc = va_arg(args, pcmk_resource_t *);
222 const char *attr = va_arg(args, char *);
223 const char *value = va_arg(args, const char *);
224
225 if (value != NULL) {
226 out->begin_list(out, NULL, NULL, "Attributes");
227 out->list_item(out, attr, "%s", value);
228 out->end_list(out);
229 return pcmk_rc_ok;
230 } else {
231 out->err(out, "Attribute '%s' not found for '%s'", attr, rsc->id);
232 }
233 return pcmk_rc_ok;
234 }
235
236 PCMK__OUTPUT_ARGS("agent-status", "int", "const char *", "const char *", "const char *",
237 "const char *", "const char *", "crm_exit_t", "const char *")
238 static int
239 agent_status_default(pcmk__output_t *out, va_list args) {
240 int status = va_arg(args, int);
241 const char *action = va_arg(args, const char *);
242 const char *name = va_arg(args, const char *);
243 const char *class = va_arg(args, const char *);
244 const char *provider = va_arg(args, const char *);
245 const char *type = va_arg(args, const char *);
246 crm_exit_t rc = va_arg(args, crm_exit_t);
247 const char *exit_reason = va_arg(args, const char *);
248
249 if (status == PCMK_EXEC_DONE) {
250
251
252
253 out->info(out, "Operation %s%s%s (%s%s%s:%s) returned %d (%s%s%s)",
254 action,
255 ((name == NULL)? "" : " for "), ((name == NULL)? "" : name),
256 class,
257 ((provider == NULL)? "" : ":"),
258 ((provider == NULL)? "" : provider),
259 type, (int) rc, crm_exit_str(rc),
260 ((exit_reason == NULL)? "" : ": "),
261 ((exit_reason == NULL)? "" : exit_reason));
262 } else {
263
264
265
266 out->err(out,
267 "Operation %s%s%s (%s%s%s:%s) could not be executed (%s%s%s)",
268 action,
269 ((name == NULL)? "" : " for "), ((name == NULL)? "" : name),
270 class,
271 ((provider == NULL)? "" : ":"),
272 ((provider == NULL)? "" : provider),
273 type, pcmk_exec_status_str(status),
274 ((exit_reason == NULL)? "" : ": "),
275 ((exit_reason == NULL)? "" : exit_reason));
276 }
277
278 return pcmk_rc_ok;
279 }
280
281 PCMK__OUTPUT_ARGS("agent-status", "int", "const char *", "const char *", "const char *",
282 "const char *", "const char *", "crm_exit_t", "const char *")
283 static int
284 agent_status_xml(pcmk__output_t *out, va_list args) {
285 int status = va_arg(args, int);
286 const char *action G_GNUC_UNUSED = va_arg(args, const char *);
287 const char *name G_GNUC_UNUSED = va_arg(args, const char *);
288 const char *class G_GNUC_UNUSED = va_arg(args, const char *);
289 const char *provider G_GNUC_UNUSED = va_arg(args, const char *);
290 const char *type G_GNUC_UNUSED = va_arg(args, const char *);
291 crm_exit_t rc = va_arg(args, crm_exit_t);
292 const char *exit_reason = va_arg(args, const char *);
293
294 char *exit_s = pcmk__itoa(rc);
295 const char *message = crm_exit_str(rc);
296 char *status_s = pcmk__itoa(status);
297 const char *execution_message = pcmk_exec_status_str(status);
298
299 pcmk__output_create_xml_node(out, PCMK_XE_AGENT_STATUS,
300 PCMK_XA_CODE, exit_s,
301 PCMK_XA_MESSAGE, message,
302 PCMK_XA_EXECUTION_CODE, status_s,
303 PCMK_XA_EXECUTION_MESSAGE, execution_message,
304 PCMK_XA_REASON, exit_reason,
305 NULL);
306
307 free(exit_s);
308 free(status_s);
309
310 return pcmk_rc_ok;
311 }
312
313 PCMK__OUTPUT_ARGS("attribute-list", "pcmk_resource_t *", "const char *",
314 "const char *")
315 static int
316 attribute_list_text(pcmk__output_t *out, va_list args) {
317 pcmk_resource_t *rsc = va_arg(args, pcmk_resource_t *);
318 const char *attr = va_arg(args, char *);
319 const char *value = va_arg(args, const char *);
320
321 if (value != NULL) {
322 pcmk__formatted_printf(out, "%s\n", value);
323 return pcmk_rc_ok;
324 } else {
325 out->err(out, "Attribute '%s' not found for '%s'", attr, rsc->id);
326 }
327 return pcmk_rc_ok;
328 }
329 PCMK__OUTPUT_ARGS("override", "const char *", "const char *", "const char *")
330 static int
331 override_default(pcmk__output_t *out, va_list args) {
332 const char *rsc_name = va_arg(args, const char *);
333 const char *name = va_arg(args, const char *);
334 const char *value = va_arg(args, const char *);
335
336 if (rsc_name == NULL) {
337 out->list_item(out, NULL, "Overriding the cluster configuration with '%s' = '%s'",
338 name, value);
339 } else {
340 out->list_item(out, NULL, "Overriding the cluster configuration for '%s' with '%s' = '%s'",
341 rsc_name, name, value);
342 }
343
344 return pcmk_rc_ok;
345 }
346
347 PCMK__OUTPUT_ARGS("override", "const char *", "const char *", "const char *")
348 static int
349 override_xml(pcmk__output_t *out, va_list args) {
350 const char *rsc_name = va_arg(args, const char *);
351 const char *name = va_arg(args, const char *);
352 const char *value = va_arg(args, const char *);
353
354 xmlNodePtr node = pcmk__output_create_xml_node(out, PCMK_XE_OVERRIDE,
355 PCMK_XA_NAME, name,
356 PCMK_XA_VALUE, value,
357 NULL);
358
359 if (rsc_name != NULL) {
360 crm_xml_add(node, PCMK_XA_RSC, rsc_name);
361 }
362
363 return pcmk_rc_ok;
364 }
365
366
367 PCMK__OUTPUT_ARGS("resource-agent-action", "int", "const char *", "const char *",
368 "const char *", "const char *", "const char *", "GHashTable *",
369 "crm_exit_t", "int", "const char *", "const char *", "const char *")
370 static int
371 resource_agent_action_default(pcmk__output_t *out, va_list args) {
372 int verbose = va_arg(args, int);
373
374 const char *class = va_arg(args, const char *);
375 const char *provider = va_arg(args, const char *);
376 const char *type = va_arg(args, const char *);
377 const char *rsc_name = va_arg(args, const char *);
378 const char *action = va_arg(args, const char *);
379 GHashTable *overrides = va_arg(args, GHashTable *);
380 crm_exit_t rc = va_arg(args, crm_exit_t);
381 int status = va_arg(args, int);
382 const char *exit_reason = va_arg(args, const char *);
383 const char *stdout_data = va_arg(args, const char *);
384 const char *stderr_data = va_arg(args, const char *);
385
386 if (overrides) {
387 GHashTableIter iter;
388 const char *name = NULL;
389 const char *value = NULL;
390
391 out->begin_list(out, NULL, NULL, PCMK_XE_OVERRIDES);
392
393 g_hash_table_iter_init(&iter, overrides);
394 while (g_hash_table_iter_next(&iter, (gpointer *) &name, (gpointer *) &value)) {
395 out->message(out, "override", rsc_name, name, value);
396 }
397
398 out->end_list(out);
399 }
400
401 out->message(out, "agent-status", status, action, rsc_name, class, provider,
402 type, rc, exit_reason);
403
404
405 if ((verbose == 0)
406 && pcmk__str_eq(action, PCMK_ACTION_VALIDATE_ALL, pcmk__str_casei)) {
407 return pcmk_rc_ok;
408 }
409
410 if (stdout_data || stderr_data) {
411 xmlNodePtr doc = NULL;
412
413 if (stdout_data != NULL) {
414 doc = pcmk__xml_parse(stdout_data);
415 }
416 if (doc != NULL) {
417 out->output_xml(out, PCMK_XE_COMMAND, stdout_data);
418 pcmk__xml_free(doc);
419 } else {
420 out->subprocess_output(out, rc, stdout_data, stderr_data);
421 }
422 }
423
424 return pcmk_rc_ok;
425 }
426
427
428 PCMK__OUTPUT_ARGS("resource-agent-action", "int", "const char *", "const char *",
429 "const char *", "const char *", "const char *", "GHashTable *",
430 "crm_exit_t", "int", "const char *", "const char *", "const char *")
431 static int
432 resource_agent_action_xml(pcmk__output_t *out, va_list args) {
433 int verbose G_GNUC_UNUSED = va_arg(args, int);
434
435 const char *class = va_arg(args, const char *);
436 const char *provider = va_arg(args, const char *);
437 const char *type = va_arg(args, const char *);
438 const char *rsc_name = va_arg(args, const char *);
439 const char *action = va_arg(args, const char *);
440 GHashTable *overrides = va_arg(args, GHashTable *);
441 crm_exit_t rc = va_arg(args, crm_exit_t);
442 int status = va_arg(args, int);
443 const char *exit_reason = va_arg(args, const char *);
444 const char *stdout_data = va_arg(args, const char *);
445 const char *stderr_data = va_arg(args, const char *);
446
447 xmlNodePtr node = NULL;
448
449 node = pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCE_AGENT_ACTION,
450 PCMK_XA_ACTION, action,
451 PCMK_XA_CLASS, class,
452 PCMK_XA_TYPE, type,
453 NULL);
454
455 if (rsc_name) {
456 crm_xml_add(node, PCMK_XA_RSC, rsc_name);
457 }
458
459 crm_xml_add(node, PCMK_XA_PROVIDER, provider);
460
461 if (overrides) {
462 GHashTableIter iter;
463 const char *name = NULL;
464 const char *value = NULL;
465
466 out->begin_list(out, NULL, NULL, PCMK_XE_OVERRIDES);
467
468 g_hash_table_iter_init(&iter, overrides);
469 while (g_hash_table_iter_next(&iter, (gpointer *) &name, (gpointer *) &value)) {
470 out->message(out, "override", rsc_name, name, value);
471 }
472
473 out->end_list(out);
474 }
475
476 out->message(out, "agent-status", status, action, rsc_name, class, provider,
477 type, rc, exit_reason);
478
479 if (stdout_data || stderr_data) {
480 xmlNodePtr doc = NULL;
481
482 if (stdout_data != NULL) {
483 doc = pcmk__xml_parse(stdout_data);
484 }
485 if (doc != NULL) {
486 out->output_xml(out, PCMK_XE_COMMAND, stdout_data);
487 pcmk__xml_free(doc);
488 } else {
489 out->subprocess_output(out, rc, stdout_data, stderr_data);
490 }
491 }
492
493 pcmk__output_xml_pop_parent(out);
494 return pcmk_rc_ok;
495 }
496
497 PCMK__OUTPUT_ARGS("resource-check-list", "resource_checks_t *")
498 static int
499 resource_check_list_default(pcmk__output_t *out, va_list args) {
500 resource_checks_t *checks = va_arg(args, resource_checks_t *);
501
502 const pcmk_resource_t *parent = pe__const_top_resource(checks->rsc, false);
503 const pcmk_scheduler_t *scheduler = checks->rsc->priv->scheduler;
504
505 if (checks->flags == 0) {
506 return pcmk_rc_no_output;
507 }
508
509 out->begin_list(out, NULL, NULL, "Resource Checks");
510
511 if (pcmk_is_set(checks->flags, rsc_remain_stopped)) {
512 out->list_item(out, "check", "Configuration specifies '%s' should remain stopped",
513 parent->id);
514 }
515
516 if (pcmk_is_set(checks->flags, rsc_unpromotable)) {
517 out->list_item(out, "check", "Configuration specifies '%s' should not be promoted",
518 parent->id);
519 }
520
521 if (pcmk_is_set(checks->flags, rsc_unmanaged)) {
522 out->list_item(out, "check", "Configuration prevents cluster from stopping or starting unmanaged '%s'",
523 parent->id);
524 }
525
526 if (pcmk_is_set(checks->flags, rsc_locked)) {
527 out->list_item(out, "check", "'%s' is locked to node %s due to shutdown",
528 parent->id, checks->lock_node);
529 }
530
531 if (pcmk_is_set(checks->flags, rsc_node_health)) {
532 out->list_item(out, "check",
533 "'%s' cannot run on unhealthy nodes due to "
534 PCMK_OPT_NODE_HEALTH_STRATEGY "='%s'",
535 parent->id,
536 pcmk__cluster_option(scheduler->priv->options,
537 PCMK_OPT_NODE_HEALTH_STRATEGY));
538 }
539
540 out->end_list(out);
541 return pcmk_rc_ok;
542 }
543
544 PCMK__OUTPUT_ARGS("resource-check-list", "resource_checks_t *")
545 static int
546 resource_check_list_xml(pcmk__output_t *out, va_list args) {
547 resource_checks_t *checks = va_arg(args, resource_checks_t *);
548
549 const pcmk_resource_t *parent = pe__const_top_resource(checks->rsc, false);
550
551 xmlNodePtr node = pcmk__output_create_xml_node(out, PCMK_XE_CHECK,
552 PCMK_XA_ID, parent->id,
553 NULL);
554
555 if (pcmk_is_set(checks->flags, rsc_remain_stopped)) {
556 pcmk__xe_set_bool_attr(node, PCMK_XA_REMAIN_STOPPED, true);
557 }
558
559 if (pcmk_is_set(checks->flags, rsc_unpromotable)) {
560 pcmk__xe_set_bool_attr(node, PCMK_XA_PROMOTABLE, false);
561 }
562
563 if (pcmk_is_set(checks->flags, rsc_unmanaged)) {
564 pcmk__xe_set_bool_attr(node, PCMK_XA_UNMANAGED, true);
565 }
566
567 if (pcmk_is_set(checks->flags, rsc_locked)) {
568 crm_xml_add(node, PCMK_XA_LOCKED_TO_HYPHEN, checks->lock_node);
569 }
570
571 if (pcmk_is_set(checks->flags, rsc_node_health)) {
572 pcmk__xe_set_bool_attr(node, PCMK_XA_UNHEALTHY, true);
573 }
574
575 return pcmk_rc_ok;
576 }
577
578 PCMK__OUTPUT_ARGS("resource-search-list", "GList *", "const gchar *")
579 static int
580 resource_search_list_default(pcmk__output_t *out, va_list args)
581 {
582 GList *nodes = va_arg(args, GList *);
583 const gchar *requested_name = va_arg(args, const gchar *);
584
585 bool printed = false;
586 int rc = pcmk_rc_no_output;
587
588 if (!out->is_quiet(out) && nodes == NULL) {
589 out->err(out, "resource %s is NOT running", requested_name);
590 return rc;
591 }
592
593 for (GList *lpc = nodes; lpc != NULL; lpc = lpc->next) {
594 node_info_t *ni = (node_info_t *) lpc->data;
595
596 if (!printed) {
597 out->begin_list(out, NULL, NULL, "Nodes");
598 printed = true;
599 rc = pcmk_rc_ok;
600 }
601
602 if (out->is_quiet(out)) {
603 out->list_item(out, "node", "%s", ni->node_name);
604 } else {
605 const char *role_text = "";
606
607 if (ni->promoted) {
608 role_text = " " PCMK_ROLE_PROMOTED;
609 }
610 out->list_item(out, "node", "resource %s is running on: %s%s",
611 requested_name, ni->node_name, role_text);
612 }
613 }
614
615 if (printed) {
616 out->end_list(out);
617 }
618
619 return rc;
620 }
621
622 PCMK__OUTPUT_ARGS("resource-search-list", "GList *", "const gchar *")
623 static int
624 resource_search_list_xml(pcmk__output_t *out, va_list args)
625 {
626 GList *nodes = va_arg(args, GList *);
627 const gchar *requested_name = va_arg(args, const gchar *);
628
629 pcmk__output_xml_create_parent(out, PCMK_XE_NODES,
630 PCMK_XA_RESOURCE, requested_name,
631 NULL);
632
633 for (GList *lpc = nodes; lpc != NULL; lpc = lpc->next) {
634 node_info_t *ni = (node_info_t *) lpc->data;
635 xmlNodePtr sub_node = pcmk__output_create_xml_text_node(out,
636 PCMK_XE_NODE,
637 ni->node_name);
638
639 if (ni->promoted) {
640 crm_xml_add(sub_node, PCMK_XA_STATE, "promoted");
641 }
642 }
643
644 pcmk__output_xml_pop_parent(out);
645 return pcmk_rc_ok;
646 }
647
648 PCMK__OUTPUT_ARGS("resource-reasons-list", "GList *", "pcmk_resource_t *",
649 "pcmk_node_t *")
650 static int
651 resource_reasons_list_default(pcmk__output_t *out, va_list args)
652 {
653 GList *resources = va_arg(args, GList *);
654 pcmk_resource_t *rsc = va_arg(args, pcmk_resource_t *);
655 pcmk_node_t *node = va_arg(args, pcmk_node_t *);
656
657 const char *host_uname = (node == NULL)? NULL : node->priv->name;
658
659 out->begin_list(out, NULL, NULL, "Resource Reasons");
660
661 if ((rsc == NULL) && (host_uname == NULL)) {
662 GList *lpc = NULL;
663 GList *hosts = NULL;
664
665 for (lpc = resources; lpc != NULL; lpc = lpc->next) {
666 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
667
668 rsc->priv->fns->location(rsc, &hosts, pcmk__rsc_node_current);
669
670 if (hosts == NULL) {
671 out->list_item(out, "reason", "Resource %s is not running", rsc->id);
672 } else {
673 out->list_item(out, "reason", "Resource %s is running", rsc->id);
674 }
675
676 cli_resource_check(out, rsc, NULL);
677 g_list_free(hosts);
678 hosts = NULL;
679 }
680
681 } else if ((rsc != NULL) && (host_uname != NULL)) {
682 if (resource_is_running_on(rsc, host_uname)) {
683 out->list_item(out, "reason", "Resource %s is running on host %s",
684 rsc->id, host_uname);
685 } else {
686 out->list_item(out, "reason", "Resource %s is not running on host %s",
687 rsc->id, host_uname);
688 }
689
690 cli_resource_check(out, rsc, node);
691
692 } else if ((rsc == NULL) && (host_uname != NULL)) {
693 const char* host_uname = node->priv->name;
694 GList *allResources = node->priv->assigned_resources;
695 GList *activeResources = node->details->running_rsc;
696 GList *unactiveResources = pcmk__subtract_lists(allResources, activeResources, (GCompareFunc) strcmp);
697 GList *lpc = NULL;
698
699 for (lpc = activeResources; lpc != NULL; lpc = lpc->next) {
700 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
701 out->list_item(out, "reason", "Resource %s is running on host %s",
702 rsc->id, host_uname);
703 cli_resource_check(out, rsc, node);
704 }
705
706 for(lpc = unactiveResources; lpc != NULL; lpc = lpc->next) {
707 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
708 out->list_item(out, "reason", "Resource %s is assigned to host %s but not running",
709 rsc->id, host_uname);
710 cli_resource_check(out, rsc, node);
711 }
712
713 g_list_free(allResources);
714 g_list_free(activeResources);
715 g_list_free(unactiveResources);
716
717 } else if ((rsc != NULL) && (host_uname == NULL)) {
718 GList *hosts = NULL;
719
720 rsc->priv->fns->location(rsc, &hosts, pcmk__rsc_node_current);
721 out->list_item(out, "reason", "Resource %s is %srunning",
722 rsc->id, (hosts? "" : "not "));
723 cli_resource_check(out, rsc, NULL);
724 g_list_free(hosts);
725 }
726
727 out->end_list(out);
728 return pcmk_rc_ok;
729 }
730
731 PCMK__OUTPUT_ARGS("resource-reasons-list", "GList *", "pcmk_resource_t *",
732 "pcmk_node_t *")
733 static int
734 resource_reasons_list_xml(pcmk__output_t *out, va_list args)
735 {
736 GList *resources = va_arg(args, GList *);
737 pcmk_resource_t *rsc = va_arg(args, pcmk_resource_t *);
738 pcmk_node_t *node = va_arg(args, pcmk_node_t *);
739
740 const char *host_uname = (node == NULL)? NULL : node->priv->name;
741
742 xmlNodePtr xml_node = pcmk__output_xml_create_parent(out, PCMK_XE_REASON,
743 NULL);
744
745 if ((rsc == NULL) && (host_uname == NULL)) {
746 GList *lpc = NULL;
747 GList *hosts = NULL;
748
749 pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCES, NULL);
750
751 for (lpc = resources; lpc != NULL; lpc = lpc->next) {
752 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
753 const char *running = NULL;
754
755 rsc->priv->fns->location(rsc, &hosts, pcmk__rsc_node_current);
756 running = pcmk__btoa(hosts != NULL);
757
758 pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCE,
759 PCMK_XA_ID, rsc->id,
760 PCMK_XA_RUNNING, running,
761 NULL);
762
763 cli_resource_check(out, rsc, NULL);
764 pcmk__output_xml_pop_parent(out);
765 g_list_free(hosts);
766 hosts = NULL;
767 }
768
769 pcmk__output_xml_pop_parent(out);
770
771 } else if ((rsc != NULL) && (host_uname != NULL)) {
772 if (resource_is_running_on(rsc, host_uname)) {
773 crm_xml_add(xml_node, PCMK_XA_RUNNING_ON, host_uname);
774 }
775
776 cli_resource_check(out, rsc, node);
777
778 } else if ((rsc == NULL) && (host_uname != NULL)) {
779 const char* host_uname = node->priv->name;
780 GList *allResources = node->priv->assigned_resources;
781 GList *activeResources = node->details->running_rsc;
782 GList *unactiveResources = pcmk__subtract_lists(allResources, activeResources, (GCompareFunc) strcmp);
783 GList *lpc = NULL;
784
785 pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCES, NULL);
786
787 for (lpc = activeResources; lpc != NULL; lpc = lpc->next) {
788 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
789
790 pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCE,
791 PCMK_XA_ID, rsc->id,
792 PCMK_XA_RUNNING, PCMK_VALUE_TRUE,
793 PCMK_XA_HOST, host_uname,
794 NULL);
795
796 cli_resource_check(out, rsc, node);
797 pcmk__output_xml_pop_parent(out);
798 }
799
800 for(lpc = unactiveResources; lpc != NULL; lpc = lpc->next) {
801 pcmk_resource_t *rsc = (pcmk_resource_t *) lpc->data;
802
803 pcmk__output_xml_create_parent(out, PCMK_XE_RESOURCE,
804 PCMK_XA_ID, rsc->id,
805 PCMK_XA_RUNNING, PCMK_VALUE_FALSE,
806 PCMK_XA_HOST, host_uname,
807 NULL);
808
809 cli_resource_check(out, rsc, node);
810 pcmk__output_xml_pop_parent(out);
811 }
812
813 pcmk__output_xml_pop_parent(out);
814 g_list_free(allResources);
815 g_list_free(activeResources);
816 g_list_free(unactiveResources);
817
818 } else if ((rsc != NULL) && (host_uname == NULL)) {
819 GList *hosts = NULL;
820
821 rsc->priv->fns->location(rsc, &hosts, pcmk__rsc_node_current);
822 crm_xml_add(xml_node, PCMK_XA_RUNNING, pcmk__btoa(hosts != NULL));
823 cli_resource_check(out, rsc, NULL);
824 g_list_free(hosts);
825 }
826
827 pcmk__output_xml_pop_parent(out);
828 return pcmk_rc_ok;
829 }
830
831 static void
832 add_resource_name(pcmk_resource_t *rsc, pcmk__output_t *out)
833 {
834 if (rsc->priv->children == NULL) {
835
836
837
838
839 out->list_item(out, PCMK_XE_RESOURCE, "%s", rsc->id);
840 } else {
841 g_list_foreach(rsc->priv->children, (GFunc) add_resource_name, out);
842 }
843 }
844
845 PCMK__OUTPUT_ARGS("resource-names-list", "GList *")
846 static int
847 resource_names(pcmk__output_t *out, va_list args) {
848 GList *resources = va_arg(args, GList *);
849
850 if (resources == NULL) {
851 out->err(out, "NO resources configured\n");
852 return pcmk_rc_no_output;
853 }
854
855 out->begin_list(out, NULL, NULL, "Resource Names");
856 g_list_foreach(resources, (GFunc) add_resource_name, out);
857 out->end_list(out);
858 return pcmk_rc_ok;
859 }
860
861 static pcmk__message_entry_t fmt_functions[] = {
862 { "agent-status", "default", agent_status_default },
863 { "agent-status", "xml", agent_status_xml },
864 { "attribute-changed", "default", attribute_changed_default },
865 { "attribute-changed", "xml", attribute_changed_xml },
866 { "attribute-changed-list", "default", attribute_changed_list_default },
867 { "attribute-changed-list", "xml", attribute_changed_list_xml },
868 { "attribute-list", "default", attribute_list_default },
869 { "attribute-list", "text", attribute_list_text },
870 { "override", "default", override_default },
871 { "override", "xml", override_xml },
872 { "resource-agent-action", "default", resource_agent_action_default },
873 { "resource-agent-action", "xml", resource_agent_action_xml },
874 { "resource-check-list", "default", resource_check_list_default },
875 { "resource-check-list", "xml", resource_check_list_xml },
876 { "resource-search-list", "default", resource_search_list_default },
877 { "resource-search-list", "xml", resource_search_list_xml },
878 { "resource-reasons-list", "default", resource_reasons_list_default },
879 { "resource-reasons-list", "xml", resource_reasons_list_xml },
880 { "resource-names-list", "default", resource_names },
881
882 { NULL, NULL, NULL }
883 };
884
885 void
886 crm_resource_register_messages(pcmk__output_t *out) {
887 pcmk__register_messages(out, fmt_functions);
888 }