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

remove excess continues

Browse Source
This commit is contained in:
Bryan Stitt 2023-01-24 10:09:12 -08:00
parent 522678e394
commit 641d11a19b
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -897,9 +897,10 @@ impl Web3Connections {
request_metadata.no_servers.fetch_add(1, Ordering::Release); request_metadata.no_servers.fetch_add(1, Ordering::Release);
} }
// TODO: if there are other servers in synced_connections, we should continue now
if let Some(watch_consensus_connections) = watch_consensus_connections.as_mut() if let Some(watch_consensus_connections) = watch_consensus_connections.as_mut()
{ {
// TODO: if there are other servers in synced_connections, we should continue now
// wait until retry_at OR synced_connections changes // wait until retry_at OR synced_connections changes
trace!("waiting for change in synced servers or retry_at"); trace!("waiting for change in synced servers or retry_at");
tokio::select! { tokio::select! {
@ -911,10 +912,8 @@ impl Web3Connections {
let _ = watch_consensus_connections.borrow_and_update(); let _ = watch_consensus_connections.borrow_and_update();
} }
} }
continue;
} else { } else {
sleep_until(retry_at).await; sleep_until(retry_at).await;
continue;
} }
} }
OpenRequestResult::NotReady => { OpenRequestResult::NotReady => {
@ -929,9 +928,6 @@ impl Web3Connections {
.subscribe() .subscribe()
.changed() .changed()
.await?; .await?;
} else {
// TODO: continue or break?
continue;
} }
} }
} }