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

Split blob pruning into two funcs (#13285)

Browse Source
This commit is contained in:
Justin Traglia 2023-12-06 17:39:02 -06:00 committed by GitHub
parent 737e0e0d3a
commit 4e4fb9ad52
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
beacon-chain/db/filesystem/blob.go
View File

@ -6,6 +6,7 @@ import (
"io"
"os"
"path"
"path/filepath"
"strconv"
"strings"
@ -218,26 +219,34 @@ func (bs *BlobStorage) Prune(currentSlot primitives.Slot) error {
}
for _, folder := range folders {
if folder.IsDir() {
f, err := bs.fs.Open(folder.Name() + "/0." + sszExt)
if err != nil {
if err := bs.processFolder(folder, currentSlot, retentionSlots); err != nil {
return err
}
defer func(f afero.File) {
err := f.Close()
if err != nil {
log.WithError(err).Errorf("Could not close blob file")
}
}(f)
}
}
return nil
}
slot, err := slotFromBlob(f)
if err != nil {
return err
}
if slot < (currentSlot - retentionSlots) {
if err = bs.fs.RemoveAll(folder.Name()); err != nil {
return errors.Wrapf(err, "failed to delete blob %s", f.Name())
}
}
// processFolder will delete the folder of blobs if the blob slot is outside the
// retention period. We determine the slot by looking at the first blob in the folder.
func (bs *BlobStorage) processFolder(folder os.FileInfo, currentSlot, retentionSlots primitives.Slot) error {
f, err := bs.fs.Open(filepath.Join(folder.Name(), "0."+sszExt))
if err != nil {
return err
}
defer func() {
if err := f.Close(); err != nil {
log.WithError(err).Errorf("Could not close blob file")
}
}()
slot, err := slotFromBlob(f)
if err != nil {
return err
}
if slot < (currentSlot - retentionSlots) {
if err = bs.fs.RemoveAll(folder.Name()); err != nil {
return errors.Wrapf(err, "failed to delete blob %s", f.Name())
}
}
return nil