Problem: tx delivery performance is not benchmarked

Solution:
- add the first benchmark for tx delivery

Author: HuangYi

app/bench_test.go

@@ -0,0 +1,139 @@
+package app
+
+import (
+	"encoding/json"
+	"math/big"
+	"testing"
+
+	sdkmath "cosmossdk.io/math"
+	"github.com/cosmos/cosmos-sdk/testutil/mock"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
+	banktypes "github.com/cosmos/cosmos-sdk/x/bank/types"
+	"github.com/crypto-org-chain/cronos/v2/x/cronos/types"
+	"github.com/ethereum/go-ethereum/common"
+	ethtypes "github.com/ethereum/go-ethereum/core/types"
+	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/evmos/ethermint/crypto/ethsecp256k1"
+	"github.com/evmos/ethermint/tests"
+	evmtypes "github.com/evmos/ethermint/x/evm/types"
+	"github.com/stretchr/testify/require"
+	abci "github.com/tendermint/tendermint/abci/types"
+	"github.com/tendermint/tendermint/libs/log"
+	tmproto "github.com/tendermint/tendermint/proto/tendermint/types"
+	tmtypes "github.com/tendermint/tendermint/types"
+	dbm "github.com/tendermint/tm-db"
+)
+
+// BenchmarkERC20Transfer benchmarks execution of standard erc20 token transfer transactions
+func BenchmarkERC20Transfer(b *testing.B) {
+	txsPerBlock := 100
+	gasPrice := big.NewInt(100000000000)
+
+	encodingConfig := MakeEncodingConfig()
+	db := dbm.NewMemDB()
+	app := New(log.NewNopLogger(), db, nil, true, map[int64]bool{}, DefaultNodeHome, 0, encodingConfig, EmptyAppOptions{})
+
+	priv, err := ethsecp256k1.GenerateKey()
+	address := common.BytesToAddress(priv.PubKey().Address().Bytes())
+	signer := tests.NewSigner(priv)
+	chainID := big.NewInt(777)
+	ethSigner := ethtypes.LatestSignerForChainID(chainID)
+
+	signTx := func(msg *evmtypes.MsgEthereumTx) ([]byte, error) {
+		msg.From = address.String()
+		if err := msg.Sign(ethSigner, signer); err != nil {
+			return nil, err
+		}
+		require.NoError(b, err)
+		tx, err := msg.BuildTx(encodingConfig.TxConfig.NewTxBuilder(), evmtypes.DefaultEVMDenom)
+		if err != nil {
+			return nil, err
+		}
+		return encodingConfig.TxConfig.TxEncoder()(tx)
+	}
+
+	ctor, err := types.ModuleCRC21Contract.ABI.Pack("", "test", uint8(0), false)
+	require.NoError(b, err)
+	deployTxBz, err := signTx(evmtypes.NewTxContract(chainID, 0, big.NewInt(0), 2100000, gasPrice, nil, nil, ctor, nil))
+	require.NoError(b, err)
+
+	privVal := mock.NewPV()
+	pubKey, err := privVal.GetPubKey()
+	consAddress := sdk.ConsAddress(pubKey.Address())
+	require.NoError(b, err)
+	validator := tmtypes.NewValidator(pubKey, 1)
+	valSet := tmtypes.NewValidatorSet([]*tmtypes.Validator{validator})
+	acc := authtypes.NewBaseAccount(priv.PubKey().Address().Bytes(), priv.PubKey(), 0, 0)
+	balance := banktypes.Balance{
+		Address: acc.GetAddress().String(),
+		Coins:   sdk.NewCoins(sdk.NewCoin(evmtypes.DefaultEVMDenom, sdkmath.NewIntWithDecimal(10000000, 18))),
+	}
+	genesisState := NewDefaultGenesisState(encodingConfig.Codec)
+	genesisState = genesisStateWithValSet(b, app, genesisState, valSet, []authtypes.GenesisAccount{acc}, balance)
+
+	appState, err := json.MarshalIndent(genesisState, "", "  ")
+	require.NoError(b, err)
+	app.InitChain(abci.RequestInitChain{
+		ChainId:         SimAppChainID,
+		AppStateBytes:   appState,
+		ConsensusParams: DefaultConsensusParams,
+	})
+	app.BeginBlock(abci.RequestBeginBlock{
+		Header: tmproto.Header{
+			Height:          1,
+			ChainID:         SimAppChainID,
+			ProposerAddress: consAddress,
+		},
+	})
+	res := app.DeliverTx(abci.RequestDeliverTx{
+		Tx: deployTxBz,
+	})
+	require.Equal(b, 0, int(res.Code))
+	app.EndBlock(abci.RequestEndBlock{})
+	app.Commit()
+
+	// prepare transactions
+	contractAddr := crypto.CreateAddress(address, 1)
+	var transferTxs [][]byte
+	for i := 0; i < b.N; i++ {
+		for j := 0; j < txsPerBlock; j++ {
+			idx := int64(i*txsPerBlock + j)
+			recipient := common.BigToAddress(big.NewInt(idx))
+			data, err := types.ModuleCRC21Contract.ABI.Pack("transfer", recipient, big.NewInt(1))
+			bz, err := signTx(evmtypes.NewTx(chainID, uint64(idx)+1, &contractAddr, big.NewInt(0), 210000, gasPrice, nil, nil, data, nil))
+			require.NoError(b, err)
+			transferTxs = append(transferTxs, bz)
+		}
+	}
+
+	/*
+		{
+			fp, err := os.Create("cpu.profile")
+			require.NoError(b, err)
+			defer fp.Close()
+			require.NoError(b, pprof.StartCPUProfile(fp))
+			defer pprof.StopCPUProfile()
+		}
+	*/
+
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		app.BeginBlock(abci.RequestBeginBlock{
+			Header: tmproto.Header{
+				Height:          int64(i) + 2,
+				ChainID:         SimAppChainID,
+				ProposerAddress: consAddress,
+			},
+		})
+		for j := 0; j < txsPerBlock; j++ {
+			idx := i*txsPerBlock + j
+			res := app.DeliverTx(abci.RequestDeliverTx{
+				Tx: transferTxs[idx],
+			})
+			require.Equal(b, 0, int(res.Code))
+		}
+		app.EndBlock(abci.RequestEndBlock{})
+		app.Commit()
+	}
+}

app/test_helpers.go

@@ -49,7 +49,7 @@ const (
 var DefaultConsensusParams = &abci.ConsensusParams{
 	Block: &abci.BlockParams{
 		MaxBytes: 200000,
-		MaxGas:   2000000,
+		MaxGas:   20000000,
 	},
 	Evidence: &tmproto.EvidenceParams{
 		MaxAgeNumBlocks: 302400,
@@ -131,7 +131,7 @@ func SetupWithGenesisValSet(t *testing.T, cronosAdmin string, valSet *tmtypes.Va
 	return app
 }
 
-func genesisStateWithValSet(t *testing.T,
+func genesisStateWithValSet(t require.TestingT,
 	app *App, genesisState GenesisState,
 	valSet *tmtypes.ValidatorSet, genAccs []authtypes.GenesisAccount,
 	balances ...banktypes.Balance,