fix handling of end of sync
This commit is contained in:
parent
6dfc40abc1
commit
f135ec8468
@ -1486,11 +1486,7 @@ func (syncer *Syncer) iterFullTipsets(ctx context.Context, headers []*types.TipS
|
|||||||
|
|
||||||
batchSize := concurrentSyncRequests * syncRequestBatchSize
|
batchSize := concurrentSyncRequests * syncRequestBatchSize
|
||||||
if i < batchSize {
|
if i < batchSize {
|
||||||
if i == 0 {
|
batchSize = i + 1
|
||||||
batchSize = 1
|
|
||||||
} else {
|
|
||||||
batchSize = i
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
ss.SetStage(api.StageFetchingMessages)
|
ss.SetStage(api.StageFetchingMessages)
|
||||||
|
Loading…
Reference in New Issue
Block a user