add metering for bulk memory opcodes

executor/executor.go

@@ -21,8 +21,8 @@ type CompilationOptions struct {
 type Executor interface {
 	check.NilInterfaceChecker
 
-	// SetOpcodeCosts sets gas costs globally inside an executor.
-	SetOpcodeCosts(opcodeCosts *WASMOpcodeCost)
+	// SetOpcodeConfig sets gas costs globally inside an executor.
+	SetOpcodeConfig(opcodeVersion OpcodeVersion, wasmOps *WASMOpcodeCost)
 
 	// FunctionNames return the low-level function names provided to contracts.
 	FunctionNames() vmcommon.FunctionNames

executor/executorFactory.go

@@ -5,6 +5,7 @@ import "github.com/multiversx/mx-chain-core-go/core/check"
 // ExecutorFactoryArgs define the Executor configurations that come from the VM, especially the hooks and the gas costs.
 type ExecutorFactoryArgs struct {
 	VMHooks                  VMHooks
+	OpcodeVersion            OpcodeVersion
 	OpcodeCosts              *WASMOpcodeCost
 	RkyvSerializationEnabled bool
 	WasmerSIGSEGVPassthrough bool

executor/executorOpcodeVersion.go

@@ -0,0 +1,8 @@
+package executor
+
+type OpcodeVersion uint32
+
+const (
+	OpcodeVersionV1 OpcodeVersion = iota
+	OpcodeVersionV2
+)

executor/wrapper/wrapperExecutor.go

@@ -15,9 +15,9 @@ type WrapperExecutor struct {
 	WrappedInstances map[string][]executor.Instance
 }
 
-// SetOpcodeCosts wraps the call to the underlying executor.
-func (wexec *WrapperExecutor) SetOpcodeCosts(opcodeCosts *executor.WASMOpcodeCost) {
-	wexec.wrappedExecutor.SetOpcodeCosts(opcodeCosts)
+// SetOpcodeConfig wraps the call to the underlying executor.
+func (wexec *WrapperExecutor) SetOpcodeConfig(opcodeVersion executor.OpcodeVersion, wasmOps *executor.WASMOpcodeCost) {
+	wexec.wrappedExecutor.SetOpcodeConfig(opcodeVersion, wasmOps)
 }
 
 // FunctionNames wraps the call to the underlying executor.

integrationTests/json/scenariosFeatures_test.go

@@ -95,6 +95,17 @@ func TestRustPayableFeatures(t *testing.T) {
 		CheckNoError()
 }
 
+func TestRustPanicMessageFeatures(t *testing.T) {
+	if testing.Short() {
+		t.Skip("not a short test")
+	}
+
+	ScenariosTest(t).
+		Folder("features/panic-message-features/scenarios").
+		Run().
+		CheckNoError()
+}
+
 func TestRustComposability(t *testing.T) {
 	ScenariosTest(t).
 		Folder("features/composability/scenarios").

mock/context/executorMock.go

@@ -55,8 +55,8 @@ func NewExecutorMock(world *worldmock.MockWorld) *ExecutorMock {
 	}
 }
 
-// SetOpcodeCosts should set gas costs, but it does nothing in the case of this mock.
-func (executorMock *ExecutorMock) SetOpcodeCosts(_ *executor.WASMOpcodeCost) {
+// SetOpcodeConfig should set gas costs, but it does nothing in the case of this mock.
+func (executorMock *ExecutorMock) SetOpcodeConfig(_ executor.OpcodeVersion, _ *executor.WASMOpcodeCost) {
 }
 
 // FunctionNames mocked method

vmhost/contexts/async_test.go

@@ -2,10 +2,11 @@ package contexts
 
 import (
 	"errors"
-	"github.com/multiversx/mx-chain-vm-go/wasmer2"
 	"math/big"
 	"testing"
 
+	"github.com/multiversx/mx-chain-vm-go/wasmer2"
+
 	"github.com/multiversx/mx-chain-core-go/data/vm"
 	"github.com/multiversx/mx-chain-core-go/marshal"
 	"github.com/multiversx/mx-chain-scenario-go/worldmock"
@@ -59,7 +60,7 @@ func initializeVMAndWasmerAsyncContextWithBuiltIn(tb testing.TB, isBuiltinFunc b
 	gasCostConfig, err := config.CreateGasConfig(gasSchedule)
 	require.Nil(tb, err)
 	wasmerExecutor, _ := wasmer2.CreateExecutor()
-	wasmerExecutor.SetOpcodeCosts(gasCostConfig.WASMOpcodeCost)
+	wasmerExecutor.SetOpcodeConfig(executor.OpcodeVersionV2, gasCostConfig.WASMOpcodeCost)
 
 	host := &contextmock.VMHostMock{
 		EnableEpochsHandlerField: &worldmock.EnableEpochsHandlerStub{},

vmhost/contexts/runtime_test.go

@@ -34,7 +34,7 @@ func InitializeVMAndWasmer() *contextmock.VMHostMock {
 	gasSchedule := config.MakeGasMapForTests()
 	gasCostConfig, _ := config.CreateGasConfig(gasSchedule)
 	wasmerExecutor, _ := wasmer2.CreateExecutor()
-	wasmerExecutor.SetOpcodeCosts(gasCostConfig.WASMOpcodeCost)
+	wasmerExecutor.SetOpcodeConfig(executor.OpcodeVersionV2, gasCostConfig.WASMOpcodeCost)
 
 	host := &contextmock.VMHostMock{}
 

vmhost/hostCore/host.go

@@ -220,8 +220,10 @@ func (host *vmHost) createExecutor(hostParameters *vmhost.VMHostParameters) (exe
 	} else {
 		vmExecutorFactory = wasmer2.ExecutorFactory()
 	}
+
 	vmExecutorFactoryArgs := executor.ExecutorFactoryArgs{
 		VMHooks:                  vmHooks,
+		OpcodeVersion:            host.getOpcodeVersionForCurrentEpoch(),
 		OpcodeCosts:              gasCostConfig.WASMOpcodeCost,
 		RkyvSerializationEnabled: true,
 		WasmerSIGSEGVPassthrough: hostParameters.WasmerSIGSEGVPassthrough,
@@ -348,6 +350,14 @@ func (host *vmHost) ClearContextStateStack() {
 	host.blockchainContext.ClearStateStack()
 }
 
+func (host *vmHost) getOpcodeVersionForCurrentEpoch() executor.OpcodeVersion {
+	if host.enableEpochsHandler.IsFlagEnabled(vmhost.AsyncV3Flag) {
+		return executor.OpcodeVersionV2
+	}
+
+	return executor.OpcodeVersionV1
+}
+
 // GasScheduleChange applies a new gas schedule to the host
 func (host *vmHost) GasScheduleChange(newGasSchedule config.GasScheduleMap) {
 	host.mutExecution.Lock()
@@ -360,7 +370,9 @@ func (host *vmHost) GasScheduleChange(newGasSchedule config.GasScheduleMap) {
 		return
 	}
 
-	host.runtimeContext.GetVMExecutor().SetOpcodeCosts(gasCostConfig.WASMOpcodeCost)
+	opcodeVersion := host.getOpcodeVersionForCurrentEpoch()
+
+	host.runtimeContext.GetVMExecutor().SetOpcodeConfig(opcodeVersion, gasCostConfig.WASMOpcodeCost)
 
 	host.meteringContext.SetGasSchedule(newGasSchedule)
 	host.runtimeContext.ClearWarmInstanceCache()

vmhost/hosttest/forbidden_opcodes_test.go

@@ -11,7 +11,7 @@ import (
 )
 
 func TestForbiddenOps_BulkAndSIMD(t *testing.T) {
-	wasmModules := []string{"data-drop", "memory-init", "memory-fill", "memory-copy", "simd"}
+	wasmModules := []string{"data-drop", "memory-init", "simd"}
 
 	for _, moduleName := range wasmModules {
 		testCase := testcommon.BuildInstanceCallTest(t).
@@ -61,3 +61,38 @@ func TestBarnardOpcodesActivation(t *testing.T) {
 				ContractInvalid()
 		})
 }
+
+func TestBulkMemoryOpcodesActivation(t *testing.T) {
+	wasmModules := []string{"memory-copy", "memory-fill"}
+
+	for _, moduleName := range wasmModules {
+		testcommon.BuildInstanceCreatorTest(t).
+			WithInput(testcommon.CreateTestContractCreateInputBuilder().
+				WithGasProvided(100000000).
+				WithContractCode(testcommon.GetTestSCCodeModule("forbidden-opcodes/"+moduleName, moduleName, "../../")).
+				Build()).
+			WithEnableEpochsHandler(&worldmock.EnableEpochsHandlerStub{
+				IsFlagEnabledCalled: func(flag core.EnableEpochFlag) bool {
+					return flag != vmhost.AsyncV3Flag
+				},
+			}).
+			AndAssertResults(func(stubBlockchainHook *contextmock.BlockchainHookStub, verify *testcommon.VMOutputVerifier) {
+				verify.
+					ContractInvalid()
+			})
+
+		testcommon.BuildInstanceCreatorTest(t).
+			WithInput(testcommon.CreateTestContractCreateInputBuilder().
+				WithGasProvided(100000000).
+				WithContractCode(testcommon.GetTestSCCodeModule("forbidden-opcodes/"+moduleName, moduleName, "../../")).
+				Build()).
+			WithEnableEpochsHandler(&worldmock.EnableEpochsHandlerStub{
+				IsFlagEnabledCalled: func(flag core.EnableEpochFlag) bool {
+					return true
+				},
+			}).
+			AndAssertResults(func(stubBlockchainHook *contextmock.BlockchainHookStub, verify *testcommon.VMOutputVerifier) {
+				verify.FunctionNotFound()
+			})
+	}
+}

vmhost/vmhooks/generate/cmd/.gitignore

@@ -1,5 +1,9 @@
 # generated files that belong to other repos:
 output
 
-# optional path where to copy rust files
+# optional path where to copy rust files (deprecated)
 wasm-vm-executor-rs-path.txt
+
+# optional path where to copy rust files
+path-to-mx-sdk-rs.txt
+path-to-vm-executor-rs.txt