mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-11-28 08:11:08 +00:00
1486a6312c
* Move timesorter to its own package and remove unused functions * Remove padding+genesis from BlockWindow * Adjust the difficulty even when there's less than difficultyAdjustmentWindowSize blocks * Remove unnecessary check from checkBlockTransactionsFinalized * Update tests with new pastMedianTime and Difficulty * Review nit
69 lines
2.4 KiB
Go
69 lines
2.4 KiB
Go
package dagtraversalmanager
|
|
|
|
import (
|
|
"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
|
|
)
|
|
|
|
// BlockWindow returns a blockWindow of the given size that contains the
|
|
// blocks in the past of startindNode, the sorting is unspecified.
|
|
// If the number of blocks in the past of startingNode is less then windowSize,
|
|
// the window will be padded by genesis blocks to achieve a size of windowSize.
|
|
func (dtm *dagTraversalManager) BlockWindow(startingBlock *externalapi.DomainHash, windowSize int) ([]*externalapi.DomainHash, error) {
|
|
currentGHOSTDAGData, err := dtm.ghostdagDataStore.Get(dtm.databaseContext, startingBlock)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
windowHeap := dtm.newSizedUpHeap(windowSize)
|
|
|
|
for windowHeap.len() <= windowSize && currentGHOSTDAGData.SelectedParent() != nil && !currentGHOSTDAGData.SelectedParent().Equal(dtm.genesisHash) {
|
|
selectedParentGHOSTDAGData, err := dtm.ghostdagDataStore.Get(dtm.databaseContext, currentGHOSTDAGData.SelectedParent())
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
added, err := windowHeap.tryPushWithGHOSTDAGData(currentGHOSTDAGData.SelectedParent(), selectedParentGHOSTDAGData)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// If the window is full and the selected parent is less than the minimum then we break
|
|
// because this means that there cannot be any more blocks in the past with higher blueWork
|
|
if !added {
|
|
break
|
|
}
|
|
|
|
// Now we go over the merge set.
|
|
// Remove the SP from the blue merge set because we already added it.
|
|
mergeSetBlues := currentGHOSTDAGData.MergeSetBlues()[1:]
|
|
// Go over the merge set in reverse because it's ordered in reverse by blueWork.
|
|
for i := len(mergeSetBlues) - 1; i >= 0; i-- {
|
|
added, err := windowHeap.tryPush(mergeSetBlues[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
// If it's smaller than minimum then we won't be able to add the rest because they're even smaller.
|
|
if !added {
|
|
break
|
|
}
|
|
}
|
|
mergeSetReds := currentGHOSTDAGData.MergeSetReds()
|
|
for i := len(mergeSetReds) - 1; i >= 0; i-- {
|
|
added, err := windowHeap.tryPush(mergeSetReds[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
// If it's smaller than minimum then we won't be able to add the rest because they're even smaller.
|
|
if !added {
|
|
break
|
|
}
|
|
}
|
|
currentGHOSTDAGData = selectedParentGHOSTDAGData
|
|
}
|
|
|
|
window := make([]*externalapi.DomainHash, 0, len(windowHeap.impl.slice))
|
|
for _, b := range windowHeap.impl.slice {
|
|
window = append(window, b.hash)
|
|
}
|
|
return window, nil
|
|
}
|