Skip to content

Commit e066eef

Browse files
committed
fix off by one header download
Signed-off-by: [email protected] <[email protected]>
1 parent d5c4c69 commit e066eef

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/PosDownloadAndStoreSyncBodiesStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public PosDownloadAndStoreSyncBodiesStep(
5353
public CompletableFuture<List<BlockHeader>> apply(final List<BlockHeader> blockHeaders) {
5454

5555
LOG.atDebug()
56-
.setMessage("Downloading {} block headers starting with {}")
56+
.setMessage("Downloading {} block bodies starting with {}")
5757
.addArgument(blockHeaders.size())
5858
.addArgument(blockHeaders.getFirst().getNumber())
5959
.log();
@@ -76,7 +76,7 @@ public CompletableFuture<List<BlockHeader>> apply(final List<BlockHeader> blockH
7676
// store blocks in the database, no TX indexing.
7777
ethContext.getBlockchain().appendSyncBlocksForPoC(sbList);
7878
LOG.atDebug()
79-
.setMessage("Stored {} Sync blocks for up to block no {}")
79+
.setMessage("Stored {} sync blocks for up to block no {}")
8080
.addArgument(sbList.size())
8181
.addArgument(blockHeaders.getLast().getNumber())
8282
.log();

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/possync/LoadHeadersStep.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ private CompletableFuture<List<BlockHeader>> loadHeaders(final SyncTargetNumberR
6060

6161
List<BlockHeader> headers =
6262
Stream.iterate(startBlockNumber, n -> n + 1)
63-
.limit(endBlockNumber - startBlockNumber)
63+
.limit(endBlockNumber - startBlockNumber + 1)
6464
.map(blockchain::getBlockHeader)
6565
.flatMap(Optional::stream)
6666
.collect(Collectors.toList());

0 commit comments

Comments
 (0)