Skip to content

Commit

Permalink
fix race in tests
Browse files Browse the repository at this point in the history
  • Loading branch information
sstanculeanu committed Jun 27, 2023
1 parent 46a4908 commit afb6675
Showing 1 changed file with 25 additions and 19 deletions.
44 changes: 25 additions & 19 deletions process/transaction/shardProcess_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -90,9 +90,9 @@ func createArgsForTxProcessor() txproc.ArgsNewTxProcessor {
EnableEpochsHandler: &enableEpochsHandlerMock.EnableEpochsHandlerStub{
IsPenalizedTooMuchGasFlagEnabledField: true,
},
GuardianChecker: &guardianMocks.GuardedAccountHandlerStub{},
TxVersionChecker: &testscommon.TxVersionCheckerStub{},
TxLogsProcessor: &mock.TxLogsProcessorStub{},
GuardianChecker: &guardianMocks.GuardedAccountHandlerStub{},
TxVersionChecker: &testscommon.TxVersionCheckerStub{},
TxLogsProcessor: &mock.TxLogsProcessorStub{},
EnableRoundsHandler: &testscommon.EnableRoundsHandlerStub{},
}
return args
Expand Down Expand Up @@ -3258,37 +3258,43 @@ func TestTxProcessor_shouldIncreaseNonce(t *testing.T) {
func TestTxProcessor_AddNonExecutableLog(t *testing.T) {
t.Parallel()

args := createArgsForTxProcessor()
sender := []byte("sender")
relayer := []byte("relayer")
originalTx := &transaction.Transaction{
SndAddr: relayer,
RcvAddr: sender,
}
originalTxHash, err := core.CalculateHash(args.Marshalizer, args.Hasher, originalTx)
assert.Nil(t, err)

t.Run("not a non-executable error should not record log", func(t *testing.T) {
t.Parallel()

argsLocal := args
argsLocal.TxLogsProcessor = &mock.TxLogsProcessorStub{
args := createArgsForTxProcessor()
sender := []byte("sender")
relayer := []byte("relayer")
originalTx := &transaction.Transaction{
SndAddr: relayer,
RcvAddr: sender,
}
originalTxHash, err := core.CalculateHash(args.Marshalizer, args.Hasher, originalTx)
assert.Nil(t, err)
args.TxLogsProcessor = &mock.TxLogsProcessorStub{
SaveLogCalled: func(txHash []byte, tx data.TransactionHandler, vmLogs []*vmcommon.LogEntry) error {
assert.Fail(t, "should have not called SaveLog")

return nil
},
}
txProc, _ := txproc.NewTxProcessor(argsLocal)
txProc, _ := txproc.NewTxProcessor(args)
err = txProc.AddNonExecutableLog(errors.New("random error"), originalTxHash, originalTx)
assert.Nil(t, err)
})
t.Run("is non executable tx error should record log", func(t *testing.T) {
t.Parallel()

argsLocal := args
args := createArgsForTxProcessor()
sender := []byte("sender")
relayer := []byte("relayer")
originalTx := &transaction.Transaction{
SndAddr: relayer,
RcvAddr: sender,
}
originalTxHash, err := core.CalculateHash(args.Marshalizer, args.Hasher, originalTx)
assert.Nil(t, err)
numLogsSaved := 0
argsLocal.TxLogsProcessor = &mock.TxLogsProcessorStub{
args.TxLogsProcessor = &mock.TxLogsProcessorStub{
SaveLogCalled: func(txHash []byte, tx data.TransactionHandler, vmLogs []*vmcommon.LogEntry) error {
assert.Equal(t, originalTxHash, txHash)
assert.Equal(t, originalTx, tx)
Expand All @@ -3304,7 +3310,7 @@ func TestTxProcessor_AddNonExecutableLog(t *testing.T) {
},
}

txProc, _ := txproc.NewTxProcessor(argsLocal)
txProc, _ := txproc.NewTxProcessor(args)
err = txProc.AddNonExecutableLog(process.ErrLowerNonceInTransaction, originalTxHash, originalTx)
assert.Nil(t, err)

Expand Down

0 comments on commit afb6675

Please sign in to comment.