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

skip backups one more place

This commit is contained in:
Bryan Stitt 2023-10-24 22:46:47 -07:00
parent 93c4cf7374
commit 27264f591f
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -166,12 +166,18 @@ impl RankedRpcs {
let backups_needed = ranked_rpcs.iter().any(|x| x.backup); let backups_needed = ranked_rpcs.iter().any(|x| x.backup);
let num_synced = ranked_rpcs.len(); let num_synced = ranked_rpcs.len();
// TODO: add all the unsynced rpcs // add all the rpcs that are behind the ranked rpcs. these might be needed for serving archive requests
for (x, x_head) in heads.iter() { for (x, x_head) in heads.iter() {
if ranked_rpcs.contains(x) { if ranked_rpcs.contains(x) {
continue; continue;
} }
// we only want to include backups if they voted for the head block
// TODO: think more about this. maybe have a config option about how easily to use backup rpcs
if x.backup && !backups_needed {
continue;
}
if x_head.number() < max_lag_block { if x_head.number() < max_lag_block {
// server is too far behind // server is too far behind
continue; continue;
@ -219,9 +225,11 @@ impl RankedRpcs {
let min_block_needed = web3_request.min_block_needed(); let min_block_needed = web3_request.min_block_needed();
let max_block_needed = web3_request.max_block_needed(); let max_block_needed = web3_request.max_block_needed();
// TODO: max lag was already handled // max lag was already handled
for rpc in self.inner.iter().cloned() { for rpc in self.inner.iter().cloned() {
if rpc.backup && !self.backups_needed { if rpc.backup && !self.backups_needed {
// this backup check was already done, but
// TODO: push these into `backup_for_request` Vec?
continue; continue;
} }