25 #include "dbus-marshal-recursive.h"
26 #include "dbus-marshal-basic.h"
27 #include "dbus-signature.h"
28 #include "dbus-internals.h"
43 int start_after_new_pos,
44 int start_after_new_len,
48 #define RECURSIVE_MARSHAL_READ_TRACE 0
51 #define RECURSIVE_MARSHAL_WRITE_TRACE 0
75 apply_and_free_fixups (
DBusList **fixups,
80 #if RECURSIVE_MARSHAL_WRITE_TRACE
82 _dbus_verbose (
" %d FIXUPS to apply\n",
99 #if RECURSIVE_MARSHAL_WRITE_TRACE
100 _dbus_verbose (
" applying FIXUP to reader %p at pos %d new_len = %d old len %d\n",
138 element_type_get_alignment (
const DBusString *str,
174 struct_or_dict_entry_types_only_reader_recurse (
DBusTypeReader *sub,
177 base_reader_recurse (sub, parent);
181 _dbus_string_get_byte (sub->
type_str,
191 struct_or_dict_entry_types_only_reader_recurse (sub, parent);
201 base_reader_recurse (sub, parent);
213 #define ARRAY_READER_LEN_POS(reader) \
214 ((reader)->u.array.start_pos - ((int)(reader)->array_len_offset) - 4)
219 dbus_uint32_t array_len;
224 _dbus_assert (_DBUS_ALIGN_VALUE (len_pos, 4) == (
unsigned) len_pos);
226 _dbus_string_get_const_data_len (reader->
value_str, len_pos, 4));
228 #if RECURSIVE_MARSHAL_READ_TRACE
229 _dbus_verbose (
" reader %p len_pos %d array len %u len_offset %d\n",
245 array_types_only_reader_recurse (sub, parent);
253 alignment = element_type_get_alignment (sub->
type_str,
262 #if RECURSIVE_MARSHAL_READ_TRACE
263 _dbus_verbose (
" type reader %p array start = %d len_offset = %d array len = %d array element type = %s\n",
265 sub->
u.array.start_pos,
267 array_reader_get_array_len (sub),
278 int contained_alignment;
280 base_reader_recurse (sub, parent);
298 #if RECURSIVE_MARSHAL_READ_TRACE
299 _dbus_verbose (
" type reader %p variant containing '%s'\n",
301 _dbus_string_get_const_data_len (sub->
type_str,
315 end_pos = reader->
u.array.start_pos + array_reader_get_array_len (reader);
324 skip_one_complete_type (
const DBusString *type_str,
343 const unsigned char *p;
344 const unsigned char *start;
350 p = start + *type_pos;
420 *type_pos = (int) (p - start);
424 find_len_of_complete_type (
const DBusString *type_str,
431 skip_one_complete_type (type_str, &end);
433 return end - type_pos;
440 switch (current_type)
507 base_reader_next (reader, current_type);
528 base_reader_next (reader, current_type);
562 end_pos = reader->
u.array.start_pos + array_reader_get_array_len (reader);
564 #if RECURSIVE_MARSHAL_READ_TRACE
565 _dbus_verbose (
" reader %p array next START start_pos = %d end_pos = %d value_pos = %d current_type = %s\n",
567 reader->
u.array.start_pos,
617 #if RECURSIVE_MARSHAL_READ_TRACE
618 _dbus_verbose (
" reader %p array next END start_pos = %d end_pos = %d value_pos = %d current_type = %s\n",
620 reader->
u.array.start_pos,
629 skip_one_complete_type (reader->
type_str,
653 struct_or_dict_entry_reader_recurse,
661 struct_or_dict_entry_types_only_reader_recurse,
669 struct_or_dict_entry_reader_recurse,
671 dict_entry_reader_next
675 "dict_entry types", 5,
677 struct_or_dict_entry_types_only_reader_recurse,
679 dict_entry_reader_next
685 array_reader_recurse,
686 array_reader_check_finished,
693 array_types_only_reader_recurse,
695 array_types_only_reader_next
701 variant_reader_recurse,
706 #ifndef DBUS_DISABLE_ASSERT
708 all_reader_classes[] = {
710 &body_types_only_reader_class,
711 &struct_reader_class,
712 &struct_types_only_reader_class,
713 &dict_entry_reader_class,
714 &dict_entry_types_only_reader_class,
716 &array_types_only_reader_class,
717 &variant_reader_class
739 reader->
klass = &body_reader_class;
741 reader_init (reader, byte_order, type_str, type_pos,
742 value_str, value_pos);
744 #if RECURSIVE_MARSHAL_READ_TRACE
745 _dbus_verbose (
" type reader %p init type_pos = %d value_pos = %d remaining sig '%s'\n",
764 reader->
klass = &body_types_only_reader_class;
766 reader_init (reader, DBUS_COMPILER_BYTE_ORDER ,
769 #if RECURSIVE_MARSHAL_READ_TRACE
770 _dbus_verbose (
" type reader %p init types only type_pos = %d remaining sig '%s'\n",
803 _dbus_verbose (
" type reader %p current type_pos = %d type = %s\n",
853 const unsigned char **value_location)
857 *value_location = _dbus_string_get_const_data_len (reader->
value_str,
885 #if RECURSIVE_MARSHAL_READ_TRACE
886 _dbus_verbose (
" type reader %p read basic type_pos = %d value_pos = %d remaining sig '%s'\n",
904 return array_reader_get_array_len (reader);
946 total_len = array_reader_get_array_len (reader);
947 end_pos = reader->
u.array.start_pos + total_len;
948 remaining_len = end_pos - reader->
value_pos;
950 #if RECURSIVE_MARSHAL_READ_TRACE
951 _dbus_verbose (
"end_pos %d total_len %d remaining_len %d value_pos %d\n",
952 end_pos, total_len, remaining_len, reader->
value_pos);
957 if (remaining_len == 0)
961 (
void*) _dbus_string_get_const_data_len (reader->
value_str,
965 *n_elements = remaining_len / alignment;
968 #if RECURSIVE_MARSHAL_READ_TRACE
969 _dbus_verbose (
" type reader %p read fixed array type_pos = %d value_pos = %d remaining sig '%s'\n",
999 sub->
klass = &struct_types_only_reader_class;
1001 sub->
klass = &struct_reader_class;
1005 sub->
klass = &dict_entry_types_only_reader_class;
1007 sub->
klass = &dict_entry_reader_class;
1011 sub->
klass = &array_types_only_reader_class;
1013 sub->
klass = &array_reader_class;
1019 sub->
klass = &variant_reader_class;
1023 #ifndef DBUS_DISABLE_CHECKS
1035 #if RECURSIVE_MARSHAL_READ_TRACE
1036 _dbus_verbose (
" type reader %p RECURSED type_pos = %d value_pos = %d remaining sig '%s'\n",
1057 #if RECURSIVE_MARSHAL_READ_TRACE
1058 _dbus_verbose (
" type reader %p START next() { type_pos = %d value_pos = %d remaining sig '%s' current_type = %s\n",
1069 #if RECURSIVE_MARSHAL_READ_TRACE
1070 _dbus_verbose (
" type reader %p END next() type_pos = %d value_pos = %d remaining sig '%s' current_type = %s\n",
1172 orig_len = _dbus_string_get_length (&block->
replacement);
1174 realign_reader = *realign_root;
1176 #if RECURSIVE_MARSHAL_WRITE_TRACE
1177 _dbus_verbose (
"INITIALIZING replacement block writer %p at value_pos %d\n",
1178 &writer, _dbus_string_get_length (&block->
replacement));
1189 #if RECURSIVE_MARSHAL_WRITE_TRACE
1190 _dbus_verbose (
"COPYING from reader at value_pos %d to writer %p starting after value_pos %d\n",
1194 if (!_dbus_type_writer_write_reader_partial (&writer,
1202 #if RECURSIVE_MARSHAL_WRITE_TRACE
1203 _dbus_verbose (
"REPLACEMENT at padding %d len %d\n", block->
padding,
1207 _dbus_verbose (
"TO BE REPLACED at value_pos = %d (align pad %d) len %d realign_reader.value_pos %d\n",
1227 apply_and_free_fixups (&fixups, reader);
1233 free_fixups (&fixups);
1280 if (!replacement_block_init (&block, reader))
1284 #if RECURSIVE_MARSHAL_WRITE_TRACE
1285 _dbus_verbose (
"INITIALIZING writer %p to write basic value at value_pos %d of replacement string\n",
1286 &writer, _dbus_string_get_length (&block.
replacement));
1294 #if RECURSIVE_MARSHAL_WRITE_TRACE
1295 _dbus_verbose (
"WRITING basic value to writer %p (replacement string)\n", &writer);
1300 if (!replacement_block_replace (&block,
1308 replacement_block_free (&block);
1372 #if RECURSIVE_MARSHAL_WRITE_TRACE
1373 _dbus_verbose (
" SET BASIC type reader %p type_pos = %d value_pos = %d remaining sig '%s' realign_root = %p with value_pos %d current_type = %s\n",
1377 realign_root ? realign_root->
value_pos : -1,
1380 _dbus_string_get_length (realign_root->
value_str) -
1388 reader_set_basic_fixed_length (reader, current_type, value);
1394 return reader_set_basic_variable_length (reader, current_type,
1395 value, realign_root);
1428 if (!replacement_block_init (&block, reader))
1431 if (!replacement_block_replace (&block,
1439 replacement_block_free (&block);
1506 #if RECURSIVE_MARSHAL_WRITE_TRACE
1507 _dbus_verbose (
"writer %p init remaining sig '%s'\n", writer,
1531 NULL, 0, value_str, value_pos);
1590 value_str, value_pos);
1596 _dbus_type_writer_write_basic_no_typecode (
DBusTypeWriter *writer,
1654 #ifndef DBUS_DISABLE_CHECKS
1665 "The overall signature expected here was '%s' and we are on byte %d of that signature.\n",
1671 "The overall signature expected here was '%s' and we are on byte %d of that signature.\n",
1680 #if RECURSIVE_MARSHAL_WRITE_TRACE
1681 _dbus_verbose (
" type writer %p recurse parent %s type_pos = %d value_pos = %d is_expectation = %d remaining sig '%s' enabled = %d\n",
1689 _dbus_verbose (
" type writer %p recurse sub %s type_pos = %d value_pos = %d is_expectation = %d enabled = %d\n",
1707 #if RECURSIVE_MARSHAL_WRITE_TRACE
1708 _dbus_verbose (
" type writer %p write_or_verify start type_pos = %d remaining sig '%s' enabled = %d\n",
1721 #ifndef DBUS_DISABLE_CHECKS
1727 if (expected != typecode)
1731 "The overall signature expected here was '%s' and we are on byte %d of that signature.\n",
1735 _dbus_warn_check_failed (
"Array or variant type wasn't expecting any more values to be written into it, but a value %s was written.\n"
1736 "The overall signature expected here was '%s' and we are on byte %d of that signature.\n",
1761 #if RECURSIVE_MARSHAL_WRITE_TRACE
1762 _dbus_verbose (
" type writer %p write_or_verify end type_pos = %d remaining sig '%s'\n",
1774 int contained_type_start,
1775 int contained_type_len,
1790 if (!write_or_verify_typecode (sub, begin_char))
1810 int contained_type_start,
1811 int contained_type_len,
1815 dbus_uint32_t value = 0;
1819 #ifndef DBUS_DISABLE_CHECKS
1824 contained_type_start,
1827 writer->
u.array.element_type_pos + 1))
1829 _dbus_warn_check_failed (
"Writing an array of '%s' but this is incompatible with the expected type of elements in the parent array\n",
1830 _dbus_string_get_const_data_len (contained_type,
1831 contained_type_start,
1832 contained_type_len));
1838 if (writer->
enabled && !is_array_append)
1852 sub->
u.array.element_type_pos = sub->
type_pos;
1869 contained_type_start, contained_type_len,
1871 sub->
u.array.element_type_pos))
1881 writer->
type_pos += 1 + contained_type_len;
1889 sub->
u.array.len_pos = _DBUS_ALIGN_VALUE (sub->
value_pos, 4);
1891 if (is_array_append)
1908 alignment = element_type_get_alignment (contained_type, contained_type_start);
1910 aligned = _DBUS_ALIGN_VALUE (sub->
value_pos, alignment);
1913 if (!is_array_append)
1927 if (is_array_append)
1931 _dbus_assert (_DBUS_ALIGN_VALUE (sub->
u.array.len_pos, 4) ==
1932 (
unsigned) sub->
u.array.len_pos);
1934 _dbus_string_get_const_data_len (sub->
value_str,
1935 sub->
u.array.len_pos,
1944 sub->
u.array.len_pos = -1;
1951 #if RECURSIVE_MARSHAL_WRITE_TRACE
1952 _dbus_verbose (
" type writer %p recurse array done remaining sig '%s' array start_pos = %d len_pos = %d value_pos = %d\n", sub,
1956 sub->
u.array.start_pos, sub->
u.array.len_pos, sub->
value_pos);
1983 int contained_type_start,
1984 int contained_type_len,
1987 int contained_alignment;
2017 contained_type_len))
2055 int contained_type_start,
2056 int contained_type_len,
2060 writer_recurse_init_and_check (writer, container_type, sub);
2062 switch (container_type)
2065 return writer_recurse_struct_or_dict_entry (writer,
2068 contained_type_start, contained_type_len,
2072 return writer_recurse_struct_or_dict_entry (writer,
2075 contained_type_start, contained_type_len,
2079 return writer_recurse_array (writer,
2080 contained_type, contained_type_start, contained_type_len,
2081 sub, is_array_append);
2084 return writer_recurse_variant (writer,
2085 contained_type, contained_type_start, contained_type_len,
2109 int contained_type_start,
2112 int contained_type_len;
2115 contained_type_len = find_len_of_complete_type (contained_type, contained_type_start);
2117 contained_type_len = 0;
2119 return _dbus_type_writer_recurse_contained_len (writer, container_type,
2121 contained_type_start,
2142 int contained_type_start,
2145 int contained_type_len;
2148 contained_type_len = find_len_of_complete_type (contained_type, contained_type_start);
2150 contained_type_len = 0;
2152 return _dbus_type_writer_recurse_contained_len (writer,
DBUS_TYPE_ARRAY,
2154 contained_type_start,
2164 return writer->
value_pos - writer->
u.array.start_pos;
2183 #if RECURSIVE_MARSHAL_WRITE_TRACE
2184 _dbus_verbose (
" type writer %p unrecurse type_pos = %d value_pos = %d is_expectation = %d container_type = %s\n",
2187 _dbus_verbose (
" type writer %p unrecurse sub type_pos = %d value_pos = %d is_expectation = %d container_type = %s\n",
2205 if (sub->
u.array.len_pos >= 0)
2210 len = writer_get_array_len (sub);
2212 sub->
u.array.len_pos,
2215 #if RECURSIVE_MARSHAL_WRITE_TRACE
2216 _dbus_verbose (
" filled in sub array len to %u at len_pos %d\n",
2217 len, sub->
u.array.len_pos);
2220 #if RECURSIVE_MARSHAL_WRITE_TRACE
2223 _dbus_verbose (
" not filling in sub array len because we were disabled when we passed the len\n");
2288 #if RECURSIVE_MARSHAL_WRITE_TRACE
2289 _dbus_verbose (
" type writer %p unrecursed type_pos = %d value_pos = %d remaining sig '%s'\n",
2323 if (!_dbus_type_writer_write_basic_no_typecode (writer, type, value))
2326 if (!write_or_verify_typecode (writer, type))
2332 #if RECURSIVE_MARSHAL_WRITE_TRACE
2333 _dbus_verbose (
" type writer %p basic type_pos = %d value_pos = %d is_expectation = %d enabled = %d\n",
2366 #if RECURSIVE_MARSHAL_WRITE_TRACE
2367 _dbus_verbose (
" type writer %p entering fixed multi type_pos = %d value_pos = %d n_elements %d\n",
2371 if (!write_or_verify_typecode (writer, element_type))
2386 #if RECURSIVE_MARSHAL_WRITE_TRACE
2387 _dbus_verbose (
" type writer %p fixed multi written new type_pos = %d new value_pos = %d n_elements %d\n",
2401 if (!writer->
enabled && _dbus_type_reader_greater_than (reader, start_after))
2403 _dbus_type_writer_set_enabled (writer,
TRUE);
2404 #if RECURSIVE_MARSHAL_WRITE_TRACE
2405 _dbus_verbose (
"ENABLING writer %p at %d because reader at value_pos %d is after reader at value_pos %d\n",
2410 _dbus_assert ((!writer->
enabled && !_dbus_type_reader_greater_than (reader, start_after)) ||
2411 (writer->
enabled && _dbus_type_reader_greater_than (reader, start_after)));
2446 int start_after_new_pos,
2447 int start_after_new_len,
2464 int reader_array_len_pos;
2465 int reader_array_start_pos;
2473 if (!inside_start_after && start_after &&
2477 this_is_start_after =
TRUE;
2479 this_is_start_after =
FALSE;
2486 reader_array_start_pos = subreader.
u.array.start_pos;
2491 reader_array_len_pos = -1;
2492 reader_array_start_pos = -1;
2496 &sig_start, &sig_len);
2498 #if RECURSIVE_MARSHAL_WRITE_TRACE
2499 _dbus_verbose (
"about to recurse into %s reader at %d subreader at %d writer at %d start_after reader at %d write target len %d inside_start_after = %d this_is_start_after = %d\n",
2504 start_after ? start_after->
value_pos : -1,
2505 _dbus_string_get_length (writer->
value_str),
2506 inside_start_after, this_is_start_after);
2509 if (!inside_start_after && !this_is_start_after)
2510 enable_if_after (writer, &subreader, start_after);
2511 enabled_at_recurse = writer->
enabled;
2512 if (!_dbus_type_writer_recurse_contained_len (writer, current_type,
2513 sig_str, sig_start, sig_len,
2517 #if RECURSIVE_MARSHAL_WRITE_TRACE
2518 _dbus_verbose (
"recursed into subwriter at %d write target len %d\n",
2520 _dbus_string_get_length (subwriter.
value_str));
2523 if (!writer_write_reader_helper (&subwriter, &subreader, start_after,
2524 start_after_new_pos, start_after_new_len,
2526 inside_start_after ||
2527 this_is_start_after))
2530 #if RECURSIVE_MARSHAL_WRITE_TRACE
2531 _dbus_verbose (
"about to unrecurse from %s subreader at %d writer at %d subwriter at %d write target len %d\n",
2536 _dbus_string_get_length (writer->
value_str));
2539 if (!inside_start_after && !this_is_start_after)
2540 enable_if_after (writer, &subreader, start_after);
2541 past_start_after = writer->
enabled;
2550 if (start_after !=
NULL &&
2551 !enabled_at_recurse && past_start_after &&
2556 int bytes_written_after_start_after;
2557 int bytes_before_start_after;
2564 bytes_written_after_start_after = writer_get_array_len (&subwriter);
2566 bytes_before_start_after =
2567 start_after->
value_pos - reader_array_start_pos;
2571 bytes_before_start_after +
2572 start_after_new_len +
2573 bytes_written_after_start_after;
2579 _dbus_string_get_const_data_len (reader->
value_str,
2582 if (old_len != fixup.
new_len && !append_fixup (fixups, &fixup))
2585 #if RECURSIVE_MARSHAL_WRITE_TRACE
2586 _dbus_verbose (
"Generated fixup len_pos_in_reader = %d new_len = %d reader_array_start_pos = %d start_after->value_pos = %d bytes_before_start_after = %d start_after_new_len = %d bytes_written_after_start_after = %d\n",
2589 reader_array_start_pos,
2591 bytes_before_start_after,
2592 start_after_new_len,
2593 bytes_written_after_start_after);
2603 #if RECURSIVE_MARSHAL_WRITE_TRACE
2604 _dbus_verbose (
"Reading basic value %s at %d\n",
2611 #if RECURSIVE_MARSHAL_WRITE_TRACE
2612 _dbus_verbose (
"Writing basic value %s at %d write target len %d inside_start_after = %d\n",
2615 _dbus_string_get_length (writer->
value_str),
2616 inside_start_after);
2618 if (!inside_start_after)
2619 enable_if_after (writer, reader, start_after);
2622 #if RECURSIVE_MARSHAL_WRITE_TRACE
2623 _dbus_verbose (
"Wrote basic value %s, new value_pos %d write target len %d\n",
2626 _dbus_string_get_length (writer->
value_str));
2637 apply_and_free_fixups (fixups,
NULL);
2677 int start_after_new_pos,
2678 int start_after_new_len,
2688 orig_type_len = _dbus_string_get_length (writer->
type_str);
2689 orig_value_len = _dbus_string_get_length (writer->
value_str);
2690 orig_enabled = writer->
enabled;
2693 _dbus_type_writer_set_enabled (writer,
FALSE);
2695 if (!writer_write_reader_helper (writer, reader, start_after,
2696 start_after_new_pos,
2697 start_after_new_len,
2701 _dbus_type_writer_set_enabled (writer, orig_enabled);
2707 new_bytes = _dbus_string_get_length (writer->
type_str) - orig_type_len;
2710 new_bytes = _dbus_string_get_length (writer->
value_str) - orig_value_len;
2731 return _dbus_type_writer_write_reader_partial (writer, reader,
NULL, 0, 0,
NULL);