forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge b4e5fa9f8d into 4e474c74dc

Browse source
This commit is contained in:
Corey Lin 2018-10-10 06:24:18 +00:00 committed by GitHub
commit 9ed5fc95f0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ethdb/database.go
View file

@ -39,6 +39,7 @@ const (
var OpenFileLimit = 64 var OpenFileLimit = 64
// LDBDatabase wraps LevelDB and some other useful information such as LevelDB database specific meters
type LDBDatabase struct { type LDBDatabase struct {
fn string // filename for reporting fn string // filename for reporting
db *leveldb.DB // LevelDB instance db *leveldb.DB // LevelDB instance
@ -101,6 +102,7 @@ func (db *LDBDatabase) Put(key []byte, value []byte) error {
return db.db.Put(key, value, nil) return db.db.Put(key, value, nil)
} }
// Has returns true if the database contains the given key.
func (db *LDBDatabase) Has(key []byte) (bool, error) { func (db *LDBDatabase) Has(key []byte) (bool, error) {
return db.db.Has(key, nil) return db.db.Has(key, nil)
} }
@ -119,6 +121,7 @@ func (db *LDBDatabase) Delete(key []byte) error {
return db.db.Delete(key, nil) return db.db.Delete(key, nil)
} }
// NewIterator creates an iterator which iterates over the database's key/value pairs in key order
func (db *LDBDatabase) NewIterator() iterator.Iterator { func (db *LDBDatabase) NewIterator() iterator.Iterator {
return db.db.NewIterator(nil, nil) return db.db.NewIterator(nil, nil)
} }
@ -128,6 +131,7 @@ func (db *LDBDatabase) NewIteratorWithPrefix(prefix []byte) iterator.Iterator {
return db.db.NewIterator(util.BytesPrefix(prefix), nil) return db.db.NewIterator(util.BytesPrefix(prefix), nil)
} }
// Close stops the metrics collection and closes underlying LevelDB database
func (db *LDBDatabase) Close() { func (db *LDBDatabase) Close() {
// Stop the metrics collection to avoid internal database races // Stop the metrics collection to avoid internal database races
db.quitLock.Lock() db.quitLock.Lock()
@ -149,6 +153,7 @@ func (db *LDBDatabase) Close() {
} }
} }
// LDB returns the underlying LevelDB database instance
func (db *LDBDatabase) LDB() *leveldb.DB { func (db *LDBDatabase) LDB() *leveldb.DB {
return db.db return db.db
} }
@ -346,6 +351,7 @@ func (db *LDBDatabase) meter(refresh time.Duration) {
errc <- merr errc <- merr
} }
// NewBatch creates a new write Batch
func (db *LDBDatabase) NewBatch() Batch { func (db *LDBDatabase) NewBatch() Batch {
return &ldbBatch{db: db.db, b: new(leveldb.Batch)} return &ldbBatch{db: db.db, b: new(leveldb.Batch)}
} }
@ -364,7 +370,7 @@ func (b *ldbBatch) Put(key, value []byte) error {
func (b *ldbBatch) Delete(key []byte) error { func (b *ldbBatch) Delete(key []byte) error {
b.b.Delete(key) b.b.Delete(key)
b.size += 1 b.size++
return nil return nil
} }