Merge pull request #238 from filecoin-project/feat/faster-sync
make chain sync faster by turning up blocksync window
This commit is contained in:
commit
2669fa3e50
@ -516,7 +516,7 @@ loop:
|
|||||||
// NB: GetBlocks validates that the blocks are in-fact the ones we
|
// NB: GetBlocks validates that the blocks are in-fact the ones we
|
||||||
// requested, and that they are correctly linked to eachother. It does
|
// requested, and that they are correctly linked to eachother. It does
|
||||||
// not validate any state transitions
|
// not validate any state transitions
|
||||||
window := 10
|
window := 500
|
||||||
if gap := int(blockSet[len(blockSet)-1].Height() - untilHeight); gap < window {
|
if gap := int(blockSet[len(blockSet)-1].Height() - untilHeight); gap < window {
|
||||||
window = gap
|
window = gap
|
||||||
}
|
}
|
||||||
@ -530,6 +530,7 @@ loop:
|
|||||||
// This error will only be logged above,
|
// This error will only be logged above,
|
||||||
return nil, xerrors.Errorf("failed to get blocks: %w", err)
|
return nil, xerrors.Errorf("failed to get blocks: %w", err)
|
||||||
}
|
}
|
||||||
|
log.Info("Got blocks: ", blks[0].Height(), len(blks))
|
||||||
|
|
||||||
for _, b := range blks {
|
for _, b := range blks {
|
||||||
if b.Height() < untilHeight {
|
if b.Height() < untilHeight {
|
||||||
@ -588,7 +589,7 @@ func (syncer *Syncer) iterFullTipsets(headers []*types.TipSet, cb func(*store.Fu
|
|||||||
}
|
}
|
||||||
headers = headers[:beg+1]
|
headers = headers[:beg+1]
|
||||||
|
|
||||||
windowSize := 10
|
windowSize := 200
|
||||||
|
|
||||||
for i := len(headers) - 1; i >= 0; i -= windowSize {
|
for i := len(headers) - 1; i >= 0; i -= windowSize {
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user