aboutsummaryrefslogtreecommitdiffstats
path: root/core
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2015-06-10 18:57:58 +0800
committerobscuren <geffobscura@gmail.com>2015-06-10 18:57:58 +0800
commit1774c494560507735d7b616456be60874063101f (patch)
tree7fcda04540c15cca45f910d749d197245d9deec2 /core
parent6fb6e6679eb7c329ac9013d0c879a7c4b17daca5 (diff)
downloaddexon-1774c494560507735d7b616456be60874063101f.tar
dexon-1774c494560507735d7b616456be60874063101f.tar.gz
dexon-1774c494560507735d7b616456be60874063101f.tar.bz2
dexon-1774c494560507735d7b616456be60874063101f.tar.lz
dexon-1774c494560507735d7b616456be60874063101f.tar.xz
dexon-1774c494560507735d7b616456be60874063101f.tar.zst
dexon-1774c494560507735d7b616456be60874063101f.zip
core: log tx count for each set of blocks we're importing
Diffstat (limited to 'core')
-rw-r--r--core/chain_manager.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/core/chain_manager.go b/core/chain_manager.go
index 6897c453c..be64b54f4 100644
--- a/core/chain_manager.go
+++ b/core/chain_manager.go
@@ -567,6 +567,7 @@ func (self *ChainManager) InsertChain(chain types.Blocks) (int, error) {
go verifyNonces(self.pow, chain, nonceQuit, nonceDone)
defer close(nonceQuit)
+ txcount := 0
for i, block := range chain {
bstart := time.Now()
// Wait for block i's nonce to be verified before processing
@@ -625,6 +626,8 @@ func (self *ChainManager) InsertChain(chain types.Blocks) (int, error) {
return i, err
}
+ txcount += len(block.Transactions())
+
cblock := self.currentBlock
// Compare the TD of the last known block in the canonical chain to make sure it's greater.
// At this point it's possible that a different chain (fork) becomes the new canonical chain.
@@ -683,7 +686,7 @@ func (self *ChainManager) InsertChain(chain types.Blocks) (int, error) {
if (stats.queued > 0 || stats.processed > 0 || stats.ignored > 0) && bool(glog.V(logger.Info)) {
tend := time.Since(tstart)
start, end := chain[0], chain[len(chain)-1]
- glog.Infof("imported %d block(s) (%d queued %d ignored) in %v. #%v [%x / %x]\n", stats.processed, stats.queued, stats.ignored, tend, end.Number(), start.Hash().Bytes()[:4], end.Hash().Bytes()[:4])
+ glog.Infof("imported %d block(s) (%d queued %d ignored) including %d txs in %v. #%v [%x / %x]\n", stats.processed, stats.queued, stats.ignored, txcount, tend, end.Number(), start.Hash().Bytes()[:4], end.Hash().Bytes()[:4])
}
go self.eventMux.Post(queueEvent)