mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-22 03:30:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

max blocks in gossipsource (#8944)

Browse Source
This commit is contained in:
a 2023-12-10 07:40:04 -06:00 committed by GitHub
parent be10b7de29
commit 036446777c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cl/persistence/block_store.go
View File

@ -114,6 +114,10 @@ func (b *GossipSource) grabOrCreate(ctx context.Context, id uint64) chan *peers.
ch = make(chan *peers.PeeredObject[*cltypes.SignedBeaconBlock], 3)
b.blocks.Set(id, ch)
}
// if there are ever more than 512 blocks, clear the last 256 blocks
if b.blocks.Len() > 512 {
b.purgeRange(ctx, nil, 0, id-256)
}
return ch
}
func (b *GossipSource) GetRange(ctx context.Context, _ kv.Tx, from uint64, count uint64) (*peers.PeeredObject[[]*cltypes.SignedBeaconBlock], error) {
@ -131,9 +135,13 @@ func (b *GossipSource) GetRange(ctx context.Context, _ kv.Tx, from uint64, count
return out, nil
}
func (b *GossipSource) PurgeRange(ctx context.Context, _ kv.Tx, from uint64, count uint64) error {
func (b *GossipSource) PurgeRange(ctx context.Context, tx kv.Tx, from uint64, count uint64) error {
b.mu.Lock()
defer b.mu.Unlock()
return b.purgeRange(ctx, tx, from, count)
}
func (b *GossipSource) purgeRange(ctx context.Context, _ kv.Tx, from uint64, count uint64) error {
initSize := count
if initSize > 256 {
initSize = 256