Commit 5952c08c authored by duanjinfei's avatar duanjinfei

add sign tx arr mux

parent da14080b
...@@ -161,9 +161,13 @@ func signedTxFunc() (*types.Transaction, error) { ...@@ -161,9 +161,13 @@ func signedTxFunc() (*types.Transaction, error) {
} }
txcache.Add(signedTx.Hash().Hex(), t.sender.Hex()) txcache.Add(signedTx.Hash().Hex(), t.sender.Hex())
atomic.AddInt32(&batchSignCount, 1) atomic.AddInt32(&batchSignCount, 1)
Add(signedTx)
}
}
}
func Add(signedTx *types.Transaction) {
signTranArr.mux.Lock() signTranArr.mux.Lock()
defer signTranArr.mux.Unlock() defer signTranArr.mux.Unlock()
signTranArr.TranArr = append(signTranArr.TranArr, signedTx) signTranArr.TranArr = append(signTranArr.TranArr, signedTx)
}
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment