This source file includes following definitions.
- pe__free_digests
- attr_not_in_string
- attr_in_string
- calculate_main_digest
- is_fence_param
- calculate_secure_digest
- calculate_restart_digest
- pe__calculate_digests
- rsc_action_digest
- rsc_action_digest_cmp
- create_unfencing_summary
- unfencing_digest_matches
- pe__compare_fencing_digest
1
2
3
4
5
6
7
8
9
10 #include <crm_internal.h>
11
12 #include <glib.h>
13 #include <stdbool.h>
14
15 #include <crm/crm.h>
16 #include <crm/common/xml.h>
17 #include <crm/common/xml_internal.h>
18 #include <crm/pengine/internal.h>
19 #include "pe_status_private.h"
20
21 extern bool pcmk__is_daemon;
22
23
24
25
26
27
28
29
30
31
32 void
33 pe__free_digests(gpointer ptr)
34 {
35 pcmk__op_digest_t *data = ptr;
36
37 if (data != NULL) {
38 free_xml(data->params_all);
39 free_xml(data->params_secure);
40 free_xml(data->params_restart);
41
42 free(data->digest_all_calc);
43 free(data->digest_restart_calc);
44 free(data->digest_secure_calc);
45
46 free(data);
47 }
48 }
49
50
51 static bool
52 attr_not_in_string(xmlAttrPtr a, void *user_data)
53 {
54 bool filter = false;
55 char *name = crm_strdup_printf(" %s ", (const char *) a->name);
56
57 if (strstr((const char *) user_data, name) == NULL) {
58 crm_trace("Filtering %s (not found in '%s')",
59 (const char *) a->name, (const char *) user_data);
60 filter = true;
61 }
62 free(name);
63 return filter;
64 }
65
66
67 static bool
68 attr_in_string(xmlAttrPtr a, void *user_data)
69 {
70 bool filter = false;
71 char *name = crm_strdup_printf(" %s ", (const char *) a->name);
72
73 if (strstr((const char *) user_data, name) != NULL) {
74 crm_trace("Filtering %s (found in '%s')",
75 (const char *) a->name, (const char *) user_data);
76 filter = true;
77 }
78 free(name);
79 return filter;
80 }
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97 static void
98 calculate_main_digest(pcmk__op_digest_t *data, pcmk_resource_t *rsc,
99 const pcmk_node_t *node, GHashTable *params,
100 const char *task, guint *interval_ms,
101 const xmlNode *xml_op, const char *op_version,
102 GHashTable *overrides, pcmk_scheduler_t *scheduler)
103 {
104 xmlNode *action_config = NULL;
105
106 data->params_all = pcmk__xe_create(NULL, PCMK_XE_PARAMETERS);
107
108
109
110
111 (void) pe__add_bundle_remote_name(rsc, data->params_all,
112 PCMK_REMOTE_RA_ADDR);
113
114 if (overrides != NULL) {
115
116 const char *meta_name = CRM_META "_" PCMK_META_INTERVAL;
117 const char *interval_s = g_hash_table_lookup(overrides, meta_name);
118
119 if (interval_s != NULL) {
120 long long value_ll;
121
122 if ((pcmk__scan_ll(interval_s, &value_ll, 0LL) == pcmk_rc_ok)
123 && (value_ll >= 0) && (value_ll <= G_MAXUINT)) {
124 *interval_ms = (guint) value_ll;
125 }
126 }
127
128
129 g_hash_table_foreach(overrides, hash2field, data->params_all);
130 }
131
132
133 g_hash_table_foreach(params, hash2field, data->params_all);
134
135
136 action_config = pcmk__find_action_config(rsc, task, *interval_ms, true);
137
138
139
140
141
142
143
144
145
146
147
148 params = pcmk__unpack_action_rsc_params(action_config, node->details->attrs,
149 scheduler);
150 if ((*interval_ms == 0) && (g_hash_table_size(params) > 0)) {
151 data->rc = pcmk__digest_restart;
152 }
153 g_hash_table_foreach(params, hash2field, data->params_all);
154 g_hash_table_destroy(params);
155
156
157 params = pcmk__unpack_action_meta(rsc, node, task, *interval_ms,
158 action_config);
159 g_hash_table_foreach(params, hash2metafield, data->params_all);
160 g_hash_table_destroy(params);
161
162 pcmk__filter_op_for_digest(data->params_all);
163
164 data->digest_all_calc = calculate_operation_digest(data->params_all,
165 op_version);
166 }
167
168
169 static bool
170 is_fence_param(xmlAttrPtr attr, void *user_data)
171 {
172 return pcmk_stonith_param((const char *) attr->name);
173 }
174
175
176
177
178
179
180
181
182
183
184
185
186 static void
187 calculate_secure_digest(pcmk__op_digest_t *data, const pcmk_resource_t *rsc,
188 GHashTable *params, const xmlNode *xml_op,
189 const char *op_version, GHashTable *overrides)
190 {
191 const char *class = crm_element_value(rsc->xml, PCMK_XA_CLASS);
192 const char *secure_list = NULL;
193 bool old_version = (compare_version(op_version, "3.16.0") < 0);
194
195 if (xml_op == NULL) {
196 secure_list = " passwd password user ";
197 } else {
198 secure_list = crm_element_value(xml_op, PCMK__XA_OP_SECURE_PARAMS);
199 }
200
201 if (old_version) {
202 data->params_secure = pcmk__xe_create(NULL, PCMK_XE_PARAMETERS);
203 if (overrides != NULL) {
204 g_hash_table_foreach(overrides, hash2field, data->params_secure);
205 }
206
207 g_hash_table_foreach(params, hash2field, data->params_secure);
208
209 } else {
210
211 data->params_secure = pcmk__xml_copy(NULL, data->params_all);
212 }
213
214 if (secure_list != NULL) {
215 pcmk__xe_remove_matching_attrs(data->params_secure, attr_in_string,
216 (void *) secure_list);
217 }
218 if (old_version
219 && pcmk_is_set(pcmk_get_ra_caps(class),
220 pcmk_ra_cap_fence_params)) {
221
222
223
224
225
226 pcmk__xe_remove_matching_attrs(data->params_secure, is_fence_param,
227 NULL);
228 }
229 pcmk__filter_op_for_digest(data->params_secure);
230
231
232
233
234
235
236
237 if (old_version) {
238 pcmk__xe_remove_attr(data->params_secure,
239 CRM_META "_" PCMK_META_TIMEOUT);
240 }
241
242 data->digest_secure_calc = calculate_operation_digest(data->params_secure,
243 op_version);
244 }
245
246
247
248
249
250
251
252
253
254
255
256
257 static void
258 calculate_restart_digest(pcmk__op_digest_t *data, const xmlNode *xml_op,
259 const char *op_version)
260 {
261 const char *value = NULL;
262
263
264 if (xml_op == NULL) {
265 return;
266 }
267
268
269 if (crm_element_value(xml_op, PCMK__XA_OP_RESTART_DIGEST) == NULL) {
270 return;
271 }
272
273
274 data->params_restart = pcmk__xml_copy(NULL, data->params_all);
275
276
277 value = crm_element_value(xml_op, PCMK__XA_OP_FORCE_RESTART);
278 if (value != NULL) {
279 pcmk__xe_remove_matching_attrs(data->params_restart, attr_not_in_string,
280 (void *) value);
281 }
282
283 value = crm_element_value(xml_op, PCMK_XA_CRM_FEATURE_SET);
284 data->digest_restart_calc = calculate_operation_digest(data->params_restart,
285 value);
286 }
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305 pcmk__op_digest_t *
306 pe__calculate_digests(pcmk_resource_t *rsc, const char *task,
307 guint *interval_ms, const pcmk_node_t *node,
308 const xmlNode *xml_op, GHashTable *overrides,
309 bool calc_secure, pcmk_scheduler_t *scheduler)
310 {
311 pcmk__op_digest_t *data = NULL;
312 const char *op_version = NULL;
313 GHashTable *params = NULL;
314
315 CRM_CHECK(scheduler != NULL, return NULL);
316
317 data = calloc(1, sizeof(pcmk__op_digest_t));
318 if (data == NULL) {
319 pcmk__sched_err("Could not allocate memory for operation digest");
320 return NULL;
321 }
322
323 data->rc = pcmk__digest_match;
324
325 if (xml_op != NULL) {
326 op_version = crm_element_value(xml_op, PCMK_XA_CRM_FEATURE_SET);
327 }
328
329 if ((op_version == NULL) && (scheduler->input != NULL)) {
330 op_version = crm_element_value(scheduler->input,
331 PCMK_XA_CRM_FEATURE_SET);
332 }
333
334 if (op_version == NULL) {
335 op_version = CRM_FEATURE_SET;
336 }
337
338 params = pe_rsc_params(rsc, node, scheduler);
339 calculate_main_digest(data, rsc, node, params, task, interval_ms, xml_op,
340 op_version, overrides, scheduler);
341 if (calc_secure) {
342 calculate_secure_digest(data, rsc, params, xml_op, op_version,
343 overrides);
344 }
345 calculate_restart_digest(data, xml_op, op_version);
346 return data;
347 }
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363 static pcmk__op_digest_t *
364 rsc_action_digest(pcmk_resource_t *rsc, const char *task, guint interval_ms,
365 pcmk_node_t *node, const xmlNode *xml_op,
366 bool calc_secure, pcmk_scheduler_t *scheduler)
367 {
368 pcmk__op_digest_t *data = NULL;
369 char *key = pcmk__op_key(rsc->id, task, interval_ms);
370
371 data = g_hash_table_lookup(node->details->digest_cache, key);
372 if (data == NULL) {
373 data = pe__calculate_digests(rsc, task, &interval_ms, node, xml_op,
374 NULL, calc_secure, scheduler);
375 CRM_ASSERT(data != NULL);
376 g_hash_table_insert(node->details->digest_cache, strdup(key), data);
377 }
378 free(key);
379 return data;
380 }
381
382
383
384
385
386
387
388
389
390
391
392
393 pcmk__op_digest_t *
394 rsc_action_digest_cmp(pcmk_resource_t *rsc, const xmlNode *xml_op,
395 pcmk_node_t *node, pcmk_scheduler_t *scheduler)
396 {
397 pcmk__op_digest_t *data = NULL;
398 guint interval_ms = 0;
399
400 const char *op_version;
401 const char *task = crm_element_value(xml_op, PCMK_XA_OPERATION);
402 const char *digest_all;
403 const char *digest_restart;
404
405 CRM_ASSERT(node != NULL);
406
407 op_version = crm_element_value(xml_op, PCMK_XA_CRM_FEATURE_SET);
408 digest_all = crm_element_value(xml_op, PCMK__XA_OP_DIGEST);
409 digest_restart = crm_element_value(xml_op, PCMK__XA_OP_RESTART_DIGEST);
410
411 crm_element_value_ms(xml_op, PCMK_META_INTERVAL, &interval_ms);
412 data = rsc_action_digest(rsc, task, interval_ms, node, xml_op,
413 pcmk_is_set(scheduler->flags,
414 pcmk_sched_sanitized),
415 scheduler);
416
417 if (digest_restart && data->digest_restart_calc && strcmp(data->digest_restart_calc, digest_restart) != 0) {
418 pcmk__rsc_info(rsc,
419 "Parameters to %ums-interval %s action for %s on %s "
420 "changed: hash was %s vs. now %s (restart:%s) %s",
421 interval_ms, task, rsc->id, pcmk__node_name(node),
422 pcmk__s(digest_restart, "missing"),
423 data->digest_restart_calc, op_version,
424 crm_element_value(xml_op, PCMK__XA_TRANSITION_MAGIC));
425 data->rc = pcmk__digest_restart;
426
427 } else if (digest_all == NULL) {
428
429 data->rc = pcmk__digest_unknown;
430
431 } else if (strcmp(digest_all, data->digest_all_calc) != 0) {
432
433
434
435
436
437
438
439
440
441 if ((interval_ms == 0) && (data->rc == pcmk__digest_restart)) {
442 pcmk__rsc_info(rsc,
443 "Parameters containing extra ones to %ums-interval"
444 " %s action for %s on %s "
445 "changed: hash was %s vs. now %s (restart:%s) %s",
446 interval_ms, task, rsc->id, pcmk__node_name(node),
447 pcmk__s(digest_all, "missing"),
448 data->digest_all_calc, op_version,
449 crm_element_value(xml_op,
450 PCMK__XA_TRANSITION_MAGIC));
451
452 } else {
453 pcmk__rsc_info(rsc,
454 "Parameters to %ums-interval %s action for %s on %s "
455 "changed: hash was %s vs. now %s (%s:%s) %s",
456 interval_ms, task, rsc->id, pcmk__node_name(node),
457 pcmk__s(digest_all, "missing"),
458 data->digest_all_calc,
459 (interval_ms > 0)? "reschedule" : "reload",
460 op_version,
461 crm_element_value(xml_op,
462 PCMK__XA_TRANSITION_MAGIC));
463 data->rc = pcmk__digest_mismatch;
464 }
465
466 } else {
467 data->rc = pcmk__digest_match;
468 }
469 return data;
470 }
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489 static inline char *
490 create_unfencing_summary(const char *rsc_id, const char *agent_type,
491 const char *param_digest)
492 {
493 return crm_strdup_printf("%s:%s:%s", rsc_id, agent_type, param_digest);
494 }
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512 static bool
513 unfencing_digest_matches(const char *rsc_id, const char *agent,
514 const char *digest_calc, const char *node_summary)
515 {
516 bool matches = FALSE;
517
518 if (rsc_id && agent && digest_calc && node_summary) {
519 char *search_secure = create_unfencing_summary(rsc_id, agent,
520 digest_calc);
521
522
523
524
525 matches = (strstr(node_summary, search_secure) != NULL);
526 crm_trace("Calculated unfencing digest '%s' %sfound in '%s'",
527 search_secure, matches? "" : "not ", node_summary);
528 free(search_secure);
529 }
530 return matches;
531 }
532
533
534
535
536
537 #define STONITH_DIGEST_TASK "stonith-on"
538
539
540
541
542
543
544
545
546
547
548
549
550 pcmk__op_digest_t *
551 pe__compare_fencing_digest(pcmk_resource_t *rsc, const char *agent,
552 pcmk_node_t *node, pcmk_scheduler_t *scheduler)
553 {
554 const char *node_summary = NULL;
555
556
557 pcmk__op_digest_t *data = rsc_action_digest(rsc, STONITH_DIGEST_TASK, 0U,
558 node, NULL, TRUE, scheduler);
559
560
561 node_summary = pcmk__node_attr(node, CRM_ATTR_DIGESTS_ALL, NULL,
562 pcmk__rsc_node_current);
563 if (node_summary == NULL) {
564 data->rc = pcmk__digest_unknown;
565 return data;
566 }
567
568
569 if (unfencing_digest_matches(rsc->id, agent, data->digest_all_calc,
570 node_summary)) {
571 data->rc = pcmk__digest_match;
572 return data;
573 }
574
575
576 node_summary = pcmk__node_attr(node, CRM_ATTR_DIGESTS_SECURE, NULL,
577 pcmk__rsc_node_current);
578 if (unfencing_digest_matches(rsc->id, agent, data->digest_secure_calc,
579 node_summary)) {
580 data->rc = pcmk__digest_match;
581 if (!pcmk__is_daemon && scheduler->priv != NULL) {
582 pcmk__output_t *out = scheduler->priv;
583 out->info(out, "Only 'private' parameters to %s "
584 "for unfencing %s changed", rsc->id,
585 pcmk__node_name(node));
586 }
587 return data;
588 }
589
590
591 data->rc = pcmk__digest_mismatch;
592 if (pcmk_is_set(scheduler->flags, pcmk_sched_sanitized)
593 && (data->digest_secure_calc != NULL)) {
594
595 if (scheduler->priv != NULL) {
596 pcmk__output_t *out = scheduler->priv;
597 char *digest = create_unfencing_summary(rsc->id, agent,
598 data->digest_secure_calc);
599
600 out->info(out, "Parameters to %s for unfencing "
601 "%s changed, try '%s'", rsc->id,
602 pcmk__node_name(node), digest);
603 free(digest);
604 } else if (!pcmk__is_daemon) {
605 char *digest = create_unfencing_summary(rsc->id, agent,
606 data->digest_secure_calc);
607
608 printf("Parameters to %s for unfencing %s changed, try '%s'\n",
609 rsc->id, pcmk__node_name(node), digest);
610 free(digest);
611 }
612 }
613 return data;
614 }