github/prysm
1
1
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-01-09 15:37:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

slasher

Browse Source
This commit is contained in:
rkapka
2020-10-08 13:40:56 +02:00
parent d4b664ba27
commit 8b34137931
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
slasher/db/kv/block_header.go
View File

@@ -116,11 +116,11 @@ func (db *Store) DeleteBlockHeader(ctx context.Context, blockHeader *ethpb.Signe
func (db *Store) PruneBlockHistory(ctx context.Context, currentEpoch uint64, pruningEpochAge uint64) error {
ctx, span := trace.StartSpan(ctx, "slasherDB.pruneBlockHistory")
defer span.End()
pruneTill := int64(currentEpoch) - int64(pruningEpochAge)
pruneTill := currentEpoch - pruningEpochAge
if pruneTill <= 0 {
return nil
}
pruneTillSlot := uint64(pruneTill) * params.BeaconConfig().SlotsPerEpoch
pruneTillSlot := pruneTill * params.BeaconConfig().SlotsPerEpoch
return db.update(func(tx *bolt.Tx) error {
bucket := tx.Bucket(historicBlockHeadersBucket)
c := tx.Bucket(historicBlockHeadersBucket).Cursor()

4
slasher/db/kv/indexed_attestations.go
View File

@@ -165,7 +165,7 @@ func (db *Store) DeleteIndexedAttestation(ctx context.Context, idxAttestation *e
func (db *Store) PruneAttHistory(ctx context.Context, currentEpoch uint64, pruningEpochAge uint64) error {
ctx, span := trace.StartSpan(ctx, "slasherDB.pruneAttHistory")
defer span.End()
pruneFromEpoch := int64(currentEpoch) - int64(pruningEpochAge)
pruneFromEpoch := currentEpoch - pruningEpochAge
if pruneFromEpoch <= 0 {
return nil
}
@@ -173,7 +173,7 @@ func (db *Store) PruneAttHistory(ctx context.Context, currentEpoch uint64, pruni
return db.update(func(tx *bolt.Tx) error {
attBucket := tx.Bucket(historicIndexedAttestationsBucket)
c := tx.Bucket(historicIndexedAttestationsBucket).Cursor()
max := bytesutil.Bytes8(uint64(pruneFromEpoch))
max := bytesutil.Bytes8(pruneFromEpoch)
for k, _ := c.First(); k != nil && bytes.Compare(k[:8], max) <= 0; k, _ = c.Next() {
if err := attBucket.Delete(k); err != nil {
return errors.Wrap(err, "failed to delete indexed attestation from historical bucket")