diff options
author | Jimmy Hu <jimmy.hu@dexon.org> | 2018-11-21 10:26:36 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:27:18 +0800 |
commit | 43846e6cfaa477d406277895275bf3c722e1bdec (patch) | |
tree | d2cd1f22e3eea148a135db74d1e4bf7d0a3d11c4 /core | |
parent | e9532ec6357747676433acfd5f6240dada406f87 (diff) | |
download | go-tangerine-43846e6cfaa477d406277895275bf3c722e1bdec.tar.gz go-tangerine-43846e6cfaa477d406277895275bf3c722e1bdec.tar.zst go-tangerine-43846e6cfaa477d406277895275bf3c722e1bdec.zip |
core, dex: Batch process touchSender. Lower priority for tx. (#41)
* dex: Add a tx queue in broadcast
* Modify queue parameter
* Priority select all messages except tx
* Batch process TouchSenders
Diffstat (limited to 'core')
-rw-r--r-- | core/types/transaction.go | 32 |
1 files changed, 19 insertions, 13 deletions
diff --git a/core/types/transaction.go b/core/types/transaction.go index 46c24bd81..5e11c0dbc 100644 --- a/core/types/transaction.go +++ b/core/types/transaction.go @@ -21,6 +21,7 @@ import ( "errors" "io" "math/big" + "runtime" "sync" "sync/atomic" @@ -274,24 +275,29 @@ func (s Transactions) GetRlp(i int) []byte { // TouchSenders calculates the sender of each transaction and update the cache. func (s Transactions) TouchSenders(signer Signer) (errorTx *Transaction, err error) { + num := runtime.NumCPU() + batchSize := len(s) / num wg := sync.WaitGroup{} - wg.Add(len(s)) + wg.Add(num) txError := make(chan error, 1) - for _, tx := range s { - go func(tx *Transaction) { + for i := 0; i < num; i++ { + go func(txs Transactions) { defer wg.Done() - if len(txError) > 0 { - return - } - _, err := Sender(signer, tx) - if err != nil { - select { - case txError <- err: - errorTx = tx - default: + for _, tx := range txs { + if len(txError) > 0 { + return + } + _, err := Sender(signer, tx) + if err != nil { + select { + case txError <- err: + errorTx = tx + default: + } + return } } - }(tx) + }(s[i*batchSize : (i+1)*batchSize]) } wg.Wait() select { |