Function benchInsertChain

core/bench_test.go:131–169

(b *testing.B, disk bool, gen func(int, *BlockGen))

}

func benchInsertChain(b *testing.B, disk bool, gen func(int, *BlockGen)) {
	// Create the database in memory or in a temporary directory.
	var db database.Database
	if !disk {
		db = database.NewMemDatabase()
	} else {
		dir, err := ioutil.TempDir("", "eth-core-bench")
		if err != nil {
			b.Fatalf("cannot create temporary directory: %v", err)
		}
		defer os.RemoveAll(dir)
		db, err = database.NewLDBDatabase(dir, 128, 128)
		if err != nil {
			b.Fatalf("cannot create temporary database: %v", err)
		}
		defer db.Close()
	}

	// Generate a chain of b.N blocks using the supplied block
	// generator function.
	gspec := Genesis{
		Config: configs.TestChainConfig,
		Alloc:  GenesisAlloc{benchRootAddr: {Balance: benchRootFunds}},
	}
	genesis := gspec.MustCommit(db)

	remoteDB := database.NewIpfsDbWithAdapter(database.NewFakeIpfsAdapter())
	chain, _ := GenerateChain(gspec.Config, genesis, dpor.NewFaker(configs.ChainConfigInfo().Dpor, db), db, remoteDB, b.N, gen)

	// Time the insertion of the new chain.
	// State and blocks are stored in the same DB.
	chainman, _ := NewBlockChain(db, nil, gspec.Config, dpor.NewFaker(configs.ChainConfigInfo().Dpor, db), vm.Config{}, remoteDB, nil)
	defer chainman.Stop()
	b.ReportAllocs()
	b.ResetTimer()
	if i, err := chainman.InsertChain(chain); err != nil {
		b.Fatalf("insert error (block %d): %v\n", i, err)
	}
}

// func BenchmarkChainRead_header_10k(b *testing.B) {
// 	benchReadChain(b, false, 10000)