292: Backfill gaps in the recent past on startup when tracking head. #395
@ -462,13 +462,13 @@ func (sdi *StateDiffIndexer) PushIPLD(batch interfaces.Batch, ipld sdtypes.IPLD)
|
|||||||
}
|
}
|
||||||
|
|
||||||
// CurrentBlock returns the HeaderModel of the highest existing block in the output.
|
// CurrentBlock returns the HeaderModel of the highest existing block in the output.
|
||||||
// In the "dump" case, this is always nil.
|
// In the "file" case, this is always nil.
|
||||||
func (sdi *StateDiffIndexer) CurrentBlock() (*models.HeaderModel, error) {
|
func (sdi *StateDiffIndexer) CurrentBlock() (*models.HeaderModel, error) {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// DetectGaps returns a list of gaps in the output found within the specified block range.
|
// DetectGaps returns a list of gaps in the output found within the specified block range.
|
||||||
// In the "dump" case this is always nil.
|
// In the "file" case this is always nil.
|
||||||
func (sdi *StateDiffIndexer) DetectGaps(beginBlockNumber uint64, endBlockNumber uint64) ([]*interfaces.BlockGap, error) {
|
func (sdi *StateDiffIndexer) DetectGaps(beginBlockNumber uint64, endBlockNumber uint64) ([]*interfaces.BlockGap, error) {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
@ -1211,7 +1211,7 @@ func (sds *Service) backfillHeadGap(indexerBlockNumber uint64, chainBlockNumber
|
|||||||
}(i)
|
}(i)
|
||||||
}
|
}
|
||||||
|
|
||||||
for bn := indexerBlockNumber; bn <= chainBlockNumber; bn++ {
|
for bn := indexerBlockNumber + 1; bn <= chainBlockNumber; bn++ {
|
||||||
ch <- bn
|
ch <- bn
|
||||||
}
|
}
|
||||||
close(ch)
|
close(ch)
|
||||||
|
Loading…
Reference in New Issue
Block a user