mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-08 10:41:19 +00:00
c4c9a8465a
* use faster hash proto * Merge branch 'master' into faster-att-pool * gaz * Merge branch 'faster-att-pool' of github.com:prysmaticlabs/prysm into faster-att-pool * nil checks and failing tests * Merge refs/heads/master into faster-att-pool * Merge refs/heads/master into faster-att-pool * Merge refs/heads/master into faster-att-pool * Merge refs/heads/master into faster-att-pool * Merge refs/heads/master into faster-att-pool * Fix * Merge branch 'faster-att-pool' of github.com:prysmaticlabs/prysm into faster-att-pool * Fix tests
38 lines
1.2 KiB
Go
38 lines
1.2 KiB
Go
package kv
|
|
|
|
import (
|
|
"sync"
|
|
|
|
ethpb "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
"github.com/prysmaticlabs/prysm/shared/hashutil"
|
|
)
|
|
|
|
var hashFn = hashutil.HashProto
|
|
|
|
// AttCaches defines the caches used to satisfy attestation pool interface.
|
|
// These caches are KV store for various attestations
|
|
// such are unaggregated, aggregated or attestations within a block.
|
|
type AttCaches struct {
|
|
aggregatedAttLock sync.RWMutex
|
|
aggregatedAtt map[[32]byte][]*ethpb.Attestation
|
|
unAggregateAttLock sync.RWMutex
|
|
unAggregatedAtt map[[32]byte]*ethpb.Attestation
|
|
forkchoiceAttLock sync.RWMutex
|
|
forkchoiceAtt map[[32]byte]*ethpb.Attestation
|
|
blockAttLock sync.RWMutex
|
|
blockAtt map[[32]byte][]*ethpb.Attestation
|
|
}
|
|
|
|
// NewAttCaches initializes a new attestation pool consists of multiple KV store in cache for
|
|
// various kind of attestations.
|
|
func NewAttCaches() *AttCaches {
|
|
pool := &AttCaches{
|
|
unAggregatedAtt: make(map[[32]byte]*ethpb.Attestation),
|
|
aggregatedAtt: make(map[[32]byte][]*ethpb.Attestation),
|
|
forkchoiceAtt: make(map[[32]byte]*ethpb.Attestation),
|
|
blockAtt: make(map[[32]byte][]*ethpb.Attestation),
|
|
}
|
|
|
|
return pool
|
|
}
|