sorock 0.12.0

A Multi-Raft implementation in Rust
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
46
47
48
49
50

use super::*;

pub struct Effect {
    pub state_machine: StateMachine,
}

impl Effect {
    pub async fn exec(self) -> Result<()> {
        let log_last_index = self.state_machine.get_log_last_index().await?;
        let snapshot_index = match self
            .state_machine
            .find_last_snapshot_index(log_last_index)
            .await?
        {
            Some(x) => {
                info!("restore state: found snapshot_index={x}");
                x
            }
            None => {
                // If the log is new, insert an initial snapshot entry.
                let init_command = Command::serialize(Command::Snapshot {
                    membership: HashSet::new(),
                });
                let snapshot = Entry {
                    prev_clock: Clock { term: 0, index: 0 },
                    this_clock: Clock { term: 0, index: 1 },
                    command: init_command.clone(),
                };
                self.state_machine.insert_entry(snapshot).await?;
                1
            }
        };
        self.state_machine
            .snapshot_pointer
            .store(snapshot_index, Ordering::SeqCst);

        self.state_machine
            .commit_pointer
            .store(snapshot_index - 1, Ordering::SeqCst);
        self.state_machine
            .kernel_pointer
            .store(snapshot_index - 1, Ordering::SeqCst);
        self.state_machine
            .application_pointer
            .store(snapshot_index - 1, Ordering::SeqCst);

        info!("restore state: snapshot_index={snapshot_index}");
        Ok(())
    }
}