From 4f877467747cbe1d204e28508b33f01cce596225 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pawe=C5=82=20=C5=9Al=C4=85ski?= Date: Thu, 28 Jan 2021 18:10:31 +0100 Subject: [PATCH] added more logging in RegularSync and PeersClient --- .../scala/io/iohk/ethereum/blockchain/sync/PeersClient.scala | 1 + .../io/iohk/ethereum/blockchain/sync/regular/RegularSync.scala | 2 ++ 2 files changed, 3 insertions(+) diff --git a/src/main/scala/io/iohk/ethereum/blockchain/sync/PeersClient.scala b/src/main/scala/io/iohk/ethereum/blockchain/sync/PeersClient.scala index c46a08d5e6..4fce2c7362 100644 --- a/src/main/scala/io/iohk/ethereum/blockchain/sync/PeersClient.scala +++ b/src/main/scala/io/iohk/ethereum/blockchain/sync/PeersClient.scala @@ -55,6 +55,7 @@ class PeersClient( case PeerRequestHandler.ResponseReceived(peer, message, _) => handleResponse(requesters, Response(peer, message.asInstanceOf[Message])) case PeerRequestHandler.RequestFailed(peer, reason) => + log.warning(s"Request to peer ${peer.remoteAddress} failed - reason: $reason") handleResponse(requesters, RequestFailed(peer, reason)) } diff --git a/src/main/scala/io/iohk/ethereum/blockchain/sync/regular/RegularSync.scala b/src/main/scala/io/iohk/ethereum/blockchain/sync/regular/RegularSync.scala index 92377cd87f..594cbaf843 100644 --- a/src/main/scala/io/iohk/ethereum/blockchain/sync/regular/RegularSync.scala +++ b/src/main/scala/io/iohk/ethereum/blockchain/sync/regular/RegularSync.scala @@ -97,9 +97,11 @@ class RegularSync( val newState = progressState.copy(initialBlock = blockNumber, currentBlock = blockNumber) context become running(newState) case ProgressProtocol.GotNewBlock(blockNumber) => + log.info(s"Got information about new block [number = $blockNumber]") val newState = progressState.copy(bestKnownNetworkBlock = blockNumber) context become running(newState) case ProgressProtocol.ImportedBlock(blockNumber, internally) => + log.info(s"Imported new block [number = $blockNumber, internally = $internally]") val newState = progressState.copy(currentBlock = blockNumber) if (internally) { fetcher ! InternalLastBlockImport(blockNumber)