diff --git a/chain/sync.go b/chain/sync.go index 899f92087..92b43a225 100644 --- a/chain/sync.go +++ b/chain/sync.go @@ -123,6 +123,8 @@ type Syncer struct { receiptTracker *blockReceiptTracker verifier ffiwrapper.Verifier + + windowSize int } // NewSyncer creates a new Syncer object. @@ -148,6 +150,7 @@ func NewSyncer(sm *stmgr.StateManager, bsync *blocksync.BlockSync, connmgr connm receiptTracker: newBlockReceiptTracker(), connmgr: connmgr, verifier: verifier, + windowSize: defaultMessageFetchWindowSize, incoming: pubsub.New(50), } @@ -1413,7 +1416,7 @@ func (syncer *Syncer) iterFullTipsets(ctx context.Context, headers []*types.TipS span.AddAttributes(trace.Int64Attribute("num_headers", int64(len(headers)))) - windowSize := defaultMessageFetchWindowSize + windowSize := syncer.windowSize mainLoop: for i := len(headers) - 1; i >= 0; { fts, err := syncer.store.TryFillTipSet(headers[i]) @@ -1490,6 +1493,9 @@ mainLoop: } } + // remember our window size + syncer.windowSize = windowSize + return nil }