diff --git a/examples/raft-kv-memstore/src/client.rs b/examples/raft-kv-memstore/src/client.rs index f730794ae..9bc817aac 100644 --- a/examples/raft-kv-memstore/src/client.rs +++ b/examples/raft-kv-memstore/src/client.rs @@ -170,7 +170,7 @@ impl ExampleClient { } .send(); - let res = timeout(Duration::from_millis(500), fu).await; + let res = timeout(Duration::from_millis(3_000), fu).await; let resp = match res { Ok(x) => x.map_err(|e| RPCError::Network(NetworkError::new(&e)))?, Err(timeout_err) => { diff --git a/examples/raft-kv-memstore/src/lib.rs b/examples/raft-kv-memstore/src/lib.rs index 7939b102a..f42b28922 100644 --- a/examples/raft-kv-memstore/src/lib.rs +++ b/examples/raft-kv-memstore/src/lib.rs @@ -36,7 +36,14 @@ pub type ExampleRaft = Raft pub async fn start_example_raft_node(node_id: ExampleNodeId, http_addr: String) -> std::io::Result<()> { // Create a configuration for the raft instance. - let config = Arc::new(Config::default().validate().unwrap()); + let config = Config { + heartbeat_interval: 500, + election_timeout_min: 1500, + election_timeout_max: 3000, + ..Default::default() + }; + + let config = Arc::new(config.validate().unwrap()); // Create a instance of where the Raft data will be stored. let store = Arc::new(ExampleStore::default()); diff --git a/openraft/src/core/raft_core.rs b/openraft/src/core/raft_core.rs index aec5ac483..b0921b7a5 100644 --- a/openraft/src/core/raft_core.rs +++ b/openraft/src/core/raft_core.rs @@ -1408,8 +1408,8 @@ impl, S: RaftStorage> RaftCore