PALL base Fastdb

cmd/utils/cmd.go

@@ -164,6 +164,7 @@ func ImportChain(chain *core.BlockChain, fn string) error {
 			return fmt.Errorf("invalid block %d: %v", n, err)
 		}
 	}
+	common.DebugInfo.Print()
 	return nil
 }
 

common/debug.go

@@ -18,10 +18,13 @@ package common
 
 import (
 	"fmt"
+	"github.com/shirou/gopsutil/cpu"
+	"github.com/shirou/gopsutil/mem"
 	"os"
 	"runtime"
 	"runtime/debug"
 	"strings"
+	"time"
 )
 
 // Report gives off a warning requesting the user to submit an issue to the github tracker.
@@ -50,3 +53,47 @@ func PrintDepricationWarning(str string) {
 
 `, line, emptyLine, str, emptyLine, line)
 }
+
+type DebugTime struct {
+	ExecuteTx     time.Duration
+	ValidateBlock time.Duration
+	WriteBlock    time.Duration
+	CommitTrie    time.Duration
+	TxLen         int
+}
+
+func NewDebugTime() *DebugTime {
+	d := &DebugTime{
+		ExecuteTx:     time.Duration(0),
+		ValidateBlock: time.Duration(0),
+		WriteBlock:    time.Duration(0),
+		CommitTrie:    time.Duration(0),
+	}
+	go d.cpuAndMem()
+	return d
+
+}
+
+func (d *DebugTime) cpuAndMem() {
+	for true {
+		v, _ := mem.VirtualMemory()
+		res, _ := cpu.Times(false)
+		fmt.Println("mem info", v)
+		fmt.Println("cpu info", res)
+		time.Sleep(10 * time.Minute)
+	}
+}
+
+func (d *DebugTime) Print() {
+	fmt.Println("总的交易数目", d.TxLen)
+
+	fmt.Println("执行区块用时", d.ExecuteTx)
+	fmt.Println("验证区块用时", d.ValidateBlock)
+	fmt.Println("写入区块用时", d.WriteBlock)
+	fmt.Println("写入trie用时", d.CommitTrie)
+}
+
+var (
+	DebugInfo         = NewDebugTime()
+	BlockExecuteBatch = int(1)
+)

core/blockchain.go

@@ -1814,12 +1814,14 @@ func (bc *BlockChain) insertChain(chain types.Blocks, verifySeals bool) (int, er
 		//}
 		// Process block using the parent state as reference point
 		substart := time.Now()
-		receipts, logs, usedGas, err := bc.processor.Process(block, statedb, bc.vmConfig)
+		receipts, logs, usedGas, err := bc.processor.PallProcess(block, statedb, bc.vmConfig)
 		if err != nil {
 			bc.reportBlock(block, receipts, err)
 			atomic.StoreUint32(&followupInterrupt, 1)
 			return it.index, err
 		}
+		common.DebugInfo.ExecuteTx += time.Since(substart)
+
 		// Update the metrics touched during block processing
 		accountReadTimer.Update(statedb.AccountReads)                 // Account reads are complete, we can mark them
 		storageReadTimer.Update(statedb.StorageReads)                 // Storage reads are complete, we can mark them
@@ -1841,6 +1843,8 @@ func (bc *BlockChain) insertChain(chain types.Blocks, verifySeals bool) (int, er
 			atomic.StoreUint32(&followupInterrupt, 1)
 			return it.index, err
 		}
+
+		common.DebugInfo.ValidateBlock += time.Since(substart)
 		proctime := time.Since(start)
 
 		// Update the metrics touched during block validation