From 1b4c296cad05c4574eec86885b6a98ca1316f539 Mon Sep 17 00:00:00 2001 From: CoCo_Sol Date: Mon, 8 Apr 2024 16:55:46 +0200 Subject: [PATCH] Fix error handling in RaftConnection append method --- crates/relay-raft/src/lib.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crates/relay-raft/src/lib.rs b/crates/relay-raft/src/lib.rs index 8e4e692..0282425 100644 --- a/crates/relay-raft/src/lib.rs +++ b/crates/relay-raft/src/lib.rs @@ -77,7 +77,7 @@ impl RaftConnection { let mut data = message.into().into_owned(); if self.node.is_leader() { let Ok(messages) = self.node.append(data) else { - panic!("Message just cancelled."); + return; }; Self::send_raft_messages(&self.connection, &self.peers, messages); } else { @@ -132,7 +132,7 @@ impl RaftConnection { } 1 if self.node.is_leader() => { let Ok(messages) = self.node.append(message) else { - panic!("Message just cancelled."); + continue; }; Self::send_raft_messages(&self.connection, &self.peers, messages); }