diff options
| author | 2026-03-25 14:34:50 +0000 | |
|---|---|---|
| committer | 2026-03-25 14:34:50 +0000 | |
| commit | e4a7aa0742f5070299d37e8421c99d67f0af3f90 (patch) | |
| tree | 36d89781476a92e61280c5ff232a2773e4092c0e /object/storer/packed/close.go | |
| parent | *: delta -> packfile/delta (diff) | |
| signature | No signature | |
*: object/store -> object/storer v0.1.107
Diffstat (limited to 'object/storer/packed/close.go')
| -rw-r--r-- | object/storer/packed/close.go | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/object/storer/packed/close.go b/object/storer/packed/close.go new file mode 100644 index 00000000..f05a8573 --- /dev/null +++ b/object/storer/packed/close.go @@ -0,0 +1,38 @@ +package packed + +// Close releases mapped pack/index resources associated with the store. +// +// Store borrows its root, so Close does not close it. +// Close releases cached pack/index mappings retained by the store. +// +// Repeated calls to Close are undefined behavior. +func (store *Store) Close() error { + store.stateMu.Lock() + packs := store.packs + store.stateMu.Unlock() + store.idxMu.RLock() + indexes := store.idxByPack + store.idxMu.RUnlock() + + var closeErr error + + for _, pack := range packs { + err := pack.close() + if err != nil && closeErr == nil { + closeErr = err + } + } + + for _, index := range indexes { + err := index.close() + if err != nil && closeErr == nil { + closeErr = err + } + } + + store.cacheMu.Lock() + store.deltaCache.clear() + store.cacheMu.Unlock() + + return closeErr +} |
