aboutsummaryrefslogtreecommitdiffstats
path: root/internal
diff options
context:
space:
mode:
authorMartin Holst Swende <martin@swende.se>2017-05-19 21:03:56 +0800
committerFelix Lange <fjl@users.noreply.github.com>2017-05-19 21:03:56 +0800
commit83721a95ce486464dd825842f80061813ebb6b83 (patch)
tree4e7df4fdb26229dd6ddcebb777bdc24c40895966 /internal
parenta2f23ca9b181fa4409fdee3076316f3127038b9b (diff)
downloaddexon-83721a95ce486464dd825842f80061813ebb6b83.tar.gz
dexon-83721a95ce486464dd825842f80061813ebb6b83.tar.zst
dexon-83721a95ce486464dd825842f80061813ebb6b83.zip
internal/ethapi: lock when auto-filling transaction nonce (#14483)
More context in the bug This solves the problems of transactions being submitted simultaneously, and getting the same nonce, due to the gap (due to signing) between nonce-issuance and nonce-update. With this PR, a lock will need to be acquired whenever a nonce is used, and released when the transaction is submitted or errors out.
Diffstat (limited to 'internal')
-rw-r--r--internal/ethapi/api.go23
1 files changed, 23 insertions, 0 deletions
diff --git a/internal/ethapi/api.go b/internal/ethapi/api.go
index f9eed8797..62edc695c 100644
--- a/internal/ethapi/api.go
+++ b/internal/ethapi/api.go
@@ -24,6 +24,7 @@ import (
"fmt"
"math/big"
"strings"
+ "sync"
"time"
"github.com/ethereum/go-ethereum/accounts"
@@ -890,6 +891,12 @@ type PublicTransactionPoolAPI struct {
b Backend
}
+// nonceMutex is a global mutex for locking the nonce while a transaction
+// is being submitted. This should be used when a nonce has not been provided by the user,
+// and we get a nonce from the pools. The mutex prevents the (an identical nonce) from being
+// read again during the time that the first transaction is being signed.
+var nonceMutex sync.RWMutex
+
// NewPublicTransactionPoolAPI creates a new RPC service with methods specific for the transaction pool.
func NewPublicTransactionPoolAPI(b Backend) *PublicTransactionPoolAPI {
return &PublicTransactionPoolAPI{b}
@@ -1170,6 +1177,14 @@ func submitTransaction(ctx context.Context, b Backend, tx *types.Transaction) (c
// SendTransaction creates a transaction for the given argument, sign it and submit it to the
// transaction pool.
func (s *PublicTransactionPoolAPI) SendTransaction(ctx context.Context, args SendTxArgs) (common.Hash, error) {
+
+ if args.Nonce == nil {
+ // We'll need to set nonce from pool, and thus we need to lock here
+ nonceMutex.Lock()
+ defer nonceMutex.Unlock()
+
+ }
+
// Set some sanity defaults and terminate on failure
if err := args.setDefaults(ctx, s.b); err != nil {
return common.Hash{}, err
@@ -1257,6 +1272,14 @@ type SignTransactionResult struct {
// The node needs to have the private key of the account corresponding with
// the given from address and it needs to be unlocked.
func (s *PublicTransactionPoolAPI) SignTransaction(ctx context.Context, args SendTxArgs) (*SignTransactionResult, error) {
+
+ if args.Nonce == nil {
+ // We'll need to set nonce from pool, and thus we need to lock here
+ nonceMutex.Lock()
+ defer nonceMutex.Unlock()
+
+ }
+
if err := args.setDefaults(ctx, s.b); err != nil {
return nil, err
}