fix: remove mutex in prefixdb

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## Unreleased
+
+- remove mutex from prefixdb
+
 ## 0.6.7
 
 **2022-2-21**

boltdb.go

@@ -1,3 +1,4 @@
+//go:build boltdb
 // +build boltdb
 
 package db

boltdb_batch.go

@@ -1,3 +1,4 @@
+//go:build boltdb
 // +build boltdb
 
 package db

boltdb_iterator.go

@@ -1,3 +1,4 @@
+//go:build boltdb
 // +build boltdb
 
 package db

boltdb_test.go

@@ -1,3 +1,4 @@
+//go:build boltdb
 // +build boltdb
 
 package db

cleveldb.go

@@ -1,3 +1,4 @@
+//go:build cleveldb
 // +build cleveldb
 
 package db

cleveldb_batch.go

@@ -1,3 +1,4 @@
+//go:build cleveldb
 // +build cleveldb
 
 package db

cleveldb_iterator.go

@@ -1,3 +1,4 @@
+//go:build cleveldb
 // +build cleveldb
 
 package db

cleveldb_test.go

@@ -1,3 +1,4 @@
+//go:build cleveldb
 // +build cleveldb
 
 package db

prefixdb.go

@@ -27,8 +27,8 @@ func (pdb *PrefixDB) Get(key []byte) ([]byte, error) {
 	if len(key) == 0 {
 		return nil, errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
+	// pdb.mtx.Lock()
+	// defer pdb.mtx.Unlock()
 
 	pkey := pdb.prefixed(key)
 	value, err := pdb.db.Get(pkey)
@@ -43,8 +43,6 @@ func (pdb *PrefixDB) Has(key []byte) (bool, error) {
 	if len(key) == 0 {
 		return false, errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	ok, err := pdb.db.Has(pdb.prefixed(key))
 	if err != nil {
@@ -62,8 +60,6 @@ func (pdb *PrefixDB) Set(key []byte, value []byte) error {
 	if value == nil {
 		return errValueNil
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	pkey := pdb.prefixed(key)
 	if err := pdb.db.Set(pkey, value); err != nil {
@@ -80,8 +76,6 @@ func (pdb *PrefixDB) SetSync(key []byte, value []byte) error {
 	if value == nil {
 		return errValueNil
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	return pdb.db.SetSync(pdb.prefixed(key), value)
 }
@@ -91,8 +85,6 @@ func (pdb *PrefixDB) Delete(key []byte) error {
 	if len(key) == 0 {
 		return errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	return pdb.db.Delete(pdb.prefixed(key))
 }
@@ -102,8 +94,6 @@ func (pdb *PrefixDB) DeleteSync(key []byte) error {
 	if len(key) == 0 {
 		return errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	return pdb.db.DeleteSync(pdb.prefixed(key))
 }
@@ -113,8 +103,6 @@ func (pdb *PrefixDB) Iterator(start, end []byte) (Iterator, error) {
 	if (start != nil && len(start) == 0) || (end != nil && len(end) == 0) {
 		return nil, errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	var pstart, pend []byte
 	pstart = append(cp(pdb.prefix), start...)
@@ -136,8 +124,6 @@ func (pdb *PrefixDB) ReverseIterator(start, end []byte) (Iterator, error) {
 	if (start != nil && len(start) == 0) || (end != nil && len(end) == 0) {
 		return nil, errKeyEmpty
 	}
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	var pstart, pend []byte
 	pstart = append(cp(pdb.prefix), start...)
@@ -156,8 +142,6 @@ func (pdb *PrefixDB) ReverseIterator(start, end []byte) (Iterator, error) {
 
 // NewBatch implements DB.
 func (pdb *PrefixDB) NewBatch() Batch {
-	pdb.mtx.Lock()
-	defer pdb.mtx.Unlock()
 
 	return newPrefixBatch(pdb.prefix, pdb.db.NewBatch())
 }

rocksdb.go

@@ -1,3 +1,4 @@
+//go:build rocksdb
 // +build rocksdb
 
 package db

rocksdb_batch.go

@@ -1,3 +1,4 @@
+//go:build rocksdb
 // +build rocksdb
 
 package db

rocksdb_iterator.go

@@ -1,3 +1,4 @@
+//go:build rocksdb
 // +build rocksdb
 
 package db

rocksdb_test.go

@@ -1,3 +1,4 @@
+//go:build rocksdb
 // +build rocksdb
 
 package db