vecdb 0.10.2

High-performance mutable persistent vectors built on rawdb
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use crate::{
    AnyStoredVec, ChangeCursor, ReadWriteBaseVec, Result, VecIndex, VecValue, WritableVec,
};

use super::{super::CompressionStrategy, ReadWriteCompressedVec};

impl<I, T, S> ReadWriteCompressedVec<I, T, S>
where
    I: VecIndex,
    T: VecValue,
    S: CompressionStrategy<T>,
{
    pub(super) fn serialize_compressed_changes(&self) -> Result<Vec<u8>> {
        self.base.serialize_changes(
            Self::SIZE_OF_T,
            |from, to| self.collect_stored_range(from, to),
            |vals, buf| {
                for v in vals {
                    S::write_to_vec(v, buf);
                }
            },
        )
    }

    pub(super) fn deserialize_then_undo_changes(&mut self, bytes: &[u8]) -> Result<()> {
        let mut c = ChangeCursor::new(bytes);
        let change = ReadWriteBaseVec::<I, T>::parse_change_data(&mut c, Self::SIZE_OF_T, |b| {
            S::read(b)
        })?;

        // No overlay map: truncated values ride in `pushed` and `stored_len`
        // is clamped to where disk still agrees with the rolled-back state.
        let (stored_len, pushed) = if change.truncated_values.is_empty() {
            (change.prev_stored_len, change.prev_pushed)
        } else {
            let agree_at = change.truncated_start.min(self.real_stored_len());
            let mut buf = change.truncated_values;
            buf.extend(change.prev_pushed);
            (agree_at, buf)
        };
        self.base.apply_rollback(change.prev_stamp, stored_len, pushed);

        Ok(())
    }
}