diff --git a/pkg/local_object_storage/engine/control.go b/pkg/local_object_storage/engine/control.go index 1b1383b6..59b652e8 100644 --- a/pkg/local_object_storage/engine/control.go +++ b/pkg/local_object_storage/engine/control.go @@ -39,6 +39,10 @@ func (e *StorageEngine) Close() error { e.mtx.RLock() defer e.mtx.RUnlock() + for _, p := range e.shardPools { + p.Release() + } + for id, sh := range e.shards { if err := sh.Close(); err != nil { e.log.Debug("could not close shard",