block-db 0.2.0

Local, multi-threaded, durable byte DB.
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

// Authors: Robert Lopez

use super::{wal::DataFileState, DataFile};
use crate::error::Error;

impl DataFile {
    /// Replays WAL from Checkpoint, truncating to the last
    /// known length -- to recover to a valid state
    pub async fn recover(&mut self) -> Result<(), Error> {
        let DataFileState {
            used_bytes,
            free_bytes,
            data_blocks,
            free_chunk_offsets,
        } = self.wal.replay(Some(self.options_store.clone())).await?;

        self.size = used_bytes + free_bytes;
        self.used_bytes = used_bytes;
        self.free_bytes = free_bytes;
        self.data_blocks = data_blocks;
        self.free_chunk_offsets = free_chunk_offsets;

        self.truncate(self.size).await
    }
}