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

more logs

Browse Source
This commit is contained in:
Bryan Stitt 2022-05-20 02:11:50 +00:00
parent d51e5116a1
commit f9f6f64033
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -236,7 +236,7 @@ impl Web3Connections {
match new_block_num.cmp(&pending_synced_connections.head_block_num) { match new_block_num.cmp(&pending_synced_connections.head_block_num) {
cmp::Ordering::Greater => { cmp::Ordering::Greater => {
// the rpc's newest block is the new overall best block // the rpc's newest block is the new overall best block
info!("new head"); info!("new head: {:?}", new_block_hash);
pending_synced_connections.inner.clear(); pending_synced_connections.inner.clear();
pending_synced_connections.inner.insert(rpc_id); pending_synced_connections.inner.insert(rpc_id);
@ -312,7 +312,13 @@ impl Web3Connections {
// the synced connections have changed // the synced connections have changed
let synced_connections = Arc::new(pending_synced_connections.clone()); let synced_connections = Arc::new(pending_synced_connections.clone());
// TODO: only do this if there are 2 nodes synced to this block? trace!(
"rpcs at {}: {:?}",
synced_connections.head_block_hash,
synced_connections.inner
);
// TODO: only publish if there are x (default 2) nodes synced to this block?
// do the arcswap // do the arcswap
self.synced_connections.swap(synced_connections); self.synced_connections.swap(synced_connections);
} }