chore: add cluster version check

Signed-off-by: iGxnon <igxnon@gmail.com>
xline-kv · Dec 29, 2023 · 61e373b · 61e373b
1 parent 3883c81
commit 61e373b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/curp/src/members.rs b/curp/src/members.rs
@@ -11,7 +11,7 @@ use std::{
 use dashmap::{mapref::one::Ref, DashMap};
 use futures::{stream::FuturesUnordered, StreamExt};
 use itertools::Itertools;
-use tracing::debug;
+use tracing::{debug, info};
 
 use crate::rpc::{self, FetchClusterRequest, FetchClusterResponse, Member};
 
@@ -297,7 +297,7 @@ impl ClusterInfo {
                 addrs.hash(&mut hasher);
             });
         let ver = hasher.finish();
-        debug!("cluster version updates to {ver}");
+        info!("cluster version updates to {ver}");
         self.cluster_version.store(ver, Ordering::Relaxed);
     }
 

diff --git a/curp/src/server/raw_curp/tests.rs b/curp/src/server/raw_curp/tests.rs
@@ -777,6 +777,10 @@ fn add_node_should_add_new_node_to_curp() {
         old_cluster.all_members(),
         cluster_after_fallback.all_members()
     );
+    assert_eq!(
+        cluster_after_fallback.cluster_version(),
+        old_cluster.cluster_version()
+    );
 }
 
 #[traced_test]