fix: the raft protocol is used to synchronize node information fix is…

…sue #1348
cnosdb · Jul 13, 2023 · ce11c41 · ce11c41
1 parent 8d511fe
commit ce11c41
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/meta/src/bin/main.rs b/meta/src/bin/main.rs
@@ -131,7 +131,7 @@ async fn detect_node_heartbeat(heartbeat_config: HeartBeatConfig, app: Data<Meta
         interval.tick().await;
 
         if let Ok(_leader) = app.raft.is_leader().await {
-            let sm = app.store.state_machine.write().await;
+            let sm = app.store.state_machine.read().await;
 
             if let Ok(list) = sm.children_data::<NodeMetrics>(&metrics_path) {
                 let node_metrics_list: Vec<NodeMetrics> = list.into_values().collect();
@@ -151,7 +151,9 @@ async fn detect_node_heartbeat(heartbeat_config: HeartBeatConfig, app: Data<Meta
                             now_node_metrics,
                         );
 
-                        sm.process_write_command(&req);
+                        if app.raft.client_write(req).await.is_err() {
+                            tracing::error!("failed to change node status to unreachable");
+                        }
                     }
                 }
             }