generated from tipragot/rust
This commit is contained in:
parent
d8a81646a6
commit
7262bf1410
|
@ -52,6 +52,7 @@ impl RaftConnection {
|
||||||
let Ok(messages) = self.node.append(data) else {
|
let Ok(messages) = self.node.append(data) else {
|
||||||
panic!("OOOOOOOOH!");
|
panic!("OOOOOOOOH!");
|
||||||
};
|
};
|
||||||
|
Self::send_raft_messages(&self.connection, &self.peers, messages);
|
||||||
} else {
|
} else {
|
||||||
data.push(1);
|
data.push(1);
|
||||||
if let (Some(leader), _) = self.node.leader() {
|
if let (Some(leader), _) = self.node.leader() {
|
||||||
|
|
Loading…
Reference in a new issue