aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorDeterminant <[email protected]>2020-09-17 13:27:52 -0400
committerDeterminant <[email protected]>2020-09-17 13:27:52 -0400
commitbfd47a0a7e61e39dcb53c684f5d25cfb399a7ad6 (patch)
tree2935366d4e4dbbb418c1d0497ab5f2ae6714a8c7 /core
parent9a7005df93a88378981c84793769de9b57a67b53 (diff)
disable reorg entirelygeth-tavum
Diffstat (limited to 'core')
-rw-r--r--core/blockchain.go20
1 files changed, 11 insertions, 9 deletions
diff --git a/core/blockchain.go b/core/blockchain.go
index 82e3b6c..cfdd07d 100644
--- a/core/blockchain.go
+++ b/core/blockchain.go
@@ -1420,7 +1420,7 @@ func (bc *BlockChain) writeKnownBlock(block *types.Block) error {
defer bc.wg.Done()
current := bc.CurrentBlock()
- if block.ParentHash() != current.Hash() {
+ if !bc.manualCanonical && block.ParentHash() != current.Hash() {
if err := bc.reorg(current, block); err != nil {
return err
}
@@ -2051,6 +2051,7 @@ func (bc *BlockChain) insertSideChain(block *types.Block, it *insertIterator) (i
// blocks and inserts them to be part of the new canonical chain and accumulates
// potential missing transactions and post an event about them.
func (bc *BlockChain) reorg(oldBlock, newBlock *types.Block) error {
+ log.Error("reorg shouldn't happen!!!")
var (
newChain types.Blocks
oldChain types.Blocks
@@ -2492,12 +2493,13 @@ func (bc *BlockChain) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscr
}
func (bc *BlockChain) ManualHead(hash common.Hash) error {
- block := bc.GetBlockByHash(hash)
- if block == nil {
- return errors.New("block not found")
- }
- bc.chainmu.Lock()
- defer bc.chainmu.Unlock()
- bc.writeHeadBlock(block)
- return nil
+ return bc.FastSyncCommitHead(hash)
+ //block := bc.GetBlockByHash(hash)
+ //if block == nil {
+ // return errors.New("block not found")
+ //}
+ //bc.chainmu.Lock()
+ //defer bc.chainmu.Unlock()
+ //bc.writeHeadBlock(block)
+ //return nil
}