diff options
| author | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:18:42 +0800 |
|---|---|---|
| committer | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:18:42 +0800 |
| commit | b0a5be4495962c291a25cbea793e43bad0781510 (patch) | |
| tree | e058201e7b29c3cb8efd710e20ec1e1f97f64368 /eth/backend.go | |
| parent | e64625aa8215985c85f97f914a98db081e07714f (diff) | |
| parent | e9c0b5431cbd7430ddec9fd17983241018fd8a55 (diff) | |
| download | dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar.gz dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar.bz2 dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar.lz dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar.xz dexon-b0a5be4495962c291a25cbea793e43bad0781510.tar.zst dexon-b0a5be4495962c291a25cbea793e43bad0781510.zip | |
Merge pull request #1321 from karalabe/cut-it-open-3000
Metrics collecting and reporting support
Diffstat (limited to 'eth/backend.go')
| -rw-r--r-- | eth/backend.go | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/eth/backend.go b/eth/backend.go index 37fe66abf..0da6f128c 100644 --- a/eth/backend.go +++ b/eth/backend.go @@ -29,6 +29,7 @@ import ( "github.com/ethereum/go-ethereum/p2p/discover" "github.com/ethereum/go-ethereum/p2p/nat" "github.com/ethereum/go-ethereum/whisper" + "github.com/rcrowley/go-metrics" ) const ( @@ -248,14 +249,35 @@ func New(config *Config) (*Ethereum, error) { if err != nil { return nil, fmt.Errorf("blockchain db err: %v", err) } + if db, ok := blockDb.(*ethdb.LDBDatabase); ok { + db.GetTimer = metrics.GetOrRegisterTimer("eth/db/block/Gets", metrics.DefaultRegistry) + db.PutTimer = metrics.GetOrRegisterTimer("eth/db/block/Puts", metrics.DefaultRegistry) + db.MissMeter = metrics.GetOrRegisterMeter("eth/db/block/Misses", metrics.DefaultRegistry) + db.ReadMeter = metrics.GetOrRegisterMeter("eth/db/block/Reads", metrics.DefaultRegistry) + db.WriteMeter = metrics.GetOrRegisterMeter("eth/db/block/Writes", metrics.DefaultRegistry) + } stateDb, err := newdb(filepath.Join(config.DataDir, "state")) if err != nil { return nil, fmt.Errorf("state db err: %v", err) } + if db, ok := stateDb.(*ethdb.LDBDatabase); ok { + db.GetTimer = metrics.GetOrRegisterTimer("eth/db/state/Gets", metrics.DefaultRegistry) + db.PutTimer = metrics.GetOrRegisterTimer("eth/db/state/Puts", metrics.DefaultRegistry) + db.MissMeter = metrics.GetOrRegisterMeter("eth/db/state/Misses", metrics.DefaultRegistry) + db.ReadMeter = metrics.GetOrRegisterMeter("eth/db/state/Reads", metrics.DefaultRegistry) + db.WriteMeter = metrics.GetOrRegisterMeter("eth/db/state/Writes", metrics.DefaultRegistry) + } extraDb, err := newdb(filepath.Join(config.DataDir, "extra")) if err != nil { return nil, fmt.Errorf("extra db err: %v", err) } + if db, ok := extraDb.(*ethdb.LDBDatabase); ok { + db.GetTimer = metrics.GetOrRegisterTimer("eth/db/extra/Gets", metrics.DefaultRegistry) + db.PutTimer = metrics.GetOrRegisterTimer("eth/db/extra/Puts", metrics.DefaultRegistry) + db.MissMeter = metrics.GetOrRegisterMeter("eth/db/extra/Misses", metrics.DefaultRegistry) + db.ReadMeter = metrics.GetOrRegisterMeter("eth/db/extra/Reads", metrics.DefaultRegistry) + db.WriteMeter = metrics.GetOrRegisterMeter("eth/db/extra/Writes", metrics.DefaultRegistry) + } nodeDb := filepath.Join(config.DataDir, "nodes") // Perform database sanity checks |