tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

move health check during voting

Browse Source
This commit is contained in:
Bryan Stitt 2023-10-24 23:33:24 -07:00
parent 8d20019b5a
commit 2e3b40a885
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
web3_proxy/src/rpcs/consensus.rs
View File

@ -759,11 +759,6 @@ impl ConsensusFinder {
.rpc_heads
.iter()
.filter(|(rpc, x)| {
if !rpc.healthy.load(atomic::Ordering::Relaxed) {
// TODO: we might go backwards if this happens. make sure we hold on to highest block from a previous run
return false;
}
if let Some(max_block_age) = self.max_head_block_age {
if x.age() > max_block_age {
return false;
@ -809,6 +804,11 @@ impl ConsensusFinder {
HashMap::with_capacity(num_known);
for (rpc, rpc_head) in self.rpc_heads.iter() {
if !rpc.healthy.load(atomic::Ordering::Relaxed) {
// TODO: should unhealthy servers get a vote? they were included in minmax_block. i think that is enough
continue;
}
let mut block_to_check = rpc_head.clone();
while block_to_check.number() >= lowest_block_number {