diff --git a/src/raft.rs b/src/raft.rs index c57c01884..2b095186b 100644 --- a/src/raft.rs +++ b/src/raft.rs @@ -1698,7 +1698,7 @@ impl Raft { }; self.read_states.push(rs); } else { - let mut to_send = Message::new(); + let mut to_send = Message::default(); to_send.set_to(m.get_from()); to_send.set_msg_type(MessageType::MsgReadIndexResp); to_send.set_index(self.raft_log.committed); diff --git a/tests/integration_cases/test_raft.rs b/tests/integration_cases/test_raft.rs index 61cf2624f..4af3162f1 100644 --- a/tests/integration_cases/test_raft.rs +++ b/tests/integration_cases/test_raft.rs @@ -2215,10 +2215,10 @@ fn test_read_only_with_learner() { assert_eq!(nt.peers[&2].state, StateRole::Follower); let mut tests = vec![ - (1, 10, 11, "ctx1"), - (2, 10, 21, "ctx2"), - (1, 10, 31, "ctx3"), - (2, 10, 41, "ctx4"), + (1, 10, 12, "ctx1"), + (2, 10, 22, "ctx2"), + (1, 10, 32, "ctx3"), + (2, 10, 42, "ctx4"), ]; for (i, (id, proposals, wri, wctx)) in tests.drain(..).enumerate() {