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

wait for consensus rpcs to change before trying again

Browse Source
This commit is contained in:
Bryan Stitt 2023-05-28 22:37:37 -07:00
parent 48905f0235
commit 08859ba04d
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
web3_proxy/src/rpcs/many.rs
View File

@ -511,6 +511,7 @@ impl Web3Rpcs {
.cloned() .cloned()
.collect(); .collect();
// TODO: include tiers in this?
potential_rpcs.shuffle(&mut thread_fast_rng::thread_fast_rng()); potential_rpcs.shuffle(&mut thread_fast_rng::thread_fast_rng());
match self match self
@ -653,16 +654,21 @@ impl Web3Rpcs {
match consensus_rpcs.should_wait_for_block(waiting_for, skip_rpcs) { match consensus_rpcs.should_wait_for_block(waiting_for, skip_rpcs) {
ShouldWaitForBlock::NeverReady => break, ShouldWaitForBlock::NeverReady => break,
ShouldWaitForBlock::Ready => {} ShouldWaitForBlock::Ready => {
if Instant::now() > stop_trying_at {
break;
}
}
ShouldWaitForBlock::Wait { .. } => select! { ShouldWaitForBlock::Wait { .. } => select! {
_ = watch_consensus_rpcs.changed() => {}, _ = watch_consensus_rpcs.changed() => {},
_ = sleep_until(stop_trying_at) => {}, _ = sleep_until(stop_trying_at) => break,
}, },
} }
} } else {
select! {
if Instant::now() > stop_trying_at { _ = watch_consensus_rpcs.changed() => {},
break; _ = sleep_until(stop_trying_at) => break,
}
} }
} }
} }