From 5bc5bbd6967550ec579d641a85d4933d6dc3ee78 Mon Sep 17 00:00:00 2001 From: Bo QIU <35757521+boqiu@users.noreply.github.com> Date: Tue, 2 Jul 2024 11:52:52 +0800 Subject: [PATCH] Enhance log level (#103) * reduce default find peers timeout for auto sync * opt log level to avoid too many noisy info logs --- node/router/src/libp2p_event_handler.rs | 2 +- node/sync/src/lib.rs | 4 ++-- node/sync/src/service.rs | 8 ++++---- run/config.toml | 2 +- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/node/router/src/libp2p_event_handler.rs b/node/router/src/libp2p_event_handler.rs index 8f05a01..9c52605 100644 --- a/node/router/src/libp2p_event_handler.rs +++ b/node/router/src/libp2p_event_handler.rs @@ -243,7 +243,7 @@ impl Libp2pEventHandler { id: &MessageId, message: PubsubMessage, ) -> MessageAcceptance { - info!(?message, %propagation_source, %source, %id, "Received pubsub message"); + trace!(?message, %propagation_source, %source, %id, "Received pubsub message"); match message { PubsubMessage::ExampleMessage(_) => MessageAcceptance::Ignore, diff --git a/node/sync/src/lib.rs b/node/sync/src/lib.rs index 2f24701..e6c2d71 100644 --- a/node/sync/src/lib.rs +++ b/node/sync/src/lib.rs @@ -28,8 +28,8 @@ impl Default for Config { fn default() -> Self { Self { auto_sync_enabled: false, - max_sync_files: 100, - find_peer_timeout: Duration::from_secs(30), + max_sync_files: 8, + find_peer_timeout: Duration::from_secs(10), sync_file_by_rpc_enabled: true, sync_file_on_announcement_enabled: false, } diff --git a/node/sync/src/service.rs b/node/sync/src/service.rs index 7558e85..ec3a98e 100644 --- a/node/sync/src/service.rs +++ b/node/sync/src/service.rs @@ -345,7 +345,7 @@ impl SyncService { request_id: PeerRequestId, request: GetChunksRequest, ) { - info!(?request, %peer_id, ?request_id, "Received GetChunks request"); + debug!(?request, %peer_id, ?request_id, "Received GetChunks request"); if let Err(err) = self .handle_chunks_request_with_db_err(peer_id, request_id, request) @@ -459,7 +459,7 @@ impl SyncService { request_id: RequestId, response: ChunkArrayWithProof, ) { - info!(%response.chunks, %peer_id, ?request_id, "Received chunks response"); + debug!(%response.chunks, %peer_id, ?request_id, "Received chunks response"); let tx_seq = match request_id { RequestId::SerialSync { tx_id } => tx_id.seq, @@ -604,7 +604,7 @@ impl SyncService { async fn on_announce_file_gossip(&mut self, tx_id: TxID, peer_id: PeerId, addr: Multiaddr) { let tx_seq = tx_id.seq; - info!(%tx_seq, %peer_id, %addr, "Received AnnounceFile gossip"); + debug!(%tx_seq, %peer_id, %addr, "Received AnnounceFile gossip"); self.manager.update_on_announcement(tx_seq).await; @@ -644,7 +644,7 @@ impl SyncService { } async fn on_announce_chunks_gossip(&mut self, msg: AnnounceChunks) { - info!(?msg, "Received AnnounceChunks gossip"); + debug!(?msg, "Received AnnounceChunks gossip"); if let Some(controller) = self.controllers.get_mut(&msg.tx_id.seq) { let info = controller.get_sync_info(); diff --git a/run/config.toml b/run/config.toml index 3bc4d50..bc15b42 100644 --- a/run/config.toml +++ b/run/config.toml @@ -230,7 +230,7 @@ miner_key = "" # Timeout to terminate a file sync when automatically sync from other peers. # If timeout, terminated file sync will be triggered later. -# find_peer_timeout = "30s" +# find_peer_timeout = "10s" # Enable to start a file sync via RPC (e.g. `admin_startSyncFile`). # sync_file_by_rpc_enabled = true