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 voter: Voter,
    pub state_machine: StateMachine,
}
impl Effect {
    pub async fn exec(
        self,
        leader_id: NodeAddress,
        leader_term: Term,
        leader_commit: LogIndex,
    ) -> Result<()> {
        let _g = self.voter.vote_sequencer.try_acquire()?;

        let mut ballot = self.voter.read_ballot().await?;
        if leader_term < ballot.cur_term {
            warn!("heartbeat is stale. rejected");
            return Ok(());
        }

        self.voter
            .leader_failure_detector
            .receive_heartbeat(leader_id.clone());

        if leader_term > ballot.cur_term {
            warn!("received heartbeat with newer term. reset ballot");
            ballot.cur_term = leader_term;
            ballot.voted_for = None;
            self.voter.write_election_state(ElectionState::Follower);
        }

        if ballot.voted_for != Some(leader_id.clone()) {
            info!("learn the current leader ({leader_id})");
            ballot.voted_for = Some(leader_id);
        }

        self.voter.write_ballot(ballot).await?;

        let new_commit_index = std::cmp::min(
            leader_commit,
            self.state_machine.get_log_last_index().await?,
        );
        self.state_machine
            .commit_pointer
            .fetch_max(new_commit_index, Ordering::SeqCst);

        Ok(())
    }
}