mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2024-12-25 04:47:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

create the bucket only once (#8579)

Browse Source 
Co-authored-by: Victor Farazdagi <simple.square@gmail.com>
This commit is contained in:
Nishant Das 2021-03-09 22:22:52 +08:00 committed by GitHub
parent 363771a5c7
commit 2bb0a602e4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
validator/db/kv/attester_protection.go
View File

@ -398,6 +398,15 @@ func (s *Store) saveAttestationRecords(ctx context.Context, atts []*AttestationR
ctx, span := trace.StartSpan(ctx, "Validator.saveAttestationRecords")
defer span.End()
return s.update(func(tx *bolt.Tx) error {
// Initialize buckets for the lowest target and source epochs.
lowestSourceBucket, err := tx.CreateBucketIfNotExists(lowestSignedSourceBucket)
if err != nil {
return err
}
lowestTargetBucket, err := tx.CreateBucketIfNotExists(lowestSignedTargetBucket)
if err != nil {
return err
}
bucket := tx.Bucket(pubKeysBucket)
for _, att := range atts {
pkBucket, err := bucket.CreateBucketIfNotExists(att.PubKey[:])
@ -448,16 +457,6 @@ func (s *Store) saveAttestationRecords(ctx context.Context, atts []*AttestationR
return errors.Wrapf(err, "could not save target epoch %d for epoch %d", att.Target, att.Source)
}
// Initialize buckets for the lowest target and source epochs.
lowestSourceBucket, err := tx.CreateBucketIfNotExists(lowestSignedSourceBucket)
if err != nil {
return err
}
lowestTargetBucket, err := tx.CreateBucketIfNotExists(lowestSignedTargetBucket)
if err != nil {
return err
}
// If the incoming source epoch is lower than the lowest signed source epoch, override.
lowestSignedSourceBytes := lowestSourceBucket.Get(att.PubKey[:])
var lowestSignedSourceEpoch types.Epoch