diff options
author | Sonic <sonic@dexon.org> | 2018-11-21 13:37:16 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2018-12-19 20:54:27 +0800 |
commit | 150bbcce6cb82acac6d1b74e5721709c5090eecc (patch) | |
tree | 8f928df72d315279da9cbcf9554390a24681dbc7 /dex | |
parent | 93317fbb29d0f9ad85b3a78eb61c963fad6d9742 (diff) | |
download | dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar.gz dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar.bz2 dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar.lz dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar.xz dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.tar.zst dexon-150bbcce6cb82acac6d1b74e5721709c5090eecc.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 a0e160b3e..0e24b631a 100644 --- a/dex/handler.go +++ b/dex/handler.go @@ -226,7 +226,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) |