ruaft/src/term_marker.rs

use std::sync::Arc;

use parking_lot::Mutex;

use crate::election::ElectionState;
use crate::{Persister, Raft, RaftState, State, Term};
use serde::Serialize;

/// A closure that updates the `Term` of the `RaftState`.
#[derive(Clone)]
pub(crate) struct TermMarker<Command> {
    rf: Arc<Mutex<RaftState<Command>>>,
    election: Arc<ElectionState>,
    persister: Arc<dyn Persister>,
}

impl<Command: Clone + Serialize> TermMarker<Command> {
    pub fn mark(&self, term: Term) {
        let mut rf = self.rf.lock();
        mark_term(&mut rf, &self.election, self.persister.as_ref(), term)
    }
}

impl<Command: Clone + Serialize> Raft<Command> {
    /// Create a `TermMarker` that can be passed to tasks.
    pub(crate) fn term_marker(&self) -> TermMarker<Command> {
        TermMarker {
            rf: self.inner_state.clone(),
            election: self.election.clone(),
            persister: self.persister.clone(),
        }
    }
}

/// Update the term of the `RaftState`.
pub(crate) fn mark_term<Command: Clone + Serialize>(
    rf: &mut RaftState<Command>,
    election: &ElectionState,
    persister: &dyn Persister,
    term: Term,
) {
    if term > rf.current_term {
        rf.current_term = term;
        rf.voted_for = None;
        rf.state = State::Follower;

        election.reset_election_timer();
        persister.save_state(rf.persisted_state().into());
    }
}