fix

loadtest/helpers/init.js

@@ -9,10 +9,11 @@ export function fundTestAccounts(client, root_address) {
 
     // fund the VUs accounts
     for (let i = 0; i < exec.instance.vusInitialized; i++) {
-        var tacc = wallet.generateKey();
+        var tacc = wallet.generateKey();        
         accounts[i] = {
             private_key: tacc.private_key,
             address: tacc.address,
+            nonce: 0,
         };
 
         // fund each account with some coins

loadtest/scenarios/multiple_EOA.js

@@ -64,30 +64,32 @@ export function setup() {
   return { accounts: fundTestAccounts(client, root_address) };
 }
 
-var nonce = 0;
-var client;
+var clients = [];
 
 // VU client
 export default function (data) {
+  var client = clients[exec.vu.idInInstance - 1];
   if (client == null) {
     client = new eth.Client({
       url: rpc_url,
       privateKey: data.accounts[exec.vu.idInInstance - 1].private_key
     });
+
+    clients[exec.vu.idInInstance - 1] = client;
   }
 
-  console.log(`nonce => ${nonce}`);
+  const userData = data.accounts[exec.vu.idInInstance - 1]
 
   const tx = {
     to: "0xDEADBEEFDEADBEEFDEADBEEFDEADBEEFDEADBEEF",
     value: Number(0.00000001 * 1e18),
     gas_price: client.gasPrice(),
-    nonce: nonce,
+    nonce: userData.nonce,
   };
 
   const txh = client.sendRawTransaction(tx);
-  console.log("tx hash => " + txh);
-  nonce++;
+  console.log("sender => " + userData.address + " tx hash => " + txh + " nonce => " + userData.nonce);
+  userData.nonce++;
 
   // client.waitForTransactionReceipt(txh).then((receipt) => {
   //   console.log("tx block hash => " + receipt.block_hash);

loadtest/scenarios/multiple_ERC20.js

@@ -73,26 +73,28 @@ export function setup() {
     };
 }
 
-let nonce = 0;
-let client;
+var clients = [];
 
 // VU client
 export default function (data) {
-    let acc = data.accounts[exec.vu.idInInstance - 1];
-
+    var client = clients[exec.vu.idInInstance - 1];
     if (client == null) {
-        client = new eth.Client({
-            url: rpc_url,
-            privateKey: acc.private_key
-        });
+      client = new eth.Client({
+        url: rpc_url,
+        privateKey: data.accounts[exec.vu.idInInstance - 1].private_key
+      });
+
+      clients[exec.vu.idInInstance - 1] = client;
     }
 
+    let acc = data.accounts[exec.vu.idInInstance - 1];
+
     console.log(acc.address);
     const con = client.newContract(data.contract_address, JSON.stringify(ZexCoin.abi));
-    const res = con.txn("transfer", { gas_limit: 100000, nonce: nonce }, acc.address, 1);
+    const res = con.txn("transfer", { gas_limit: 100000, nonce: acc.nonce }, acc.address, 1);
     console.log(`txn hash => ${res}`);
 
-    nonce++;
+    acc.nonce++;
     // console.log(JSON.stringify(con.call("balanceOf", acc.address)));
 }
 

server/server.go

@@ -343,6 +343,7 @@ func NewServer(config *Config) (*Server, error) {
 				PriceLimit:         m.config.PriceLimit,
 				MaxAccountEnqueued: m.config.MaxAccountEnqueued,
 				ChainID:            big.NewInt(m.config.Chain.Params.ChainID),
+				PeerID:             m.network.AddrInfo().ID,
 			},
 		)
 		if err != nil {

txpool/txpool.go

@@ -102,6 +102,7 @@ type Config struct {
 	MaxSlots           uint64
 	MaxAccountEnqueued uint64
 	ChainID            *big.Int
+	PeerID             peer.ID
 }
 
 /* All requests are passed to the main loop
@@ -186,6 +187,9 @@ type TxPool struct {
 
 	// chain id
 	chainID *big.Int
+
+	// localPeerID is the peer ID of the local node that is running the txpool
+	localPeerID peer.ID
 }
 
 // NewTxPool returns a new pool for processing incoming transactions.
@@ -207,6 +211,7 @@ func NewTxPool(
 		gauge:       slotGauge{height: 0, max: config.MaxSlots},
 		priceLimit:  config.PriceLimit,
 		chainID:     config.ChainID,
+		localPeerID: config.PeerID,
 
 		//	main loop channels
 		promoteReqCh: make(chan promoteRequest),
@@ -919,11 +924,16 @@ func (p *TxPool) handlePromoteRequest(req promoteRequest) {
 
 // addGossipTx handles receiving transactions
 // gossiped by the network.
-func (p *TxPool) addGossipTx(obj interface{}, _ peer.ID) {
+func (p *TxPool) addGossipTx(obj interface{}, peerID peer.ID) {
 	if !p.sealing.Load() {
 		return
 	}
 
+	// ignore txs gossiped by the node itself
+	if p.localPeerID == peerID {
+		return
+	}
+
 	raw, ok := obj.(*proto.Txn)
 	if !ok {
 		p.logger.Error("failed to cast gossiped message to txn")