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

chain isn't ExactSizeIterator

This commit is contained in:
Bryan Stitt 2023-10-06 16:07:08 -07:00
parent c1df05f8b6
commit 8180290be7
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -124,7 +124,6 @@ pub struct RankedRpcs {
// TODO: could these be refs? The owning RankedRpcs lifetime might work. `stream!` might make it complicated // TODO: could these be refs? The owning RankedRpcs lifetime might work. `stream!` might make it complicated
pub struct RpcsForRequest { pub struct RpcsForRequest {
inner: Vec<Arc<Web3Rpc>>, inner: Vec<Arc<Web3Rpc>>,
outer: Vec<Arc<Web3Rpc>>,
request: Arc<Web3Request>, request: Arc<Web3Request>,
} }
@ -276,9 +275,11 @@ impl RankedRpcs {
outer.sort_by_cached_key(|x| x.sort_for_load_balancing_on(max_block_needed, now)); outer.sort_by_cached_key(|x| x.sort_for_load_balancing_on(max_block_needed, now));
} }
} }
inner.extend(outer);
Some(RpcsForRequest { Some(RpcsForRequest {
inner, inner,
outer,
request: web3_request.clone(), request: web3_request.clone(),
}) })
} }
@ -985,6 +986,7 @@ impl RpcsForRequest {
// TODO: need an iter of self.inner, then self.outer // TODO: need an iter of self.inner, then self.outer
// we have to collect cuz apparently a Chain isn't sized
for (rpc_a, rpc_b) in self.inner.iter().circular_tuple_windows() { for (rpc_a, rpc_b) in self.inner.iter().circular_tuple_windows() {
trace!("{} vs {}", rpc_a, rpc_b); trace!("{} vs {}", rpc_a, rpc_b);
// TODO: ties within X% to the server with the smallest block_data_limit? // TODO: ties within X% to the server with the smallest block_data_limit?