mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-08-01 16:23:20 +00:00

* Add cache to block window * Copy the window heap slice with the right capacity * Use WindowHeapSliceStore * Use the selected parent window as a basis (and some comments and variable renames) * Clone slice on newSizedUpHeapFromSlice * Rename isNotFoundError->currentIsNonTrustedBlock * Increase windowHeapSliceStore cache size to 2000 and some cosmetic changes
80 lines
2.1 KiB
Go
80 lines
2.1 KiB
Go
package lrucachehashandwindowsizetoblockghostdagdatahashpairs
|
|
|
|
import "github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
|
|
|
|
type lruKey struct {
|
|
blockHash externalapi.DomainHash
|
|
windowSize int
|
|
}
|
|
|
|
func newKey(blockHash *externalapi.DomainHash, windowSize int) lruKey {
|
|
return lruKey{
|
|
blockHash: *blockHash,
|
|
windowSize: windowSize,
|
|
}
|
|
}
|
|
|
|
// LRUCache is a least-recently-used cache from
|
|
// lruKey to *externalapi.BlockGHOSTDAGDataHashPair
|
|
type LRUCache struct {
|
|
cache map[lruKey][]*externalapi.BlockGHOSTDAGDataHashPair
|
|
capacity int
|
|
}
|
|
|
|
// New creates a new LRUCache
|
|
func New(capacity int, preallocate bool) *LRUCache {
|
|
var cache map[lruKey][]*externalapi.BlockGHOSTDAGDataHashPair
|
|
if preallocate {
|
|
cache = make(map[lruKey][]*externalapi.BlockGHOSTDAGDataHashPair, capacity+1)
|
|
} else {
|
|
cache = make(map[lruKey][]*externalapi.BlockGHOSTDAGDataHashPair)
|
|
}
|
|
return &LRUCache{
|
|
cache: cache,
|
|
capacity: capacity,
|
|
}
|
|
}
|
|
|
|
// Add adds an entry to the LRUCache
|
|
func (c *LRUCache) Add(blockHash *externalapi.DomainHash, windowSize int, value []*externalapi.BlockGHOSTDAGDataHashPair) {
|
|
key := newKey(blockHash, windowSize)
|
|
c.cache[key] = value
|
|
|
|
if len(c.cache) > c.capacity {
|
|
c.evictRandom()
|
|
}
|
|
}
|
|
|
|
// Get returns the entry for the given key, or (nil, false) otherwise
|
|
func (c *LRUCache) Get(blockHash *externalapi.DomainHash, windowSize int) ([]*externalapi.BlockGHOSTDAGDataHashPair, bool) {
|
|
key := newKey(blockHash, windowSize)
|
|
value, ok := c.cache[key]
|
|
if !ok {
|
|
return nil, false
|
|
}
|
|
return value, true
|
|
}
|
|
|
|
// Has returns whether the LRUCache contains the given key
|
|
func (c *LRUCache) Has(blockHash *externalapi.DomainHash, windowSize int) bool {
|
|
key := newKey(blockHash, windowSize)
|
|
_, ok := c.cache[key]
|
|
return ok
|
|
}
|
|
|
|
// Remove removes the entry for the the given key. Does nothing if
|
|
// the entry does not exist
|
|
func (c *LRUCache) Remove(blockHash *externalapi.DomainHash, windowSize int) {
|
|
key := newKey(blockHash, windowSize)
|
|
delete(c.cache, key)
|
|
}
|
|
|
|
func (c *LRUCache) evictRandom() {
|
|
var keyToEvict lruKey
|
|
for key := range c.cache {
|
|
keyToEvict = key
|
|
break
|
|
}
|
|
c.Remove(&keyToEvict.blockHash, keyToEvict.windowSize)
|
|
}
|