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