Skip to content

Commit 8d16f2c

Browse files
committed
Merge remote-tracking branch 'origin/phase/beta1' into fix/downloadMptFirst
2 parents 816a78a + a667ed8 commit 8d16f2c

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

src/main/scala/io/iohk/ethereum/blockchain/sync/SyncBlockBodiesRequestHandler.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ class SyncBlockBodiesRequestHandler(
2121
if (blockBodies.bodies.isEmpty) {
2222
val reason = s"got empty block bodies response for known hashes: ${requestedHashes.map(h => Hex.toHexString(h.toArray[Byte]))}"
2323
syncController ! BlacklistSupport.BlacklistPeer(peer.id, reason)
24+
syncController ! FastSync.EnqueueBlockBodies(requestedHashes)
2425
} else {
2526
syncController ! BlockBodiesReceived(peer, requestedHashes, blockBodies.bodies)
2627
}

src/test/scala/io/iohk/ethereum/blockchain/sync/FastSyncBlockBodiesRequestHandlerSpec.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ class FastSyncBlockBodiesRequestHandlerSpec extends FlatSpec with Matchers {
4141
peerMessageBus.reply(MessageFromPeer(BlockBodies(responseBodies), peer.id))
4242

4343
parent.expectMsg(BlacklistSupport.BlacklistPeer(peer.id, "got empty block bodies response for known hashes: List(31, 32)"))
44+
parent.expectMsg(FastSync.EnqueueBlockBodies(requestedHashes))
4445
parent.expectMsg(SyncRequestHandler.Done)
4546

4647
peerMessageBus.expectMsg(Unsubscribe(PeerDisconnectedClassifier(PeerSelector.WithId(peer.id))))

0 commit comments

Comments
 (0)