more logging
This commit is contained in:
parent
283bae6245
commit
61f02b3d0c
@ -11,7 +11,7 @@ use std::fmt;
|
|||||||
use std::sync::atomic::{self, AtomicU64};
|
use std::sync::atomic::{self, AtomicU64};
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use tokio::sync::RwLock;
|
use tokio::sync::RwLock;
|
||||||
use tracing::{debug, info, trace, warn};
|
use tracing::{debug, info, trace, warn, instrument};
|
||||||
|
|
||||||
use crate::config::Web3ConnectionConfig;
|
use crate::config::Web3ConnectionConfig;
|
||||||
use crate::connection::{ActiveRequestHandle, Web3Connection};
|
use crate::connection::{ActiveRequestHandle, Web3Connection};
|
||||||
@ -174,8 +174,12 @@ impl Web3Connections {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// TODO: possible dead lock here. investigate more. probably refactor
|
||||||
|
#[instrument]
|
||||||
pub async fn update_synced_rpcs(&self, rpc: &Arc<Web3Connection>) -> anyhow::Result<()> {
|
pub async fn update_synced_rpcs(&self, rpc: &Arc<Web3Connection>) -> anyhow::Result<()> {
|
||||||
|
info!("Locking synced_connections")
|
||||||
let mut synced_connections = self.synced_connections.write().await;
|
let mut synced_connections = self.synced_connections.write().await;
|
||||||
|
info!("Locked synced_connections")
|
||||||
|
|
||||||
let new_block = rpc.head_block_number();
|
let new_block = rpc.head_block_number();
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user