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

skip nodes on block 0

This commit is contained in:
Bryan Stitt 2022-05-06 21:04:02 +00:00
parent 8548753a32
commit 21761435f2
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
web3-proxy/src/connections.rs
View File

@ -186,10 +186,15 @@ impl Web3Connections {
pub fn update_synced_rpcs(&self, rpc: &Arc<Web3Connection>) -> anyhow::Result<()> { pub fn update_synced_rpcs(&self, rpc: &Arc<Web3Connection>) -> anyhow::Result<()> {
let mut synced_connections = self.synced_connections.write(); let mut synced_connections = self.synced_connections.write();
let current_best_block_number = synced_connections.head_block_number;
let new_block = rpc.head_block_number(); let new_block = rpc.head_block_number();
if new_block == 0 {
warn!("{:?} is still syncing", rpc);
return Ok(());
}
let current_best_block_number = synced_connections.head_block_number;
let overall_best_head_block = self.head_block_number(); let overall_best_head_block = self.head_block_number();
// TODO: double check this logic // TODO: double check this logic
@ -210,8 +215,8 @@ impl Web3Connections {
atomic::Ordering::AcqRel, atomic::Ordering::AcqRel,
atomic::Ordering::Acquire, atomic::Ordering::Acquire,
) { ) {
Ok(current_best_block_number) => { Ok(_) => {
info!("new head block from {}: {}", rpc, current_best_block_number); info!("new head block from {}: {}", rpc, new_block);
} }
Err(current_best_block_number) => { Err(current_best_block_number) => {
// actually, there was a race and this ended up not being the latest block. return now without adding this rpc to the synced list // actually, there was a race and this ended up not being the latest block. return now without adding this rpc to the synced list