diff options
author | Péter Szilágyi <peterke@gmail.com> | 2015-06-22 17:01:27 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2015-06-24 23:34:04 +0800 |
commit | 43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062 (patch) | |
tree | f89773dd13c08c3c9dca00808cdeff28f49db1e1 | |
parent | 7bd71fa80071f86ca86ed7ef64ab51c88cabe7d4 (diff) | |
download | dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar.gz dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar.bz2 dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar.lz dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar.xz dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.tar.zst dexon-43e4a6501beb42bc0f4fffcbcb1e3f5fe58b6062.zip |
core, ethdb: instrument the block and state db
Conflicts:
ethdb/database.go
-rw-r--r-- | core/chain_manager.go | 15 | ||||
-rw-r--r-- | ethdb/database.go | 19 |
2 files changed, 28 insertions, 6 deletions
diff --git a/core/chain_manager.go b/core/chain_manager.go index 6a017b63f..b87f65893 100644 --- a/core/chain_manager.go +++ b/core/chain_manager.go @@ -13,6 +13,7 @@ import ( "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/core/state" "github.com/ethereum/go-ethereum/core/types" + "github.com/ethereum/go-ethereum/ethdb" "github.com/ethereum/go-ethereum/event" "github.com/ethereum/go-ethereum/logger" "github.com/ethereum/go-ethereum/logger/glog" @@ -30,6 +31,10 @@ var ( blockNumPre = []byte("block-num-") blockInsertTimer = metrics.GetOrRegisterTimer("core/BlockInsertions", metrics.DefaultRegistry) + blockdbGetMeter = metrics.GetOrRegisterMeter("core/blockdb/Gets", metrics.DefaultRegistry) + blockdbPutMeter = metrics.GetOrRegisterMeter("core/blockdb/Puts", metrics.DefaultRegistry) + statedbGetMeter = metrics.GetOrRegisterMeter("core/statedb/Gets", metrics.DefaultRegistry) + statedbPutMeter = metrics.GetOrRegisterMeter("core/statedb/Puts", metrics.DefaultRegistry) ) const ( @@ -121,7 +126,15 @@ func NewChainManager(genesis *types.Block, blockDb, stateDb common.Database, pow cache: NewBlockCache(blockCacheLimit), pow: pow, } - + // Instrument the block and state databases + if db, ok := blockDb.(*ethdb.LDBDatabase); ok { + db.GetMeter = blockdbGetMeter + db.PutMeter = blockdbPutMeter + } + if db, ok := stateDb.(*ethdb.LDBDatabase); ok { + db.GetMeter = statedbGetMeter + db.PutMeter = statedbPutMeter + } // Check the genesis block given to the chain manager. If the genesis block mismatches block number 0 // throw an error. If no block or the same block's found continue. if g := bc.GetBlockByNumber(0); g != nil && g.Hash() != genesis.Hash() { diff --git a/ethdb/database.go b/ethdb/database.go index 5faf8c4e0..48cb37f7c 100644 --- a/ethdb/database.go +++ b/ethdb/database.go @@ -4,6 +4,7 @@ import ( "github.com/ethereum/go-ethereum/compression/rle" "github.com/ethereum/go-ethereum/logger" "github.com/ethereum/go-ethereum/logger/glog" + "github.com/rcrowley/go-metrics" "github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb/errors" "github.com/syndtr/goleveldb/leveldb/iterator" @@ -13,10 +14,11 @@ import ( var OpenFileLimit = 64 type LDBDatabase struct { - // filename for reporting - fn string - // LevelDB instance - db *leveldb.DB + fn string // filename for reporting + db *leveldb.DB // LevelDB instance + + GetMeter metrics.Meter // Meter for measuring the database get requests + PutMeter metrics.Meter // Meter for measuring the database put requests } // NewLDBDatabase returns a LevelDB wrapped object. LDBDatabase does not persist data by @@ -43,7 +45,11 @@ func NewLDBDatabase(file string) (*LDBDatabase, error) { // Put puts the given key / value to the queue func (self *LDBDatabase) Put(key []byte, value []byte) error { - return self.db.Put(key, rle.Compress(value), nil) + dat := rle.Compress(value) + if self.PutMeter != nil { + self.PutMeter.Mark(int64(len(dat))) + } + return self.db.Put(key, dat, nil) } // Get returns the given key if it's present. @@ -52,6 +58,9 @@ func (self *LDBDatabase) Get(key []byte) ([]byte, error) { if err != nil { return nil, err } + if self.GetMeter != nil { + self.GetMeter.Mark(int64(len(dat))) + } return rle.Decompress(dat) } |