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

skip backups in another place

Browse Source
This commit is contained in:
Bryan Stitt 2023-10-24 18:16:59 -07:00
parent 54df286acc
commit d706a53c04
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -211,7 +211,7 @@ impl RankedRpcs {
let num_active = self.num_active_rpcs();
// these are bigger than we need, but how much does that matter?
let mut inner_for_request = Vec::<Arc<Web3Rpc>>::with_capacity(num_active);
let mut inner_for_request = Vec::with_capacity(num_active);
let mut outer_for_request = Vec::with_capacity(num_active);
// TODO: what if min is set to some future block?
@ -221,7 +221,10 @@ impl RankedRpcs {
// TODO: max lag was already handled
for rpc in self.inner.iter().cloned() {
// if web3_request.head_block.is_some() {
if rpc.backup && !self.backups_needed {
continue;
}
if let Some(block_needed) = min_block_needed {
if !rpc.has_block_data(block_needed) {
outer_for_request.push(rpc);
@ -234,7 +237,6 @@ impl RankedRpcs {
continue;
}
}
// }
inner_for_request.push(rpc);
}