mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-10 11:41:21 +00:00
fcbb168c76
* remove unused cache states map * correct typo * Remove unused array * Add lock around deposits cache chainstart pubkeys * Copy attestation before grabbing lock. This may reduce lock contention time as other callers wanting the lock do not need to wait as long for the lock to become available. * Copy attestation before grabbing lock. This may reduce lock contention time as other callers wanting the lock do not need to wait as long for the lock to become available. * Set capacity to 1 since it is known that the slice will be 1 after insertion * require validatorSlashingPreconditionCheck caller to hold lock * Add lock for voluntary exits pool HasBeenIncluded * Require rate limiter retrieveCollector to hold lock * Add lock requirement assertions in sync * Remove unused struct * remove ClearCachedStates API * field initSyncState is unused Co-authored-by: Raul Jordan <raul@prysmaticlabs.com>
67 lines
1.6 KiB
Go
67 lines
1.6 KiB
Go
package kv
|
|
|
|
import (
|
|
"github.com/pkg/errors"
|
|
ethpb "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
stateTrie "github.com/prysmaticlabs/prysm/beacon-chain/state"
|
|
)
|
|
|
|
// SaveForkchoiceAttestation saves an forkchoice attestation in cache.
|
|
func (p *AttCaches) SaveForkchoiceAttestation(att *ethpb.Attestation) error {
|
|
if att == nil {
|
|
return nil
|
|
}
|
|
r, err := hashFn(att)
|
|
if err != nil {
|
|
return errors.Wrap(err, "could not tree hash attestation")
|
|
}
|
|
|
|
att = stateTrie.CopyAttestation(att)
|
|
p.forkchoiceAttLock.Lock()
|
|
defer p.forkchoiceAttLock.Unlock()
|
|
p.forkchoiceAtt[r] = att
|
|
|
|
return nil
|
|
}
|
|
|
|
// SaveForkchoiceAttestations saves a list of forkchoice attestations in cache.
|
|
func (p *AttCaches) SaveForkchoiceAttestations(atts []*ethpb.Attestation) error {
|
|
for _, att := range atts {
|
|
if err := p.SaveForkchoiceAttestation(att); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// ForkchoiceAttestations returns the forkchoice attestations in cache.
|
|
func (p *AttCaches) ForkchoiceAttestations() []*ethpb.Attestation {
|
|
p.forkchoiceAttLock.RLock()
|
|
defer p.forkchoiceAttLock.RUnlock()
|
|
|
|
atts := make([]*ethpb.Attestation, 0, len(p.forkchoiceAtt))
|
|
for _, att := range p.forkchoiceAtt {
|
|
atts = append(atts, stateTrie.CopyAttestation(att) /* Copied */)
|
|
}
|
|
|
|
return atts
|
|
}
|
|
|
|
// DeleteForkchoiceAttestation deletes a forkchoice attestation in cache.
|
|
func (p *AttCaches) DeleteForkchoiceAttestation(att *ethpb.Attestation) error {
|
|
if att == nil {
|
|
return nil
|
|
}
|
|
r, err := hashFn(att)
|
|
if err != nil {
|
|
return errors.Wrap(err, "could not tree hash attestation")
|
|
}
|
|
|
|
p.forkchoiceAttLock.Lock()
|
|
defer p.forkchoiceAttLock.Unlock()
|
|
delete(p.forkchoiceAtt, r)
|
|
|
|
return nil
|
|
}
|