Merge remote-tracking branch 'origin/develop' into graceful-shutdown-…

…websocket

CHANGELOG.md

@@ -97,6 +97,7 @@ Ref: https://keepachangelog.com/en/1.0.0/
 * [#522](https://github.com/crypto-org-chain/ethermint/pull/522) block-stm executor support optional pre-estimations.
 * [#526](https://github.com/crypto-org-chain/ethermint/pull/526), [#535](https://github.com/crypto-org-chain/ethermint/pull/535) Avoid unnecessary block result in header related api call.
 * [#533](https://github.com/crypto-org-chain/ethermint/pull/533) Bump cosmos-sdk to v0.50.10, cometbft to v0.38.13 and ibc-go to v8.5.1.
+* [#546](https://github.com/crypto-org-chain/ethermint/pull/546) Introduce `--async-check-tx` flag to run check-tx async with consensus.
 
 ## v0.21.x-cronos
 

server/start.go

@@ -69,6 +69,8 @@ import (
 	ethermint "github.com/evmos/ethermint/types"
 )
 
+const FlagAsyncCheckTx = "async-check-tx"
+
 // DBOpener is a function to open `application.db`, potentially with customized options.
 type DBOpener func(opts types.AppOptions, rootDir string, backend dbm.BackendType) (dbm.DB, error)
 
@@ -227,6 +229,8 @@ which accepts a path for the resulting pprof file.
 	cmd.Flags().Uint32(server.FlagStateSyncSnapshotKeepRecent, 2, "State sync snapshot to keep")
 	cmd.Flags().Int(server.FlagMempoolMaxTxs, config.DefaultMaxTxs, "Sets MaxTx value for the app-side mempool")
 
+	cmd.Flags().Bool(FlagAsyncCheckTx, false, "Enable async check tx [experimental]")
+
 	// add support for all CometBFT-specific command line options
 	tcmd.AddNodeFlags(cmd)
 	return cmd
@@ -355,12 +359,21 @@ func startInProcess(svrCtx *server.Context, clientCtx client.Context, opts Start
 		logger.Info("starting node with ABCI CometBFT in-process")
 
 		cmtApp := server.NewCometABCIWrapper(app)
+
+		var clientCreator proxy.ClientCreator
+		if svrCtx.Viper.GetBool(FlagAsyncCheckTx) {
+			logger.Info("enabling async check tx")
+			clientCreator = proxy.NewConnSyncLocalClientCreator(cmtApp)
+		} else {
+			clientCreator = proxy.NewLocalClientCreator(cmtApp)
+		}
+
 		tmNode, err = node.NewNodeWithContext(
 			ctx,
 			cfg,
 			pvm.LoadOrGenFilePV(cfg.PrivValidatorKeyFile(), cfg.PrivValidatorStateFile()),
 			nodeKey,
-			proxy.NewLocalClientCreator(cmtApp),
+			clientCreator,
 			genDocProvider,
 			cmtcfg.DefaultDBProvider,
 			node.DefaultMetricsProvider(cfg.Instrumentation),