1*890232f2SAndroid Build Coastguard Worker // Copyright 2019 Google LLC
2*890232f2SAndroid Build Coastguard Worker //
3*890232f2SAndroid Build Coastguard Worker // Licensed under the Apache License, Version 2.0 (the "License");
4*890232f2SAndroid Build Coastguard Worker // you may not use this file except in compliance with the License.
5*890232f2SAndroid Build Coastguard Worker // You may obtain a copy of the License at
6*890232f2SAndroid Build Coastguard Worker //
7*890232f2SAndroid Build Coastguard Worker // https://www.apache.org/licenses/LICENSE-2.0
8*890232f2SAndroid Build Coastguard Worker //
9*890232f2SAndroid Build Coastguard Worker // Unless required by applicable law or agreed to in writing, software
10*890232f2SAndroid Build Coastguard Worker // distributed under the License is distributed on an "AS IS" BASIS,
11*890232f2SAndroid Build Coastguard Worker // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12*890232f2SAndroid Build Coastguard Worker // See the License for the specific language governing permissions and
13*890232f2SAndroid Build Coastguard Worker // limitations under the License.
14*890232f2SAndroid Build Coastguard Worker
15*890232f2SAndroid Build Coastguard Worker use super::{Builder, Pushable, Value, VectorBuilder};
16*890232f2SAndroid Build Coastguard Worker
17*890232f2SAndroid Build Coastguard Worker /// Builds a Flexbuffer map, returned by a [Builder](struct.Builder.html).
18*890232f2SAndroid Build Coastguard Worker ///
19*890232f2SAndroid Build Coastguard Worker /// ## Side effect when dropped:
20*890232f2SAndroid Build Coastguard Worker /// When this is dropped, or `end_map` is called, the map is
21*890232f2SAndroid Build Coastguard Worker /// commited to the buffer. If this map is the root of the flexbuffer, then the
22*890232f2SAndroid Build Coastguard Worker /// root is written and the flexbuffer is complete.
23*890232f2SAndroid Build Coastguard Worker /// ## Panics:
24*890232f2SAndroid Build Coastguard Worker /// - Duplicate keys will result in a panic in both debug and release mode.
25*890232f2SAndroid Build Coastguard Worker /// - Keys with internal nulls results in a panic in debug mode and result in silent truncaction
26*890232f2SAndroid Build Coastguard Worker /// in release mode.
27*890232f2SAndroid Build Coastguard Worker pub struct MapBuilder<'a> {
28*890232f2SAndroid Build Coastguard Worker pub(super) builder: &'a mut Builder,
29*890232f2SAndroid Build Coastguard Worker // If the root is this map then start == None. Otherwise start is the
30*890232f2SAndroid Build Coastguard Worker // number of values in the 'values stack' before adding this map.
31*890232f2SAndroid Build Coastguard Worker pub(super) start: Option<usize>,
32*890232f2SAndroid Build Coastguard Worker }
33*890232f2SAndroid Build Coastguard Worker impl<'a> MapBuilder<'a> {
34*890232f2SAndroid Build Coastguard Worker /// Push `p` onto this map with key `key`.
35*890232f2SAndroid Build Coastguard Worker /// This will panic (in debug mode) if `key` contains internal nulls.
36*890232f2SAndroid Build Coastguard Worker #[inline]
push<P: Pushable>(&mut self, key: &str, p: P)37*890232f2SAndroid Build Coastguard Worker pub fn push<P: Pushable>(&mut self, key: &str, p: P) {
38*890232f2SAndroid Build Coastguard Worker self.builder.push_key(key);
39*890232f2SAndroid Build Coastguard Worker self.builder.push(p);
40*890232f2SAndroid Build Coastguard Worker }
41*890232f2SAndroid Build Coastguard Worker /// Starts a nested vector that will be pushed onto this map
42*890232f2SAndroid Build Coastguard Worker /// with key `key` when it is dropped.
43*890232f2SAndroid Build Coastguard Worker ///
44*890232f2SAndroid Build Coastguard Worker /// This will panic (in debug mode) if `key` contains internal nulls.
45*890232f2SAndroid Build Coastguard Worker #[inline]
start_vector(&mut self, key: &str) -> VectorBuilder46*890232f2SAndroid Build Coastguard Worker pub fn start_vector(&mut self, key: &str) -> VectorBuilder {
47*890232f2SAndroid Build Coastguard Worker // Push the key that refers to this nested vector.
48*890232f2SAndroid Build Coastguard Worker self.builder.push_key(key);
49*890232f2SAndroid Build Coastguard Worker // Nested vector.
50*890232f2SAndroid Build Coastguard Worker let start = Some(self.builder.values.len());
51*890232f2SAndroid Build Coastguard Worker VectorBuilder {
52*890232f2SAndroid Build Coastguard Worker builder: &mut self.builder,
53*890232f2SAndroid Build Coastguard Worker start,
54*890232f2SAndroid Build Coastguard Worker }
55*890232f2SAndroid Build Coastguard Worker }
56*890232f2SAndroid Build Coastguard Worker /// Starts a nested map which that will be pushed onto this map
57*890232f2SAndroid Build Coastguard Worker /// with key `key` when it is dropped.
58*890232f2SAndroid Build Coastguard Worker ///
59*890232f2SAndroid Build Coastguard Worker /// This will panic (in debug mode) if `key` contains internal nulls.
60*890232f2SAndroid Build Coastguard Worker #[inline]
start_map(&mut self, key: &str) -> MapBuilder61*890232f2SAndroid Build Coastguard Worker pub fn start_map(&mut self, key: &str) -> MapBuilder {
62*890232f2SAndroid Build Coastguard Worker // Push the key that refers to this nested vector.
63*890232f2SAndroid Build Coastguard Worker self.builder.push_key(key);
64*890232f2SAndroid Build Coastguard Worker // Nested map.
65*890232f2SAndroid Build Coastguard Worker let start = Some(self.builder.values.len());
66*890232f2SAndroid Build Coastguard Worker MapBuilder {
67*890232f2SAndroid Build Coastguard Worker builder: &mut self.builder,
68*890232f2SAndroid Build Coastguard Worker start,
69*890232f2SAndroid Build Coastguard Worker }
70*890232f2SAndroid Build Coastguard Worker }
71*890232f2SAndroid Build Coastguard Worker /// `end_map` sorts the map by key and writes it to the buffer. This happens anyway
72*890232f2SAndroid Build Coastguard Worker /// when the map builder is dropped.
73*890232f2SAndroid Build Coastguard Worker #[inline]
end_map(self)74*890232f2SAndroid Build Coastguard Worker pub fn end_map(self) {}
75*890232f2SAndroid Build Coastguard Worker }
76*890232f2SAndroid Build Coastguard Worker impl<'a> Drop for MapBuilder<'a> {
77*890232f2SAndroid Build Coastguard Worker #[inline]
drop(&mut self)78*890232f2SAndroid Build Coastguard Worker fn drop(&mut self) {
79*890232f2SAndroid Build Coastguard Worker self.builder.end_map_or_vector(true, self.start);
80*890232f2SAndroid Build Coastguard Worker }
81*890232f2SAndroid Build Coastguard Worker }
82*890232f2SAndroid Build Coastguard Worker
83*890232f2SAndroid Build Coastguard Worker // Read known keys / strings as iterators over bytes -- skipping utf8 validation and strlen.
get_key(buffer: &[u8], address: usize) -> impl Iterator<Item = &u8>84*890232f2SAndroid Build Coastguard Worker pub(super) fn get_key(buffer: &[u8], address: usize) -> impl Iterator<Item = &u8> {
85*890232f2SAndroid Build Coastguard Worker buffer[address..].iter().take_while(|&&b| b != b'\0')
86*890232f2SAndroid Build Coastguard Worker }
87*890232f2SAndroid Build Coastguard Worker
88*890232f2SAndroid Build Coastguard Worker // `values` is assumed to be of the format [key1, value1, ..., keyN, valueN].
89*890232f2SAndroid Build Coastguard Worker // The keys refer to cstrings in `buffer`. When this function returns,
90*890232f2SAndroid Build Coastguard Worker // `values` is sorted in place by key.
sort_map_by_keys(values: &mut [Value], buffer: &[u8])91*890232f2SAndroid Build Coastguard Worker pub(super) fn sort_map_by_keys(values: &mut [Value], buffer: &[u8]) {
92*890232f2SAndroid Build Coastguard Worker debug_assert_eq!(values.len() % 2, 0);
93*890232f2SAndroid Build Coastguard Worker debug_assert!(values.iter().step_by(2).all(Value::is_key));
94*890232f2SAndroid Build Coastguard Worker let raw_pairs = values.as_mut_ptr() as *mut [Value; 2];
95*890232f2SAndroid Build Coastguard Worker let pairs_len = values.len() / 2;
96*890232f2SAndroid Build Coastguard Worker // Unsafe code needed to treat the slice as key-value pairs when sorting in place. This is
97*890232f2SAndroid Build Coastguard Worker // preferred over custom sorting or adding another dependency. By construction, this part
98*890232f2SAndroid Build Coastguard Worker // of the values stack must be alternating (key, value) pairs. The public API must not be
99*890232f2SAndroid Build Coastguard Worker // able to trigger the above debug_assets that protect this unsafe usage.
100*890232f2SAndroid Build Coastguard Worker let pairs: &mut [[Value; 2]] = unsafe { std::slice::from_raw_parts_mut(raw_pairs, pairs_len) };
101*890232f2SAndroid Build Coastguard Worker #[rustfmt::skip]
102*890232f2SAndroid Build Coastguard Worker pairs.sort_unstable_by(|[key1, _], [key2, _]| {
103*890232f2SAndroid Build Coastguard Worker if let Value::Key(a1) = *key1 {
104*890232f2SAndroid Build Coastguard Worker if let Value::Key(a2) = *key2 {
105*890232f2SAndroid Build Coastguard Worker let s1 = get_key(buffer, a1);
106*890232f2SAndroid Build Coastguard Worker let s2 = get_key(buffer, a2);
107*890232f2SAndroid Build Coastguard Worker let ord = s1.cmp(s2);
108*890232f2SAndroid Build Coastguard Worker if ord == std::cmp::Ordering::Equal {
109*890232f2SAndroid Build Coastguard Worker let dup: String = get_key(buffer, a1).map(|&b| b as char).collect();
110*890232f2SAndroid Build Coastguard Worker panic!("Duplicated key in map {:?}", dup);
111*890232f2SAndroid Build Coastguard Worker }
112*890232f2SAndroid Build Coastguard Worker return ord;
113*890232f2SAndroid Build Coastguard Worker }
114*890232f2SAndroid Build Coastguard Worker }
115*890232f2SAndroid Build Coastguard Worker unreachable!();
116*890232f2SAndroid Build Coastguard Worker });
117*890232f2SAndroid Build Coastguard Worker }
118