Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-06-07 06:36:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

[NOD-1527] Allow to process headers while in missing utxo set sync state (#1018)

Browse Source 
* [NOD-1527] Allow to process headers while in missing utxo set sync state

* [NOD-1527] Add isHeaderOnlyBlock function
This commit is contained in:
Ori Newman 2020-11-10 04:43:18 -08:00 committed by GitHub
parent 32da4440ba
commit 31c5264430
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
domain/consensus/processes/blockprocessor/validateandinsertblock.go
View File

@ -15,20 +15,25 @@ func (bp *blockProcessor) validateAndInsertBlock(block *externalapi.DomainBlock)
hash := consensusserialization.HeaderHash(block.Header) hash := consensusserialization.HeaderHash(block.Header)
if mode.State == externalapi.SyncStateMissingUTXOSet { if mode.State == externalapi.SyncStateMissingUTXOSet {
headerTipsPruningPoint, err := bp.consensusStateManager.HeaderTipsPruningPoint() if isHeaderOnlyBlock(block) {
if err != nil { // Allow processing headers while in state SyncStateMissingUTXOSet
return err mode.State = externalapi.SyncStateHeadersFirst
} } else {
headerTipsPruningPoint, err := bp.consensusStateManager.HeaderTipsPruningPoint()
if err != nil {
return err
}
if *hash != *headerTipsPruningPoint { if *hash != *headerTipsPruningPoint {
return errors.Errorf("cannot insert blocks other than the header pruning point "+ return errors.Errorf("cannot insert blocks other than the header pruning point "+
"while in %s mode", mode.State) "while in %s mode", mode.State)
} }
mode.State = externalapi.SyncStateMissingBlockBodies mode.State = externalapi.SyncStateMissingBlockBodies
}
} }
if mode.State == externalapi.SyncStateHeadersFirst && len(block.Transactions) != 0 { if mode.State == externalapi.SyncStateHeadersFirst && !isHeaderOnlyBlock(block) {
mode.State = externalapi.SyncStateNormal mode.State = externalapi.SyncStateNormal
log.Warnf("block %s contains transactions while validating in header only mode", hash) log.Warnf("block %s contains transactions while validating in header only mode", hash)
} }
@ -138,6 +143,10 @@ func (bp *blockProcessor) updateReachabilityReindexRoot(oldHeadersSelectedTip *e
return bp.reachabilityManager.UpdateReindexRoot(headersSelectedTip) return bp.reachabilityManager.UpdateReindexRoot(headersSelectedTip)
} }
func isHeaderOnlyBlock(block *externalapi.DomainBlock) bool {
return len(block.Transactions) == 0
}
func (bp *blockProcessor) checkBlockStatus(hash *externalapi.DomainHash, mode *externalapi.SyncInfo) error { func (bp *blockProcessor) checkBlockStatus(hash *externalapi.DomainHash, mode *externalapi.SyncInfo) error {
exists, err := bp.blockStatusStore.Exists(bp.databaseContext, hash) exists, err := bp.blockStatusStore.Exists(bp.databaseContext, hash)
if err != nil { if err != nil {