From 7466be219fdda0af4c85da1f1f6ee3d1ea7e4f04 Mon Sep 17 00:00:00 2001 From: Joel Date: Tue, 14 May 2024 11:40:36 +0800 Subject: [PATCH] add recoery log --- .../src/sync_manager/log_entry_fetcher.rs | 2 ++ node/log_entry_sync/src/sync_manager/log_query.rs | 10 +++++++++- 2 files changed, 11 insertions(+), 1 deletion(-) diff --git a/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs b/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs index a3ead52..169b660 100644 --- a/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs +++ b/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs @@ -274,6 +274,8 @@ impl LogEntryFetcher { } } } + + debug!("recover finished"); }, "log recover", ); diff --git a/node/log_entry_sync/src/sync_manager/log_query.rs b/node/log_entry_sync/src/sync_manager/log_query.rs index 37e77fb..f0b7d00 100644 --- a/node/log_entry_sync/src/sync_manager/log_query.rs +++ b/node/log_entry_sync/src/sync_manager/log_query.rs @@ -1,6 +1,6 @@ use ethers::prelude::{Filter, JsonRpcClient, Log, Middleware, Provider, ProviderError, U64}; use futures_core::stream::Stream; -use jsonrpsee::tracing::trace; +use jsonrpsee::tracing::{debug, trace}; use std::future::Future; use std::time::Duration; use std::{ @@ -128,6 +128,10 @@ where .from_block(from_block) .to_block(to_block); let provider = self.provider; + debug!( + "log_query: from_block={} last_block={}", + from_block, to_block + ); // load first page of logs #[allow(clippy::redundant_async_block)] let fut = Box::pin(async move { @@ -177,6 +181,10 @@ where .from_block(from_block) .to_block(to_block); let provider = self.provider; + debug!( + "log_query: from_block={} last_block={}", + from_block, to_block + ); #[allow(clippy::redundant_async_block)] let fut = Box::pin(async move { tokio::time::sleep(delay).await;