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

skip outers earlier

Browse Source
This commit is contained in:
Bryan Stitt 2023-10-10 20:02:20 -07:00
parent 8b8dfbbda7
commit bf49b84eae
4 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Cargo.lock generated
View File

@ -6585,7 +6585,7 @@ dependencies = [
[[package]]
name = "web3_proxy"
version = "1.43.30"
version = "1.43.31"
dependencies = [
"anyhow",
"arc-swap",
@ -6667,7 +6667,7 @@ dependencies = [
[[package]]
name = "web3_proxy_cli"
version = "1.43.30"
version = "1.43.31"
dependencies = [
"env_logger",
"parking_lot",

2
web3_proxy/Cargo.toml
View File

@ -1,6 +1,6 @@
[package]
name = "web3_proxy"
version = "1.43.30"
version = "1.43.31"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

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

@ -298,6 +298,9 @@ impl RankedRpcs {
}
}
// TODO: turn these back on
outer.clear();
if inner.is_empty() && outer.is_empty() {
warn!(?inner, ?outer, %web3_request, %head_block, "no rpcs for request");
None
@ -1041,9 +1044,7 @@ impl RpcsForRequest {
let mut wait_for_sync = FuturesUnordered::new();
// first check the inners, then the outers
// for rpcs in [&self.inner, &self.outer] {
for rpcs in [&self.inner] {
for rpcs in [&self.inner, &self.outer] {
attempted.clear();
while attempted.len() + completed.len() < rpcs.len() {

2
web3_proxy_cli/Cargo.toml
View File

@ -1,6 +1,6 @@
[package]
name = "web3_proxy_cli"
version = "1.43.30"
version = "1.43.31"
edition = "2021"
default-run = "web3_proxy_cli"