diff options
author | Sonic <sonic@dexon.org> | 2018-11-21 13:37:16 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:27:18 +0800 |
commit | 9d8b455d62d851d265a8383a5d34e9c594ff89c9 (patch) | |
tree | a1cde73a7a77db35f12d2a4d29b8da098f4165f3 /dex | |
parent | 708606074cba33a91026b6378456bd6311749369 (diff) | |
download | go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar.gz go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar.bz2 go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar.lz go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar.xz go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.tar.zst go-tangerine-9d8b455d62d851d265a8383a5d34e9c594ff89c9.zip |
core, dex, dex/downloader: restore insertChain to upstream version
Also rename InsertChain2, insertChain2, InsertHeaderChain2,
ValidateHeaderChain2
Diffstat (limited to 'dex')
-rw-r--r-- | dex/downloader/downloader.go | 12 | ||||
-rw-r--r-- | dex/handler.go | 2 |
2 files changed, 7 insertions, 7 deletions
diff --git a/dex/downloader/downloader.go b/dex/downloader/downloader.go index 69d95d801..828c7c6bc 100644 --- a/dex/downloader/downloader.go +++ b/dex/downloader/downloader.go @@ -180,8 +180,8 @@ type LightChain interface { // GetTd returns the total difficulty of a local block. GetTd(common.Hash, uint64) *big.Int - // InsertHeaderChain2 inserts a batch of headers into the local chain. - InsertHeaderChain2([]*types.HeaderWithGovState, *dexCore.TSigVerifierCache) (int, error) + // InsertDexonHeaderChain inserts a batch of headers into the local chain. + InsertDexonHeaderChain([]*types.HeaderWithGovState, *dexCore.TSigVerifierCache) (int, error) // Rollback removes a few recently added elements from the local chain. Rollback([]common.Hash) @@ -206,8 +206,8 @@ type BlockChain interface { // FastSyncCommitHead directly commits the head block to a certain entity. FastSyncCommitHead(common.Hash) error - // InsertChain2 inserts a batch of blocks into the local chain. - InsertChain2(types.Blocks) (int, error) + // InsertDexonChain inserts a batch of blocks into the local chain. + InsertDexonChain(types.Blocks) (int, error) // InsertReceiptChain inserts a batch of receipts into the local chain. InsertReceiptChain(types.Blocks, []types.Receipts) (int, error) @@ -1421,7 +1421,7 @@ func (d *Downloader) processHeaders(origin uint64, pivot uint64, td *big.Int) er } } - if n, err := d.lightchain.InsertHeaderChain2(chunk, d.verifierCache); err != nil { + if n, err := d.lightchain.InsertDexonHeaderChain(chunk, d.verifierCache); err != nil { // If some headers were inserted, add them too to the rollback list if n > 0 { for _, h := range chunk[:n] { @@ -1513,7 +1513,7 @@ func (d *Downloader) importBlockResults(results []*fetchResult) error { for i, result := range results { blocks[i] = types.NewBlockWithHeader(result.Header).WithBody(result.Transactions, result.Uncles) } - if index, err := d.blockchain.InsertChain2(blocks); err != nil { + if index, err := d.blockchain.InsertDexonChain(blocks); err != nil { log.Debug("Downloaded item processing failed", "number", results[index].Header.Number, "hash", results[index].Header.Hash(), "err", err) return errInvalidChain } diff --git a/dex/handler.go b/dex/handler.go index 0c7a3e919..a86a68329 100644 --- a/dex/handler.go +++ b/dex/handler.go @@ -221,7 +221,7 @@ func NewProtocolManager( return 0, nil } atomic.StoreUint32(&manager.acceptTxs, 1) // Mark initial sync done on any fetcher import - return manager.blockchain.InsertChain2(blocks) + return manager.blockchain.InsertDexonChain(blocks) } manager.fetcher = fetcher.New(blockchain.GetBlockByHash, validator, manager.BroadcastBlock, heighter, inserter, manager.removePeer) |