add concurrency tests

.gitignore

@@ -32,6 +32,7 @@ mytestnet
 coverage.txt
 profile.out
 sim_log_file
+testdata
 
 # Vagrant
 .vagrant/

Makefile

@@ -201,6 +201,9 @@ contracts-gen: $(CONTRACTS_DIR)/*
 benchmark:
 	@go test -timeout 20m -mod=readonly -bench=. ./... 
 
+fuzz:
+	@go test --timeout 2m -mod=readonly -fuzz=Fuzz ./x/evm/keeper
+
 .PHONY: test test-all test-cover test-unit test-race benchmark contracts-gen
 
 ###############################################################################

x/evm/contracts/counter/Counter.sol

@@ -14,7 +14,13 @@ contract Counter is IIBCAsyncCallback {
 
     constructor() payable {}
 
-    function increase() external payable {
+    function increase_for_fuzz(uint64 num) external {
+        for (uint64 i = 0; i < num; i++) {
+            increase();
+        }
+    }
+
+    function increase() public payable {
         count++;
 
         emit increased(count - 1, count);

x/evm/keeper/context_test.go

@@ -118,7 +118,7 @@ func Test_Call(t *testing.T) {
 	res, logs, err := input.EVMKeeper.EVMCall(ctx, caller, contractAddr, inputBz, uint256.NewInt(100), nil)
 	require.NoError(t, err)
 	require.Empty(t, res)
-	require.NotEmpty(t, logs)
+	require.Len(t, logs, int(2))
 
 	// check balance
 	balance, err := input.EVMKeeper.ERC20Keeper().GetBalance(ctx, contractAddr.Bytes(), sdk.DefaultBondDenom)

x/evm/keeper/fuzz_test.go

@@ -0,0 +1,92 @@
+package keeper_test
+
+import (
+	"bytes"
+	"sync"
+	"sync/atomic"
+	"testing"
+
+	sdk "github.com/cosmos/cosmos-sdk/types"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/common/hexutil"
+	coretypes "github.com/ethereum/go-ethereum/core/types"
+
+	"github.com/holiman/uint256"
+	"github.com/stretchr/testify/require"
+
+	"github.com/initia-labs/minievm/x/evm/contracts/counter"
+	"github.com/initia-labs/minievm/x/evm/types"
+)
+
+func Fuzz_Concurrent_Counter(f *testing.F) {
+	f.Add(uint8(100), uint8(100))
+	f.Fuzz(func(t *testing.T, numThread uint8, numCount uint8) {
+		if numThread == 0 || numCount == 0 {
+			t.Skip("skip invalid input")
+		}
+
+		ctx, input := createDefaultTestInput(t)
+		_, _, addr := keyPubAddr()
+
+		counterBz, err := hexutil.Decode(counter.CounterBin)
+		require.NoError(t, err)
+
+		caller := common.BytesToAddress(addr.Bytes())
+		retBz, contractAddr, _, err := input.EVMKeeper.EVMCreate(ctx, caller, counterBz, nil, nil)
+		require.NoError(t, err)
+		require.NotEmpty(t, retBz)
+		require.Len(t, contractAddr, 20)
+
+		parsed, err := counter.CounterMetaData.GetAbi()
+		require.NoError(t, err)
+
+		count := getCount(t, ctx, input, contractAddr)
+		require.Equal(t, uint256.NewInt(0), count)
+
+		inputBz, err := parsed.Pack("increase_for_fuzz", uint64(numCount))
+		require.NoError(t, err)
+
+		atomicBloomBytes := atomic.Pointer[[]byte]{}
+		atomicBloomBytes.Store(nil)
+
+		var wg sync.WaitGroup
+		cacheCtxes := make([]sdk.Context, numThread)
+		for i := uint8(0); i < numThread; i++ {
+			wg.Add(1)
+			cacheCtx, _ := ctx.CacheContext()
+			cacheCtxes[i] = cacheCtx
+			go func(ctx sdk.Context) {
+				defer wg.Done()
+
+				// call with value
+				res, logs, err := input.EVMKeeper.EVMCall(ctx, caller, contractAddr, inputBz, nil, nil)
+				require.NoError(t, err)
+				require.Empty(t, res)
+				bloomBytes := coretypes.LogsBloom(logs.ToEthLogs())
+				prev := atomicBloomBytes.Swap(&bloomBytes)
+				require.True(t, prev == nil || bytes.Equal(*prev, bloomBytes))
+			}(cacheCtx)
+		}
+		wg.Wait()
+
+		for i := uint8(0); i < numThread; i++ {
+			count := getCount(t, cacheCtxes[i], input, contractAddr)
+			require.Equal(t, uint256.NewInt(uint64(numCount)), count)
+			require.NotEmpty(t, atomicBloomBytes.Load())
+		}
+	})
+}
+
+func getCount(t *testing.T, ctx sdk.Context, input TestKeepers, contractAddr common.Address) *uint256.Int {
+	parsed, err := counter.CounterMetaData.GetAbi()
+	require.NoError(t, err)
+
+	queryInputBz, err := parsed.Pack("count")
+	require.NoError(t, err)
+
+	queryRes, err := input.EVMKeeper.EVMStaticCall(ctx, types.StdAddress, contractAddr, queryInputBz, nil)
+	require.NoError(t, err)
+
+	return uint256.NewInt(0).SetBytes32(queryRes)
+}