087db1de70
Since we're about to do a v3.0.0 release, let's bump the version to v3. Make this change automatically with the following command to avoid any missed items: git grep -l github.com/git-lfs/git-lfs/v2 | \ xargs sed -i -e 's!github.com/git-lfs/git-lfs/v2!github.com/git-lfs/git-lfs/v3!g'
84 lines
1.8 KiB
Go
84 lines
1.8 KiB
Go
package fs
|
|
|
|
import (
|
|
"os"
|
|
"path/filepath"
|
|
"strings"
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/git-lfs/git-lfs/v3/tools"
|
|
"github.com/rubyist/tracerx"
|
|
)
|
|
|
|
func (f *Filesystem) cleanupTmp() error {
|
|
tmpdir := f.TempDir()
|
|
if len(tmpdir) == 0 {
|
|
return nil
|
|
}
|
|
|
|
// No temporary directory? No problem.
|
|
if _, err := os.Stat(tmpdir); err != nil && os.IsNotExist(err) {
|
|
return nil
|
|
}
|
|
|
|
traversedDirectories := &sync.Map{}
|
|
|
|
var walkErr error
|
|
tools.FastWalkDir(tmpdir, func(parentDir string, info os.FileInfo, err error) {
|
|
if err != nil {
|
|
walkErr = err
|
|
}
|
|
if walkErr != nil {
|
|
return
|
|
}
|
|
path := filepath.Join(parentDir, info.Name())
|
|
if info.IsDir() {
|
|
traversedDirectories.Store(path, info)
|
|
return
|
|
}
|
|
parts := strings.SplitN(info.Name(), "-", 2)
|
|
oid := parts[0]
|
|
if len(parts) == 2 && len(oid) == 64 {
|
|
fi, err := os.Stat(f.ObjectPathname(oid))
|
|
if err == nil && !fi.IsDir() {
|
|
tracerx.Printf("Removing existing tmp object file: %s", path)
|
|
os.RemoveAll(path)
|
|
return
|
|
}
|
|
}
|
|
|
|
// Don't prune items in a directory younger than an hour. These
|
|
// items could be hard links to files from other repositories,
|
|
// which would have an older timestamp but which are still in
|
|
// use by some active process. Exempt the main temporary from
|
|
// this check, since we frequently modify it and we'd never
|
|
// prune otherwise.
|
|
if tmpdir != parentDir {
|
|
var dirInfo os.FileInfo
|
|
entry, ok := traversedDirectories.Load(parentDir)
|
|
if ok {
|
|
dirInfo = entry.(os.FileInfo)
|
|
} else {
|
|
dirInfo, err = os.Stat(parentDir)
|
|
if err != nil {
|
|
return
|
|
}
|
|
traversedDirectories.Store(path, dirInfo)
|
|
}
|
|
|
|
if time.Since(dirInfo.ModTime()) <= time.Hour {
|
|
return
|
|
}
|
|
}
|
|
|
|
if time.Since(info.ModTime()) > time.Hour {
|
|
tracerx.Printf("Removing old tmp object file: %s", path)
|
|
os.RemoveAll(path)
|
|
return
|
|
}
|
|
})
|
|
|
|
return walkErr
|
|
}
|