gossip when not enough votes
This commit is contained in:
parent
84cf27c3ef
commit
bb8347477a
@ -85,12 +85,23 @@ impl IoHandler<Step> for TransitionHandler {
|
|||||||
set_timeout(io, engine.our_params.timeouts.precommit);
|
set_timeout(io, engine.our_params.timeouts.precommit);
|
||||||
Some(Step::Precommit)
|
Some(Step::Precommit)
|
||||||
},
|
},
|
||||||
|
Step::Prevote => {
|
||||||
|
trace!(target: "poa", "timeout: Prevote timeout without enough votes.");
|
||||||
|
set_timeout(io, engine.our_params.timeouts.precommit);
|
||||||
|
Some(Step::Prevote)
|
||||||
|
},
|
||||||
Step::Precommit if engine.has_enough_any_votes() => {
|
Step::Precommit if engine.has_enough_any_votes() => {
|
||||||
trace!(target: "poa", "timeout: Precommit timeout.");
|
trace!(target: "poa", "timeout: Precommit timeout.");
|
||||||
set_timeout(io, engine.our_params.timeouts.propose);
|
set_timeout(io, engine.our_params.timeouts.propose);
|
||||||
engine.increment_round(1);
|
engine.increment_round(1);
|
||||||
Some(Step::Propose)
|
Some(Step::Propose)
|
||||||
},
|
},
|
||||||
|
Step::Precommit => {
|
||||||
|
trace!(target: "poa", "timeout: Precommit timeout without enough votes.");
|
||||||
|
set_timeout(io, engine.our_params.timeouts.propose);
|
||||||
|
engine.increment_round(1);
|
||||||
|
Some(Step::Propose)
|
||||||
|
},
|
||||||
Step::Commit => {
|
Step::Commit => {
|
||||||
trace!(target: "poa", "timeout: Commit timeout.");
|
trace!(target: "poa", "timeout: Commit timeout.");
|
||||||
set_timeout(io, engine.our_params.timeouts.propose);
|
set_timeout(io, engine.our_params.timeouts.propose);
|
||||||
|
Loading…
Reference in New Issue
Block a user