Limit block batches to 10k during checkpoint syncs (#215)

Author: oskarszoon

services/legacy/netsync/manager.go

@@ -1289,6 +1289,16 @@ func (sm *SyncManager) fetchHeaderBlocks() {
 		return
 	}
 
+	// Limit batch size to avoid peer processing timeouts during checkpoint sync.
+	// Large checkpoint gaps (e.g., 50k blocks) can cause timeouts when downloading
+	// and processing all blocks at once. Chunk requests to manageable sizes.
+	maxBlocks := maxRequestedBlocks
+	headerListLen := sm.headerList.Len()
+	if headerListLen > 10000 {
+		maxBlocks = 10000
+		sm.logger.Infof("[fetchHeaderBlocks] Header list contains %d blocks, limiting batch to %d blocks to avoid timeout", headerListLen, maxBlocks)
+	}
+
 	// Build up a getdata request for the list of blocks the headers
 	// describe.  The size hint will be limited to wire.MaxInvPerMsg by
 	// the function, so no need to double check it here.
@@ -1326,7 +1336,7 @@ func (sm *SyncManager) fetchHeaderBlocks() {
 
 		sm.startHeader = e.Next()
 
-		if numRequested >= maxRequestedBlocks {
+		if numRequested >= maxBlocks {
 			sm.logger.Debugf("[fetchHeaderBlocks] Limiting to %d block(s) from %s", numRequested, sm.syncPeer)
 			break
 		}

services/utxopersister/filestorer/FileStorer.go

@@ -86,7 +86,7 @@ func NewFileStorer(ctx context.Context, logger ulogger.Logger, tSettings *settin
 		bufferSize = 1024 * 128 // default to 128KB
 	}
 
-	logger.Infof("Using %s buffer for file storer", bufferSize)
+	logger.Debugf("Using %s buffer for file storer", bufferSize)
 
 	// Create pipe for streaming data to blob storage
 	reader, writer := io.Pipe()

settings.conf

@@ -711,6 +711,8 @@ legacy_outpointBatcherConcurrency = 32
 
 legacy_outpointBatcherSize = 1024
 
+legacy_peerProcessingTimeout = 10m
+
 legacy_printInvMessages     = false
 legacy_printInvMessages.dev = true