refactor: Mailbox<NormalRequest> -> Mutex<RawNode>

src/main.rs

@@ -454,7 +454,7 @@ fn start_boot(args: &args::Run) {
         init_entries.push({
             let ctx = traft::EntryContextNormal {
                 op: traft::Op::PersistPeer { peer },
-                lc: lc.clone(),
+                lc,
             };
             let e = traft::Entry {
                 entry_type: raft::EntryType::EntryNormal,
@@ -601,6 +601,8 @@ fn postjoin(args: &args::Run) {
 
     let node = traft::node::Node::new(&raft_cfg);
     let node = node.expect("failed initializing raft node");
+    traft::node::set_global(node);
+    let node = traft::node::global().unwrap();
 
     let cs = traft::Storage::conf_state().unwrap();
     if cs.voters == [raft_cfg.id] {
@@ -614,12 +616,8 @@ fn postjoin(args: &args::Run) {
 
         node.tick(1); // apply configuration, if any
         node.campaign().ok(); // trigger election immediately
-        assert_eq!(node.status().raft_state, "Leader");
     }
 
-    traft::node::set_global(node);
-    let node = traft::node::global().unwrap();
-
     box_cfg.listen = Some(args.listen.clone());
     tarantool::set_cfg(&box_cfg);
 
@@ -639,7 +637,7 @@ fn postjoin(args: &args::Run) {
         }
 
         let timeout = Duration::from_secs(10);
-        if let Err(e) = traft::node::global().unwrap().read_index(timeout) {
+        if let Err(e) = node.read_index(timeout) {
             tlog!(Debug, "unable to get a read barrier: {e}");
             fiber::sleep(Duration::from_millis(100));
             continue;

src/traft/event.rs

@@ -60,6 +60,7 @@ define_events! {
     LeaveJointState, "raft.leave-joint-state";
     StatusChanged, "raft.status-changed";
     TopologyChanged, "raft.topology-changed";
+    RaftLoopNeeded, "raft.loop-needed";
 }
 
 ////////////////////////////////////////////////////////////////////////////////

src/traft/mod.rs

@@ -38,7 +38,7 @@ pub type ReplicasetId = String;
 /// - `count` is a simple in-memory counter. It's cheap to increment because it's volatile.
 /// - `gen` should be persisted upon LogicalClock initialization to ensure the uniqueness.
 /// - `id` corresponds to `raft_id` of the instance (that is already unique across nodes).
-#[derive(Clone, Debug, Default, Serialize, Deserialize, Hash, PartialEq, Eq)]
+#[derive(Copy, Clone, Debug, Default, Serialize, Deserialize, Hash, PartialEq, Eq)]
 pub struct LogicalClock {
     id: u64,
     gen: u64,