diff --git a/ethdb/kv_lmdb.go b/ethdb/kv_lmdb.go index c4c033c9275e1f81a99470964b2ce401c8473727..b93cf1af785686c149c56113162b2a81b5b96c9f 100644 --- a/ethdb/kv_lmdb.go +++ b/ethdb/kv_lmdb.go @@ -657,6 +657,7 @@ func (tx *lmdbTx) Put(bucket string, k, v []byte) error { if err != nil { return err } + defer c.Close() return c.Put(k, v) } @@ -670,6 +671,7 @@ func (tx *lmdbTx) Delete(bucket string, k, v []byte) error { if err != nil { return err } + defer c.Close() return c.Delete(k, v) } err := tx.tx.Del(lmdb.DBI(b.DBI), k, v) diff --git a/ethdb/kv_mdbx.go b/ethdb/kv_mdbx.go index efbd2e5e145b4a8f8f9b5212adb0f3ea70522635..a027b34b666f1caf22cb91a6e4521de66534dd09 100644 --- a/ethdb/kv_mdbx.go +++ b/ethdb/kv_mdbx.go @@ -712,6 +712,7 @@ func (tx *MdbxTx) Put(bucket string, k, v []byte) error { if err != nil { return err } + defer c.Close() return c.Put(k, v) } @@ -725,6 +726,7 @@ func (tx *MdbxTx) Delete(bucket string, k, v []byte) error { if err != nil { return err } + defer c.Close() return c.Delete(k, v) }