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

lower error log when starting

This commit is contained in:
Bryan Stitt 2023-06-27 10:05:07 -07:00
parent 1cf18b78a9
commit 8e98eabebe
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
web3_proxy/src/rpcs/blockchain.rs
View File

@ -418,6 +418,8 @@ impl Web3Rpcs {
// TODO: what timeout on block receiver? we want to keep consensus_finder fresh so that server tiers are correct // TODO: what timeout on block receiver? we want to keep consensus_finder fresh so that server tiers are correct
let double_block_time = average_block_interval(self.chain_id).mul_f32(2.0); let double_block_time = average_block_interval(self.chain_id).mul_f32(2.0);
let mut had_first_success = false;
loop { loop {
match timeout(double_block_time, block_receiver.recv_async()).await { match timeout(double_block_time, block_receiver.recv_async()).await {
Ok(Ok((new_block, rpc))) => { Ok(Ok((new_block, rpc))) => {
@ -436,12 +438,19 @@ impl Web3Rpcs {
) )
.await .await
{ {
Ok(Ok(_)) => {} Ok(Ok(_)) => had_first_success = true,
Ok(Err(err)) => { Ok(Err(err)) => {
error!( if had_first_success {
"error while processing block from rpc {}: {:#?}", error!(
rpc_name, err "error while processing block from rpc {}: {:#?}",
); rpc_name, err
);
} else {
debug!(
"startup error while processing block from rpc {}: {:#?}",
rpc_name, err
);
}
} }
Err(timeout) => { Err(timeout) => {
error!( error!(