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

ethdb: minor polish

Browse source
This commit is contained in:
rjl493456442 2018-06-11 21:06:48 +08:00
parent 3a91f18391
commit 3266d8e402
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
ethdb/database.go
View file

@ -214,11 +214,10 @@ func (db *LDBDatabase) meter(refresh time.Duration) {
var ( var (
errc chan error errc chan error
merr error merr error
i int = 1
) )
// Iterate ad infinitum and collect the stats // Iterate ad infinitum and collect the stats
for errc == nil && merr == nil { for i := 1; errc == nil && merr == nil; i++ {
// Retrieve the database stats // Retrieve the database stats
stats, err := db.db.GetProperty("leveldb.stats") stats, err := db.db.GetProperty("leveldb.stats")
if err != nil { if err != nil {
@ -356,8 +355,7 @@ func (db *LDBDatabase) meter(refresh time.Duration) {
if db.diskWriteMeter != nil { if db.diskWriteMeter != nil {
db.diskWriteMeter.Mark(int64((nWrite - iostats[1]) * 1024 * 1024)) db.diskWriteMeter.Mark(int64((nWrite - iostats[1]) * 1024 * 1024))
} }
iostats[0] = nRead iostats[0], iostats[1] = nRead, nWrite
iostats[1] = nWrite
// Sleep a bit, then repeat the stats collection // Sleep a bit, then repeat the stats collection
select { select {
@ -366,7 +364,6 @@ func (db *LDBDatabase) meter(refresh time.Duration) {
case <-time.After(refresh): case <-time.After(refresh):
// Timeout, gather a new set of stats // Timeout, gather a new set of stats
} }
i += 1
} }
if errc == nil { if errc == nil {