generated from tipragot/rust
Fix error handling in RaftConnection append method
Some checks failed
Rust Checks / checks (push) Has been cancelled
Some checks failed
Rust Checks / checks (push) Has been cancelled
This commit is contained in:
parent
4d1c26d6b3
commit
1b4c296cad
|
@ -77,7 +77,7 @@ impl RaftConnection {
|
||||||
let mut data = message.into().into_owned();
|
let mut data = message.into().into_owned();
|
||||||
if self.node.is_leader() {
|
if self.node.is_leader() {
|
||||||
let Ok(messages) = self.node.append(data) else {
|
let Ok(messages) = self.node.append(data) else {
|
||||||
panic!("Message just cancelled.");
|
return;
|
||||||
};
|
};
|
||||||
Self::send_raft_messages(&self.connection, &self.peers, messages);
|
Self::send_raft_messages(&self.connection, &self.peers, messages);
|
||||||
} else {
|
} else {
|
||||||
|
@ -132,7 +132,7 @@ impl RaftConnection {
|
||||||
}
|
}
|
||||||
1 if self.node.is_leader() => {
|
1 if self.node.is_leader() => {
|
||||||
let Ok(messages) = self.node.append(message) else {
|
let Ok(messages) = self.node.append(message) else {
|
||||||
panic!("Message just cancelled.");
|
continue;
|
||||||
};
|
};
|
||||||
Self::send_raft_messages(&self.connection, &self.peers, messages);
|
Self::send_raft_messages(&self.connection, &self.peers, messages);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue