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 pcmk__xml_free(data->params_all);
39 pcmk__xml_free(data->params_secure);
40 pcmk__xml_free(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->priv->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 = pcmk__digest_operation(data->params_all);
165 }
166
167
168 static bool
169 is_fence_param(xmlAttrPtr attr, void *user_data)
170 {
171 return pcmk_stonith_param((const char *) attr->name);
172 }
173
174
175
176
177
178
179
180
181
182
183
184
185 static void
186 calculate_secure_digest(pcmk__op_digest_t *data, const pcmk_resource_t *rsc,
187 GHashTable *params, const xmlNode *xml_op,
188 const char *op_version, GHashTable *overrides)
189 {
190 const char *class = crm_element_value(rsc->priv->xml, PCMK_XA_CLASS);
191 const char *secure_list = NULL;
192 bool old_version = (compare_version(op_version, "3.16.0") < 0);
193
194 if (xml_op == NULL) {
195 secure_list = " passwd password user ";
196 } else {
197 secure_list = crm_element_value(xml_op, PCMK__XA_OP_SECURE_PARAMS);
198 }
199
200 if (old_version) {
201 data->params_secure = pcmk__xe_create(NULL, PCMK_XE_PARAMETERS);
202 if (overrides != NULL) {
203 g_hash_table_foreach(overrides, hash2field, data->params_secure);
204 }
205
206 g_hash_table_foreach(params, hash2field, data->params_secure);
207
208 } else {
209
210 data->params_secure = pcmk__xml_copy(NULL, data->params_all);
211 }
212
213 if (secure_list != NULL) {
214 pcmk__xe_remove_matching_attrs(data->params_secure, false,
215 attr_in_string, (void *) secure_list);
216 }
217 if (old_version
218 && pcmk_is_set(pcmk_get_ra_caps(class),
219 pcmk_ra_cap_fence_params)) {
220
221
222
223
224
225 pcmk__xe_remove_matching_attrs(data->params_secure, false,
226 is_fence_param, NULL);
227 }
228 pcmk__filter_op_for_digest(data->params_secure);
229
230
231
232
233
234
235
236 if (old_version) {
237 pcmk__xe_remove_attr(data->params_secure,
238 CRM_META "_" PCMK_META_TIMEOUT);
239 }
240
241 data->digest_secure_calc = pcmk__digest_operation(data->params_secure);
242 }
243
244
245
246
247
248
249
250
251
252
253
254
255 static void
256 calculate_restart_digest(pcmk__op_digest_t *data, const xmlNode *xml_op,
257 const char *op_version)
258 {
259 const char *value = NULL;
260
261
262 if (xml_op == NULL) {
263 return;
264 }
265
266
267 if (crm_element_value(xml_op, PCMK__XA_OP_RESTART_DIGEST) == NULL) {
268 return;
269 }
270
271
272 data->params_restart = pcmk__xml_copy(NULL, data->params_all);
273
274
275 value = crm_element_value(xml_op, PCMK__XA_OP_FORCE_RESTART);
276 if (value != NULL) {
277 pcmk__xe_remove_matching_attrs(data->params_restart, false,
278 attr_not_in_string, (void *) value);
279 }
280
281 data->digest_restart_calc = pcmk__digest_operation(data->params_restart);
282 }
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301 pcmk__op_digest_t *
302 pe__calculate_digests(pcmk_resource_t *rsc, const char *task,
303 guint *interval_ms, const pcmk_node_t *node,
304 const xmlNode *xml_op, GHashTable *overrides,
305 bool calc_secure, pcmk_scheduler_t *scheduler)
306 {
307 pcmk__op_digest_t *data = NULL;
308 const char *op_version = NULL;
309 GHashTable *params = NULL;
310
311 CRM_CHECK(scheduler != NULL, return NULL);
312
313 data = calloc(1, sizeof(pcmk__op_digest_t));
314 if (data == NULL) {
315 pcmk__sched_err(scheduler,
316 "Could not allocate memory for operation digest");
317 return NULL;
318 }
319
320 data->rc = pcmk__digest_match;
321
322 if (xml_op != NULL) {
323 op_version = crm_element_value(xml_op, PCMK_XA_CRM_FEATURE_SET);
324 }
325
326 if ((op_version == NULL) && (scheduler->input != NULL)) {
327 op_version = crm_element_value(scheduler->input,
328 PCMK_XA_CRM_FEATURE_SET);
329 }
330
331 if (op_version == NULL) {
332 op_version = CRM_FEATURE_SET;
333 }
334
335 params = pe_rsc_params(rsc, node, scheduler);
336 calculate_main_digest(data, rsc, node, params, task, interval_ms, xml_op,
337 op_version, overrides, scheduler);
338 if (calc_secure) {
339 calculate_secure_digest(data, rsc, params, xml_op, op_version,
340 overrides);
341 }
342 calculate_restart_digest(data, xml_op, op_version);
343 return data;
344 }
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360 static pcmk__op_digest_t *
361 rsc_action_digest(pcmk_resource_t *rsc, const char *task, guint interval_ms,
362 pcmk_node_t *node, const xmlNode *xml_op,
363 bool calc_secure, pcmk_scheduler_t *scheduler)
364 {
365 pcmk__op_digest_t *data = NULL;
366 char *key = pcmk__op_key(rsc->id, task, interval_ms);
367
368 data = g_hash_table_lookup(node->priv->digest_cache, key);
369 if (data == NULL) {
370 data = pe__calculate_digests(rsc, task, &interval_ms, node, xml_op,
371 NULL, calc_secure, scheduler);
372 pcmk__assert(data != NULL);
373 g_hash_table_insert(node->priv->digest_cache, strdup(key), data);
374 }
375 free(key);
376 return data;
377 }
378
379
380
381
382
383
384
385
386
387
388
389
390 pcmk__op_digest_t *
391 rsc_action_digest_cmp(pcmk_resource_t *rsc, const xmlNode *xml_op,
392 pcmk_node_t *node, pcmk_scheduler_t *scheduler)
393 {
394 pcmk__op_digest_t *data = NULL;
395 guint interval_ms = 0;
396
397 const char *op_version;
398 const char *task = crm_element_value(xml_op, PCMK_XA_OPERATION);
399 const char *digest_all;
400 const char *digest_restart;
401
402 pcmk__assert(node != NULL);
403
404 op_version = crm_element_value(xml_op, PCMK_XA_CRM_FEATURE_SET);
405 digest_all = crm_element_value(xml_op, PCMK__XA_OP_DIGEST);
406 digest_restart = crm_element_value(xml_op, PCMK__XA_OP_RESTART_DIGEST);
407
408 crm_element_value_ms(xml_op, PCMK_META_INTERVAL, &interval_ms);
409 data = rsc_action_digest(rsc, task, interval_ms, node, xml_op,
410 pcmk_is_set(scheduler->flags,
411 pcmk__sched_sanitized),
412 scheduler);
413
414 if (!pcmk__str_eq(data->digest_restart_calc, digest_restart,
415 pcmk__str_null_matches)) {
416 pcmk__rsc_info(rsc,
417 "Parameter change for %s-interval %s of %s on %s "
418 "requires restart (hash now %s vs. %s "
419 "with op feature set %s for transition %s)",
420 pcmk__readable_interval(interval_ms), task, rsc->id,
421 pcmk__node_name(node), data->digest_restart_calc,
422 pcmk__s(digest_restart, "missing"), op_version,
423 crm_element_value(xml_op, PCMK__XA_TRANSITION_MAGIC));
424 data->rc = pcmk__digest_restart;
425
426 } else if (digest_all == NULL) {
427
428 data->rc = pcmk__digest_unknown;
429
430 } else if (strcmp(digest_all, data->digest_all_calc) != 0) {
431
432
433
434
435
436
437
438
439
440 if ((interval_ms == 0) && (data->rc == pcmk__digest_restart)) {
441 pcmk__rsc_info(rsc,
442 "Parameters containing extra ones to %ums-interval"
443 " %s action for %s on %s "
444 "changed: hash was %s vs. now %s (restart:%s) %s",
445 interval_ms, task, rsc->id, pcmk__node_name(node),
446 pcmk__s(digest_all, "missing"),
447 data->digest_all_calc, op_version,
448 crm_element_value(xml_op,
449 PCMK__XA_TRANSITION_MAGIC));
450
451 } else {
452 pcmk__rsc_info(rsc,
453 "Parameters to %ums-interval %s action for %s on %s "
454 "changed: hash was %s vs. now %s (%s:%s) %s",
455 interval_ms, task, rsc->id, pcmk__node_name(node),
456 pcmk__s(digest_all, "missing"),
457 data->digest_all_calc,
458 (interval_ms > 0)? "reschedule" : "reload",
459 op_version,
460 crm_element_value(xml_op,
461 PCMK__XA_TRANSITION_MAGIC));
462 data->rc = pcmk__digest_mismatch;
463 }
464
465 } else {
466 data->rc = pcmk__digest_match;
467 }
468 return data;
469 }
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488 static inline char *
489 create_unfencing_summary(const char *rsc_id, const char *agent_type,
490 const char *param_digest)
491 {
492 return crm_strdup_printf("%s:%s:%s", rsc_id, agent_type, param_digest);
493 }
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511 static bool
512 unfencing_digest_matches(const char *rsc_id, const char *agent,
513 const char *digest_calc, const char *node_summary)
514 {
515 bool matches = FALSE;
516
517 if (rsc_id && agent && digest_calc && node_summary) {
518 char *search_secure = create_unfencing_summary(rsc_id, agent,
519 digest_calc);
520
521
522
523
524 matches = (strstr(node_summary, search_secure) != NULL);
525 crm_trace("Calculated unfencing digest '%s' %sfound in '%s'",
526 search_secure, matches? "" : "not ", node_summary);
527 free(search_secure);
528 }
529 return matches;
530 }
531
532
533
534
535
536 #define STONITH_DIGEST_TASK "stonith-on"
537
538
539
540
541
542
543
544
545
546
547
548
549 pcmk__op_digest_t *
550 pe__compare_fencing_digest(pcmk_resource_t *rsc, const char *agent,
551 pcmk_node_t *node, pcmk_scheduler_t *scheduler)
552 {
553 const char *node_summary = NULL;
554
555
556 pcmk__op_digest_t *data = rsc_action_digest(rsc, STONITH_DIGEST_TASK, 0U,
557 node, NULL, TRUE, scheduler);
558
559
560 node_summary = pcmk__node_attr(node, CRM_ATTR_DIGESTS_ALL, NULL,
561 pcmk__rsc_node_current);
562 if (node_summary == NULL) {
563 data->rc = pcmk__digest_unknown;
564 return data;
565 }
566
567
568 if (unfencing_digest_matches(rsc->id, agent, data->digest_all_calc,
569 node_summary)) {
570 data->rc = pcmk__digest_match;
571 return data;
572 }
573
574
575 node_summary = pcmk__node_attr(node, CRM_ATTR_DIGESTS_SECURE, NULL,
576 pcmk__rsc_node_current);
577 if (unfencing_digest_matches(rsc->id, agent, data->digest_secure_calc,
578 node_summary)) {
579 data->rc = pcmk__digest_match;
580 if (!pcmk__is_daemon && (scheduler->priv->out != NULL)) {
581 pcmk__output_t *out = scheduler->priv->out;
582
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->out != NULL) {
596 pcmk__output_t *out = scheduler->priv->out;
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 }