diff options
| author | Bojie Wu <bojie@dexon.org> | 2018-10-09 13:28:45 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-03-12 12:19:09 +0800 |
| commit | e776662999ddf0ab195fb731975643708fa2e8c3 (patch) | |
| tree | deb415ca4e0f32bb5889d6a50559d0da1d4c187e /dex | |
| parent | f55fd11ed93d15d47e914eb61289ca18ce51f4de (diff) | |
| download | dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar.gz dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar.bz2 dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar.lz dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar.xz dexon-e776662999ddf0ab195fb731975643708fa2e8c3.tar.zst dexon-e776662999ddf0ab195fb731975643708fa2e8c3.zip | |
app: fix bug when prepare transaction
Diffstat (limited to 'dex')
| -rw-r--r-- | dex/app.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/dex/app.go b/dex/app.go index 577135dc0..d5b7d3556 100644 --- a/dex/app.go +++ b/dex/app.go @@ -160,6 +160,8 @@ func (d *DexconApp) PreparePayload(position coreTypes.Position) (payload []byte, blockGasLimit := new(big.Int).SetUint64(core.CalcGasLimit(d.blockchain.CurrentBlock(), d.config.GasFloor, d.config.GasCeil)) blockGasUsed := new(big.Int) var allTxs types.Transactions + +addressMap: for address, txs := range txsMap { // every address's transactions will appear in fixed chain if !d.checkChain(address, chainNums, chainID) { @@ -217,8 +219,7 @@ func (d *DexconApp) PreparePayload(position coreTypes.Position) (payload []byte, blockGasUsed = new(big.Int).Add(blockGasUsed, new(big.Int).SetUint64(tx.Gas())) if blockGasLimit.Cmp(blockGasUsed) < 0 { - log.Error("Reach block gas limit", "limit", blockGasLimit, "gasUsed", blockGasUsed) - return nil, fmt.Errorf("reach block gas limit %v", blockGasLimit) + break addressMap } allTxs = append(allTxs, tx) @@ -238,9 +239,13 @@ func (d *DexconApp) PrepareWitness(consensusHeight uint64) (witness coreTypes.Wi if d.lastPendingHeight == 0 && consensusHeight == 0 { witnessBlock = d.blockchain.CurrentBlock() } else if d.lastPendingHeight >= consensusHeight { + d.insertMu.Lock() witnessBlock = d.blockchain.GetPendingBlockByHeight(d.lastPendingHeight) + d.insertMu.Unlock() } else if h := <-d.addNotify(consensusHeight); h >= consensusHeight { + d.insertMu.Lock() witnessBlock = d.blockchain.GetPendingBlockByHeight(h) + d.insertMu.Unlock() } else { log.Error("need pending block") return witness, fmt.Errorf("need pending block") |