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

Cache virtual past median time (#1775)

Browse Source 
* Add cache for virtual pastMedianTime

* Implement InvalidateVirtualPastMedianTimeCache for mocPastMedianTimeManager
This commit is contained in:
Svarog 2021-07-04 11:47:43 +03:00 committed by GitHub
parent 2f7a1395e7
commit f7cce5cb39
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
domain/consensus/model/interface_processes_pastmediantimemanager.go
View File

@ -6,4 +6,5 @@ import "github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
// past median time of a block
type PastMedianTimeManager interface {
PastMedianTime(stagingArea *StagingArea, blockHash *externalapi.DomainHash) (int64, error)
InvalidateVirtualPastMedianTimeCache()
}

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

@ -184,6 +184,8 @@ func (bp *blockProcessor) validateAndInsertBlock(stagingArea *model.StagingArea,
return nil, err
}
bp.pastMedianTimeManager.InvalidateVirtualPastMedianTimeCache()
bp.blockLogger.LogBlock(block)
return &externalapi.BlockInsertionResult{

20
domain/consensus/processes/pastmediantimemanager/pastmediantimemanager.go
View File

@ -23,6 +23,8 @@ type pastMedianTimeManager struct {
ghostdagDataStore model.GHOSTDAGDataStore
genesisHash *externalapi.DomainHash
virtualPastMedianTimeCache int64
}
// New instantiates a new PastMedianTimeManager
@ -47,6 +49,9 @@ func New(timestampDeviationTolerance int,
// PastMedianTime returns the past median time for some block
func (pmtm *pastMedianTimeManager) PastMedianTime(stagingArea *model.StagingArea, blockHash *externalapi.DomainHash) (int64, error) {
if blockHash == model.VirtualBlockHash && pmtm.virtualPastMedianTimeCache != 0 {
return pmtm.virtualPastMedianTimeCache, nil
}
window, err := pmtm.dagTraversalManager.BlockWindow(stagingArea, blockHash, 2*pmtm.timestampDeviationTolerance-1)
if err != nil {
return 0, err
@ -59,7 +64,16 @@ func (pmtm *pastMedianTimeManager) PastMedianTime(stagingArea *model.StagingArea
return header.TimeInMilliseconds(), nil
}
return pmtm.windowMedianTimestamp(stagingArea, window)
pastMedianTime, err := pmtm.windowMedianTimestamp(stagingArea, window)
if err != nil {
return 0, err
}
if blockHash == model.VirtualBlockHash {
pmtm.virtualPastMedianTimeCache = pastMedianTime
}
return pastMedianTime, nil
}
func (pmtm *pastMedianTimeManager) windowMedianTimestamp(
@ -82,3 +96,7 @@ func (pmtm *pastMedianTimeManager) windowMedianTimestamp(
return timestamps[len(timestamps)/2], nil
}
func (pmtm *pastMedianTimeManager) InvalidateVirtualPastMedianTimeCache() {
pmtm.virtualPastMedianTimeCache = 0
}

4
domain/consensus/processes/transactionvalidator/transactionvalidator_test.go
View File

@ -23,6 +23,10 @@ type mocPastMedianTimeManager struct {
pastMedianTimeForTest int64
}
func (mdf *mocPastMedianTimeManager) InvalidateVirtualPastMedianTimeCache() {
// do nothing
}
// PastMedianTime returns the past median time for the test.
func (mdf *mocPastMedianTimeManager) PastMedianTime(*model.StagingArea, *externalapi.DomainHash) (int64, error) {
return mdf.pastMedianTimeForTest, nil