refactor(store): add missing error checks in store (#17794)
This commit is contained in:
parent
86ab9890b8
commit
22925c7d8b
@ -363,7 +363,9 @@ func (st *Store) Query(req *types.RequestQuery) (res *types.ResponseQuery, err e
|
||||
for ; iterator.Valid(); iterator.Next() {
|
||||
pairs.Pairs = append(pairs.Pairs, kv.Pair{Key: iterator.Key(), Value: iterator.Value()})
|
||||
}
|
||||
iterator.Close()
|
||||
if err := iterator.Close(); err != nil {
|
||||
panic(fmt.Errorf("failed to close iterator: %w", err))
|
||||
}
|
||||
|
||||
bz, err := pairs.Marshal()
|
||||
if err != nil {
|
||||
|
||||
@ -314,7 +314,9 @@ func deleteKVStore(kv types.KVStore) error {
|
||||
keys = append(keys, itr.Key())
|
||||
itr.Next()
|
||||
}
|
||||
itr.Close()
|
||||
if err := itr.Close(); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, k := range keys {
|
||||
kv.Delete(k)
|
||||
@ -330,7 +332,9 @@ func moveKVStoreData(oldDB, newDB types.KVStore) error {
|
||||
newDB.Set(itr.Key(), itr.Value())
|
||||
itr.Next()
|
||||
}
|
||||
itr.Close()
|
||||
if err := itr.Close(); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// then delete the old store
|
||||
return deleteKVStore(oldDB)
|
||||
@ -1106,7 +1110,9 @@ func (rs *Store) GetCommitInfo(ver int64) (*types.CommitInfo, error) {
|
||||
func (rs *Store) flushMetadata(db dbm.DB, version int64, cInfo *types.CommitInfo) {
|
||||
rs.logger.Debug("flushing metadata", "height", version)
|
||||
batch := db.NewBatch()
|
||||
defer batch.Close()
|
||||
defer func() {
|
||||
_ = batch.Close()
|
||||
}()
|
||||
|
||||
if cInfo != nil {
|
||||
flushCommitInfo(batch, version, cInfo)
|
||||
|
||||
@ -197,6 +197,6 @@ func writeOperation(w io.Writer, op operation, tc types.TraceContext, key, value
|
||||
|
||||
_, err = io.WriteString(w, "\n")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
panic(errors.Wrap(err, "failed to write newline"))
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user