Skip to content

Commit 648ef5f

Browse files
authored
refactor: keep batch.Close error handle logic consistance (#21812)
1 parent 89d96e8 commit 648ef5f

2 files changed

Lines changed: 5 additions & 4 deletions

File tree

store/rootmulti/store.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1147,7 +1147,9 @@ func (rs *Store) flushMetadata(db corestore.KVStoreWithBatch, version int64, cIn
11471147
rs.logger.Debug("flushing metadata", "height", version)
11481148
batch := db.NewBatch()
11491149
defer func() {
1150-
_ = batch.Close()
1150+
if err := batch.Close(); err != nil {
1151+
rs.logger.Error("call flushMetadata error on batch close", "err", err)
1152+
}
11511153
}()
11521154

11531155
if cInfo != nil {

store/v2/commitment/metadata.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package commitment
22

33
import (
44
"bytes"
5+
"errors"
56
"fmt"
67

78
corestore "cosmossdk.io/core/store"
@@ -158,9 +159,7 @@ func (m *MetadataStore) deleteRemovedStoreKeys(version uint64, removeStore func(
158159

159160
batch := m.kv.NewBatch()
160161
defer func() {
161-
if berr := batch.Close(); berr != nil {
162-
err = berr
163-
}
162+
err = errors.Join(err, batch.Close())
164163
}()
165164
for _, storeKey := range removedStoreKeys {
166165
if err := removeStore(storeKey, version); err != nil {

0 commit comments

Comments
 (0)