From c438001a6202af8cf61219bf4e2f4f7535294f7b Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 28 Sep 2021 22:34:04 +0800 Subject: [PATCH] Fix rocksdb_kv value free (#8798) Signed-off-by: fishpenguin --- internal/kv/rocksdb/rocksdb_kv.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/kv/rocksdb/rocksdb_kv.go b/internal/kv/rocksdb/rocksdb_kv.go index 321ac85d01..ef2b6bb848 100644 --- a/internal/kv/rocksdb/rocksdb_kv.go +++ b/internal/kv/rocksdb/rocksdb_kv.go @@ -137,7 +137,6 @@ func (kv *RocksdbKV) MultiLoad(keys []string) ([]string, error) { if err != nil { return []string{}, err } - defer value.Free() values = append(values, string(value.Data())) value.Free() } @@ -187,6 +186,7 @@ func (kv *RocksdbKV) RemoveWithPrefix(prefix string) error { for ; iter.Valid(); iter.Next() { key := iter.Key() err := kv.DB.Delete(kv.WriteOptions, key.Data()) + key.Free() if err != nil { return nil }