Skip to content

Commit

Permalink
🎨 Add purge repo logging details
Browse files Browse the repository at this point in the history
  • Loading branch information
88250 committed Nov 23, 2023
1 parent f5d92ba commit 866f838
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions store.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {

entries, err := os.ReadDir(objectsDir)
if nil != err {
logging.LogErrorf("read objects dir [%s] failed: %s", objectsDir, err)
return
}

Expand All @@ -79,6 +80,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
objs, readErr := os.ReadDir(dir)
if nil != readErr {
err = readErr
logging.LogErrorf("read objects dir [%s] failed: %s", dir, err)
return
}

Expand All @@ -93,6 +95,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
if gulu.File.IsDir(indexesDir) {
entries, err = os.ReadDir(indexesDir)
if nil != err {
logging.LogErrorf("read indexes dir [%s] failed: %s", indexesDir, err)
return
}

Expand All @@ -108,6 +111,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {

refIndexIDs, err := store.readRefs()
if nil != err {
logging.LogErrorf("read refs failed: %s", err)
return
}

Expand All @@ -123,6 +127,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
index, getErr := store.GetIndex(refID)
if nil != getErr {
err = getErr
logging.LogErrorf("get index [%s] failed: %s", refID, err)
return
}

Expand All @@ -131,6 +136,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
file, getFileErr := store.GetFile(fileID)
if nil != getFileErr {
err = getFileErr
logging.LogErrorf("get file [%s] failed: %s", fileID, err)
return
}

Expand All @@ -154,19 +160,22 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
stat, statErr := store.Stat(unreferencedID)
if nil != statErr {
err = statErr
logging.LogErrorf("stat [%s] failed: %s", unreferencedID, err)
return
}

ret.Size += stat.Size()
ret.Objects++

if err = store.Remove(unreferencedID); nil != err {
logging.LogErrorf("remove unreferenced object [%s] failed: %s", unreferencedID, err)
return
}
}
for unreferencedID := range unreferencedIndexIDs {
indexPath := filepath.Join(store.Path, "indexes", unreferencedID)
if err = os.RemoveAll(indexPath); nil != err {
logging.LogErrorf("remove unreferenced index [%s] failed: %s", unreferencedID, err)
return
}
}
Expand All @@ -177,6 +186,7 @@ func (store *Store) Purge() (ret *PurgeStat, err error) {
if gulu.File.IsDir(checkIndexesDir) {
entries, err = os.ReadDir(checkIndexesDir)
if nil != err {
logging.LogErrorf("read check indexes dir [%s] failed: %s", checkIndexesDir, err)
return
}

Expand Down

0 comments on commit 866f838

Please sign in to comment.