aboutsummaryrefslogtreecommitdiff
path: root/object/store/packed/close.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-28 04:19:44 +0000
committerGravatar Runxi Yu2026-03-28 04:20:29 +0000
commit402ef2733813d128631ca4aea18c2908c74340d5 (patch)
treee03a90b6f41411bd62e7339390802c5c50082850 /object/store/packed/close.go
parentobject/store: Rename from object/storer (diff)
signatureNo signature
object/store: Rename back from storer; rename Store to ReadingStore v0.1.118
Diffstat (limited to 'object/store/packed/close.go')
-rw-r--r--object/store/packed/close.go38
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
+}