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)