neoneo-go/pkg/consensus/cache.go

74 lines
1.3 KiB
Go
Raw Normal View History

2019-11-08 15:40:21 +00:00
package consensus
import (
"container/list"
"sync"
"github.com/nspcc-dev/neo-go/pkg/util"
2019-11-08 15:40:21 +00:00
)
// relayCache is a payload cache which is used to store
// last consensus payloads.
type relayCache struct {
*sync.RWMutex
maxCap int
elems map[util.Uint256]*list.Element
queue *list.List
}
2019-11-15 10:32:40 +00:00
// hashable is a type of items which can be stored in the relayCache.
type hashable interface {
Hash() util.Uint256
}
2019-11-08 15:40:21 +00:00
func newFIFOCache(capacity int) *relayCache {
return &relayCache{
RWMutex: new(sync.RWMutex),
maxCap: capacity,
elems: make(map[util.Uint256]*list.Element),
queue: list.New(),
}
}
// Add adds payload into a cache if it doesn't already exist.
2019-11-15 10:32:40 +00:00
func (c *relayCache) Add(p hashable) {
2019-11-08 15:40:21 +00:00
c.Lock()
defer c.Unlock()
h := p.Hash()
if c.elems[h] != nil {
return
}
if c.queue.Len() >= c.maxCap {
first := c.queue.Front()
c.queue.Remove(first)
2019-11-15 10:32:40 +00:00
delete(c.elems, first.Value.(hashable).Hash())
2019-11-08 15:40:21 +00:00
}
e := c.queue.PushBack(p)
c.elems[h] = e
}
2019-11-15 10:32:40 +00:00
// Has checks if an item is already in cache.
func (c *relayCache) Has(h util.Uint256) bool {
c.RLock()
defer c.RUnlock()
return c.elems[h] != nil
}
2019-11-08 15:40:21 +00:00
// Get returns payload with the specified hash from cache.
2019-11-15 10:32:40 +00:00
func (c *relayCache) Get(h util.Uint256) hashable {
2019-11-08 15:40:21 +00:00
c.RLock()
defer c.RUnlock()
e, ok := c.elems[h]
if !ok {
2019-11-15 10:32:40 +00:00
return hashable(nil)
2019-11-08 15:40:21 +00:00
}
2019-11-15 10:32:40 +00:00
return e.Value.(hashable)
2019-11-08 15:40:21 +00:00
}