This source file includes following definitions.
- pcmk__new_nvpair
- pcmk__free_nvpair
- pcmk_prepend_nvpair
- pcmk_free_nvpairs
- pcmk__compare_nvpair
- pcmk_sort_nvpairs
- pcmk_xml_attrs2nvpairs
- pcmk__nvpair_add_xml_attr
- pcmk_nvpairs2xml_attrs
- pcmk__scan_nvpair
- pcmk__format_nvpair
- crm_xml_add
- crm_xml_replace
- crm_xml_add_int
- crm_xml_add_ms
- crm_xml_add_ll
- crm_xml_add_timeval
- crm_element_value
- crm_element_value_int
- crm_element_value_ll
- crm_element_value_ms
- crm_element_value_epoch
- crm_element_value_timeval
- crm_element_value_copy
- hash2smartfield
- hash2field
- hash2metafield
- crm_create_nvpair_xml
- hash2nvpair
- xml2list
- pcmk__xe_set_bool_attr
- pcmk__xe_get_bool_attr
- pcmk__xe_attr_is_true
- pcmk_scan_nvpair
- pcmk_format_nvpair
- pcmk_format_named_time
1
2
3
4
5
6
7
8
9
10 #include <crm_internal.h>
11
12 #include <stdio.h>
13 #include <sys/types.h>
14 #include <string.h>
15 #include <ctype.h>
16 #include <glib.h>
17 #include <libxml/tree.h>
18
19 #include <crm/crm.h>
20 #include <crm/msg_xml.h>
21 #include <crm/common/xml.h>
22 #include <crm/common/xml_internal.h>
23 #include "crmcommon_private.h"
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46 static pcmk_nvpair_t *
47 pcmk__new_nvpair(const char *name, const char *value)
48 {
49 pcmk_nvpair_t *nvpair = NULL;
50
51 CRM_ASSERT(name);
52
53 nvpair = calloc(1, sizeof(pcmk_nvpair_t));
54 CRM_ASSERT(nvpair);
55
56 pcmk__str_update(&nvpair->name, name);
57 pcmk__str_update(&nvpair->value, value);
58 return nvpair;
59 }
60
61
62
63
64
65
66
67 static void
68 pcmk__free_nvpair(gpointer data)
69 {
70 if (data) {
71 pcmk_nvpair_t *nvpair = data;
72
73 free(nvpair->name);
74 free(nvpair->value);
75 free(nvpair);
76 }
77 }
78
79
80
81
82
83
84
85
86
87
88
89
90 GSList *
91 pcmk_prepend_nvpair(GSList *nvpairs, const char *name, const char *value)
92 {
93 return g_slist_prepend(nvpairs, pcmk__new_nvpair(name, value));
94 }
95
96
97
98
99
100
101 void
102 pcmk_free_nvpairs(GSList *nvpairs)
103 {
104 g_slist_free_full(nvpairs, pcmk__free_nvpair);
105 }
106
107
108
109
110
111
112
113
114
115
116 static gint
117 pcmk__compare_nvpair(gconstpointer a, gconstpointer b)
118 {
119 int rc = 0;
120 const pcmk_nvpair_t *pair_a = a;
121 const pcmk_nvpair_t *pair_b = b;
122
123 CRM_ASSERT(a != NULL);
124 CRM_ASSERT(pair_a->name != NULL);
125
126 CRM_ASSERT(b != NULL);
127 CRM_ASSERT(pair_b->name != NULL);
128
129 rc = strcmp(pair_a->name, pair_b->name);
130 if (rc < 0) {
131 return -1;
132 } else if (rc > 0) {
133 return 1;
134 }
135 return 0;
136 }
137
138
139
140
141
142
143
144
145 GSList *
146 pcmk_sort_nvpairs(GSList *list)
147 {
148 return g_slist_sort(list, pcmk__compare_nvpair);
149 }
150
151
152
153
154
155
156
157
158
159
160 GSList *
161 pcmk_xml_attrs2nvpairs(const xmlNode *xml)
162 {
163 GSList *result = NULL;
164
165 for (xmlAttrPtr iter = pcmk__xe_first_attr(xml); iter != NULL;
166 iter = iter->next) {
167
168 result = pcmk_prepend_nvpair(result,
169 (const char *) iter->name,
170 (const char *) pcmk__xml_attr_value(iter));
171 }
172 return result;
173 }
174
175
176
177
178
179
180
181
182
183
184
185 static void
186 pcmk__nvpair_add_xml_attr(gpointer data, gpointer user_data)
187 {
188 pcmk_nvpair_t *pair = data;
189 xmlNode *parent = user_data;
190
191 crm_xml_add(parent, pair->name, pair->value);
192 }
193
194
195
196
197
198
199
200 void
201 pcmk_nvpairs2xml_attrs(GSList *list, xmlNode *xml)
202 {
203 g_slist_foreach(list, pcmk__nvpair_add_xml_attr, xml);
204 }
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220 int
221 pcmk__scan_nvpair(const char *input, char **name, char **value)
222 {
223 #ifdef HAVE_SSCANF_M
224 *name = NULL;
225 *value = NULL;
226 if (sscanf(input, "%m[^=]=%m[^\n]", name, value) <= 0) {
227 return -pcmk_err_bad_nvpair;
228 }
229 #else
230 char *sep = NULL;
231 *name = NULL;
232 *value = NULL;
233
234 sep = strstr(optarg, "=");
235 if (sep == NULL) {
236 return -pcmk_err_bad_nvpair;
237 }
238
239 *name = strndup(input, sep-input);
240
241 if (*name == NULL) {
242 return -ENOMEM;
243 }
244
245
246
247
248 if (*(sep+1) != '\0') {
249 *value = strdup(sep+1);
250
251 if (*value == NULL) {
252 return -ENOMEM;
253 }
254 }
255 #endif
256
257 if (*name != NULL && *value != NULL) {
258 return 2;
259 } else if (*name != NULL || *value != NULL) {
260 return 1;
261 } else {
262 return -pcmk_err_bad_nvpair;
263 }
264 }
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283 char *
284 pcmk__format_nvpair(const char *name, const char *value, const char *units)
285 {
286 return crm_strdup_printf("%s=\"%s%s\"", name, value, units ? units : "");
287 }
288
289
290
291
292
293
294
295
296
297
298
299
300
301 const char *
302 crm_xml_add(xmlNode *node, const char *name, const char *value)
303 {
304 bool dirty = FALSE;
305 xmlAttr *attr = NULL;
306
307 CRM_CHECK(node != NULL, return NULL);
308 CRM_CHECK(name != NULL, return NULL);
309
310 if (value == NULL) {
311 return NULL;
312 }
313
314 if (pcmk__tracking_xml_changes(node, FALSE)) {
315 const char *old = crm_element_value(node, name);
316
317 if (old == NULL || value == NULL || strcmp(old, value) != 0) {
318 dirty = TRUE;
319 }
320 }
321
322 if (dirty && (pcmk__check_acl(node, name, pcmk__xf_acl_create) == FALSE)) {
323 crm_trace("Cannot add %s=%s to %s", name, value, node->name);
324 return NULL;
325 }
326
327 attr = xmlSetProp(node, (pcmkXmlStr) name, (pcmkXmlStr) value);
328 if (dirty) {
329 pcmk__mark_xml_attr_dirty(attr);
330 }
331
332 CRM_CHECK(attr && attr->children && attr->children->content, return NULL);
333 return (char *)attr->children->content;
334 }
335
336
337
338
339
340
341
342
343
344
345
346 const char *
347 crm_xml_replace(xmlNode *node, const char *name, const char *value)
348 {
349 bool dirty = FALSE;
350 xmlAttr *attr = NULL;
351 const char *old_value = NULL;
352
353 CRM_CHECK(node != NULL, return NULL);
354 CRM_CHECK(name != NULL && name[0] != 0, return NULL);
355
356 old_value = crm_element_value(node, name);
357
358
359 CRM_CHECK(old_value != value, return value);
360
361 if (pcmk__check_acl(node, name, pcmk__xf_acl_write) == FALSE) {
362
363 crm_trace("Cannot replace %s=%s to %s", name, value, node->name);
364 return NULL;
365
366 } else if (old_value && !value) {
367 xml_remove_prop(node, name);
368 return NULL;
369 }
370
371 if (pcmk__tracking_xml_changes(node, FALSE)) {
372 if (!old_value || !value || !strcmp(old_value, value)) {
373 dirty = TRUE;
374 }
375 }
376
377 attr = xmlSetProp(node, (pcmkXmlStr) name, (pcmkXmlStr) value);
378 if (dirty) {
379 pcmk__mark_xml_attr_dirty(attr);
380 }
381 CRM_CHECK(attr && attr->children && attr->children->content, return NULL);
382 return (char *) attr->children->content;
383 }
384
385
386
387
388
389
390
391
392
393
394
395
396
397 const char *
398 crm_xml_add_int(xmlNode *node, const char *name, int value)
399 {
400 char *number = pcmk__itoa(value);
401 const char *added = crm_xml_add(node, name, number);
402
403 free(number);
404 return added;
405 }
406
407
408
409
410
411
412
413
414
415
416
417
418
419 const char *
420 crm_xml_add_ms(xmlNode *node, const char *name, guint ms)
421 {
422 char *number = crm_strdup_printf("%u", ms);
423 const char *added = crm_xml_add(node, name, number);
424
425 free(number);
426 return added;
427 }
428
429
430
431 #define LLSTRSIZE 21
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447 const char *
448 crm_xml_add_ll(xmlNode *xml, const char *name, long long value)
449 {
450 char s[LLSTRSIZE] = { '\0', };
451
452 if (snprintf(s, LLSTRSIZE, "%lld", (long long) value) == LLSTRSIZE) {
453 return NULL;
454 }
455 return crm_xml_add(xml, name, s);
456 }
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471 const char *
472 crm_xml_add_timeval(xmlNode *xml, const char *name_sec, const char *name_usec,
473 const struct timeval *value)
474 {
475 const char *added = NULL;
476
477 if (xml && name_sec && value) {
478 added = crm_xml_add_ll(xml, name_sec, (long long) value->tv_sec);
479 if (added && name_usec) {
480
481 crm_xml_add_ll(xml, name_usec, (long long) value->tv_usec);
482 }
483 }
484 return added;
485 }
486
487
488
489
490
491
492
493
494
495 const char *
496 crm_element_value(const xmlNode *data, const char *name)
497 {
498 xmlAttr *attr = NULL;
499
500 if (data == NULL) {
501 crm_err("Couldn't find %s in NULL", name ? name : "<null>");
502 CRM_LOG_ASSERT(data != NULL);
503 return NULL;
504
505 } else if (name == NULL) {
506 crm_err("Couldn't find NULL in %s", crm_element_name(data));
507 return NULL;
508 }
509
510
511
512
513 attr = xmlHasProp((xmlNode *) data, (pcmkXmlStr) name);
514 if (!attr || !attr->children) {
515 return NULL;
516 }
517 return (const char *) attr->children->content;
518 }
519
520
521
522
523
524
525
526
527
528
529
530
531 int
532 crm_element_value_int(const xmlNode *data, const char *name, int *dest)
533 {
534 const char *value = NULL;
535
536 CRM_CHECK(dest != NULL, return -1);
537 value = crm_element_value(data, name);
538 if (value) {
539 long long value_ll;
540
541 if ((pcmk__scan_ll(value, &value_ll, 0LL) != pcmk_rc_ok)
542 || (value_ll < INT_MIN) || (value_ll > INT_MAX)) {
543 *dest = PCMK__PARSE_INT_DEFAULT;
544 } else {
545 *dest = (int) value_ll;
546 return 0;
547 }
548 }
549 return -1;
550 }
551
552
553
554
555
556
557
558
559
560
561
562
563 int
564 crm_element_value_ll(const xmlNode *data, const char *name, long long *dest)
565 {
566 const char *value = NULL;
567
568 CRM_CHECK(dest != NULL, return -1);
569 value = crm_element_value(data, name);
570 if ((value != NULL)
571 && (pcmk__scan_ll(value, dest, PCMK__PARSE_INT_DEFAULT) == pcmk_rc_ok)) {
572 return 0;
573 }
574 return -1;
575 }
576
577
578
579
580
581
582
583
584
585
586
587
588 int
589 crm_element_value_ms(const xmlNode *data, const char *name, guint *dest)
590 {
591 const char *value = NULL;
592 long long value_ll;
593
594 CRM_CHECK(dest != NULL, return -1);
595 *dest = 0;
596 value = crm_element_value(data, name);
597 if ((pcmk__scan_ll(value, &value_ll, 0LL) != pcmk_rc_ok)
598 || (value_ll < 0) || (value_ll > G_MAXUINT)) {
599 return -1;
600 }
601 *dest = (guint) value_ll;
602 return pcmk_ok;
603 }
604
605
606
607
608
609
610
611
612
613
614
615
616 int
617 crm_element_value_epoch(const xmlNode *xml, const char *name, time_t *dest)
618 {
619 long long value_ll = 0;
620
621 if (crm_element_value_ll(xml, name, &value_ll) < 0) {
622 return -1;
623 }
624
625
626
627
628 *dest = (time_t) value_ll;
629 return pcmk_ok;
630 }
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645 int
646 crm_element_value_timeval(const xmlNode *xml, const char *name_sec,
647 const char *name_usec, struct timeval *dest)
648 {
649 long long value_i = 0;
650
651 CRM_CHECK(dest != NULL, return -EINVAL);
652 dest->tv_sec = 0;
653 dest->tv_usec = 0;
654
655 if (xml == NULL) {
656 return pcmk_ok;
657 }
658
659
660
661
662
663
664
665
666 errno = 0;
667 if (crm_element_value_ll(xml, name_sec, &value_i) < 0) {
668 return -errno;
669 }
670 dest->tv_sec = (time_t) value_i;
671
672
673 if (crm_element_value_ll(xml, name_usec, &value_i) < 0) {
674 return -errno;
675 }
676 dest->tv_usec = (suseconds_t) value_i;
677
678 return pcmk_ok;
679 }
680
681
682
683
684
685
686
687
688
689
690
691
692 char *
693 crm_element_value_copy(const xmlNode *data, const char *name)
694 {
695 char *value_copy = NULL;
696
697 pcmk__str_update(&value_copy, crm_element_value(data, name));
698 return value_copy;
699 }
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714 void
715 hash2smartfield(gpointer key, gpointer value, gpointer user_data)
716 {
717 const char *name = key;
718 const char *s_value = value;
719
720 xmlNode *xml_node = user_data;
721
722 if (isdigit(name[0])) {
723 xmlNode *tmp = create_xml_node(xml_node, XML_TAG_PARAM);
724
725 crm_xml_add(tmp, XML_NVPAIR_ATTR_NAME, name);
726 crm_xml_add(tmp, XML_NVPAIR_ATTR_VALUE, s_value);
727
728 } else if (crm_element_value(xml_node, name) == NULL) {
729 crm_xml_add(xml_node, name, s_value);
730 crm_trace("dumped: %s=%s", name, s_value);
731
732 } else {
733 crm_trace("duplicate: %s=%s", name, s_value);
734 }
735 }
736
737
738
739
740
741
742
743
744
745
746
747
748 void
749 hash2field(gpointer key, gpointer value, gpointer user_data)
750 {
751 const char *name = key;
752 const char *s_value = value;
753
754 xmlNode *xml_node = user_data;
755
756 if (crm_element_value(xml_node, name) == NULL) {
757 crm_xml_add(xml_node, name, s_value);
758
759 } else {
760 crm_trace("duplicate: %s=%s", name, s_value);
761 }
762 }
763
764
765
766
767
768
769
770
771
772
773
774
775
776 void
777 hash2metafield(gpointer key, gpointer value, gpointer user_data)
778 {
779 char *crm_name = NULL;
780
781 if (key == NULL || value == NULL) {
782 return;
783 }
784
785
786
787
788 for (crm_name = key; *crm_name; ++crm_name) {
789 if ((*crm_name == '#') || (*crm_name == ':')) {
790 return;
791 }
792 }
793
794 crm_name = crm_meta_name(key);
795 hash2field(crm_name, value, user_data);
796 free(crm_name);
797 }
798
799
800
801
802
803
804
805
806
807
808
809
810
811 xmlNode *
812 crm_create_nvpair_xml(xmlNode *parent, const char *id, const char *name,
813 const char *value)
814 {
815 xmlNode *nvp;
816
817
818
819
820 CRM_CHECK(id || name, return NULL);
821
822 nvp = create_xml_node(parent, XML_CIB_TAG_NVPAIR);
823 CRM_CHECK(nvp, return NULL);
824
825 if (id) {
826 crm_xml_add(nvp, XML_ATTR_ID, id);
827 } else {
828 const char *parent_id = ID(parent);
829
830 crm_xml_set_id(nvp, "%s-%s",
831 (parent_id? parent_id : XML_CIB_TAG_NVPAIR), name);
832 }
833 crm_xml_add(nvp, XML_NVPAIR_ATTR_NAME, name);
834 crm_xml_add(nvp, XML_NVPAIR_ATTR_VALUE, value);
835 return nvp;
836 }
837
838
839
840
841
842
843
844
845
846
847
848
849 void
850 hash2nvpair(gpointer key, gpointer value, gpointer user_data)
851 {
852 const char *name = key;
853 const char *s_value = value;
854 xmlNode *xml_node = user_data;
855
856 crm_create_nvpair_xml(xml_node, name, name, s_value);
857 crm_trace("dumped: name=%s value=%s", name, s_value);
858 }
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874 GHashTable *
875 xml2list(const xmlNode *parent)
876 {
877 xmlNode *child = NULL;
878 xmlAttrPtr pIter = NULL;
879 xmlNode *nvpair_list = NULL;
880 GHashTable *nvpair_hash = pcmk__strkey_table(free, free);
881
882 CRM_CHECK(parent != NULL, return nvpair_hash);
883
884 nvpair_list = find_xml_node(parent, XML_TAG_ATTRS, FALSE);
885 if (nvpair_list == NULL) {
886 crm_trace("No attributes in %s", crm_element_name(parent));
887 crm_log_xml_trace(parent, "No attributes for resource op");
888 }
889
890 crm_log_xml_trace(nvpair_list, "Unpacking");
891
892 for (pIter = pcmk__xe_first_attr(nvpair_list); pIter != NULL;
893 pIter = pIter->next) {
894
895 const char *p_name = (const char *)pIter->name;
896 const char *p_value = pcmk__xml_attr_value(pIter);
897
898 crm_trace("Added %s=%s", p_name, p_value);
899
900 g_hash_table_insert(nvpair_hash, strdup(p_name), strdup(p_value));
901 }
902
903 for (child = pcmk__xml_first_child(nvpair_list); child != NULL;
904 child = pcmk__xml_next(child)) {
905
906 if (strcmp((const char *)child->name, XML_TAG_PARAM) == 0) {
907 const char *key = crm_element_value(child, XML_NVPAIR_ATTR_NAME);
908 const char *value = crm_element_value(child, XML_NVPAIR_ATTR_VALUE);
909
910 crm_trace("Added %s=%s", key, value);
911 if (key != NULL && value != NULL) {
912 g_hash_table_insert(nvpair_hash, strdup(key), strdup(value));
913 }
914 }
915 }
916
917 return nvpair_hash;
918 }
919
920 void
921 pcmk__xe_set_bool_attr(xmlNodePtr node, const char *name, bool value)
922 {
923 crm_xml_add(node, name, value ? XML_BOOLEAN_TRUE : XML_BOOLEAN_FALSE);
924 }
925
926 int
927 pcmk__xe_get_bool_attr(const xmlNode *node, const char *name, bool *value)
928 {
929 const char *xml_value = NULL;
930 int ret, rc;
931
932 if (node == NULL) {
933 return ENODATA;
934 } else if (name == NULL || value == NULL) {
935 return EINVAL;
936 }
937
938 xml_value = crm_element_value(node, name);
939
940 if (xml_value == NULL) {
941 return ENODATA;
942 }
943
944 rc = crm_str_to_boolean(xml_value, &ret);
945 if (rc == 1) {
946 *value = ret;
947 return pcmk_rc_ok;
948 } else {
949 return pcmk_rc_bad_input;
950 }
951 }
952
953 bool
954 pcmk__xe_attr_is_true(const xmlNode *node, const char *name)
955 {
956 bool value = false;
957 int rc;
958
959 rc = pcmk__xe_get_bool_attr(node, name, &value);
960 return rc == pcmk_rc_ok && value == true;
961 }
962
963
964
965
966 #include <crm/common/util_compat.h>
967
968 int
969 pcmk_scan_nvpair(const char *input, char **name, char **value)
970 {
971 return pcmk__scan_nvpair(input, name, value);
972 }
973
974 char *
975 pcmk_format_nvpair(const char *name, const char *value,
976 const char *units)
977 {
978 return pcmk__format_nvpair(name, value, units);
979 }
980
981 char *
982 pcmk_format_named_time(const char *name, time_t epoch_time)
983 {
984 char *now_s = pcmk__epoch2str(&epoch_time, 0);
985 char *result = crm_strdup_printf("%s=\"%s\"", name, pcmk__s(now_s, ""));
986
987 free(now_s);
988 return result;
989 }
990
991
992