diff options
Diffstat (limited to 'object/store/packed/close.go')
| -rw-r--r-- | object/store/packed/close.go | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/object/store/packed/close.go b/object/store/packed/close.go new file mode 100644 index 00000000..f05a8573 --- /dev/null +++ b/object/store/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 +} |
