mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-07 10:12:19 +00:00
cc741ed8af
* begin state service * begin on the state trie idea * created beacon state structure * add in the full clone getter * return by value instead * add all setters * new state setters are being completed * arrays roots exposed * close to finishing all these headerssss * functionality complete * added in proto benchmark test * test for compatibility * add test for compat * comments fixed * add clone * add clone * remove underlying copies * make it immutable * integrate it into chainservice * revert * wrap up comments for package * address all comments and godocs * address all comments * clone the pending attestation properly * properly clone remaining items * tests pass fixed bug * begin using it instead of head state * prevent nil pointer exceptions * begin using new struct in db * integrated new type into db package * add proper nil checks * using new state in archiver * refactored much of core * editing all the precompute functions * done with most core refactor * fixed up some bugs in the clone comparisons * append current epoch atts * add missing setters * add new setters * fix other core methods * fix up transition * main service and forkchoice * fix rpc * integrated to powchain * some more changes * fix build * improve processing of deposits * fix error * prevent panic * comment * fix process att * gaz * fix up att process * resolve existing review comments * resolve another batch of gh comments * resolve broken cpt state * revise testutil to use the new state * begin updating the state transition func to pass in more compartmentalized args * finish editing transition function to return errors * block operations pretty much done with refactor * state transition fully refactored * got epoch processing completed * fix build in fork choice * fixing more of the build * fix up broken sync package * it builds nowww it buildssss * revert registry changes * Recompute on Read (#4627) * compute on read * fix up eth1 data votes * looking into slashings bug introduced in core/ * able to advance more slots * add logging * can now sync with testnet yay * remove the leaves algorithm and other merkle imports * expose initialize unsafe funcs * Update beacon-chain/db/kv/state.go * lint Co-authored-by: Raul Jordan <raul@prysmaticlabs.com> * More Optimizations for New State (#4641) * map optimization * more optimizations * use a custom hasher * comment * block operations optimizations * Update beacon-chain/state/types.go Co-Authored-By: Raul Jordan <raul@prysmaticlabs.com> * fixed up various operations to use the validator index map access Co-authored-by: Raul Jordan <raul@prysmaticlabs.com> * archiver tests pass * fixing cache tests * cache tests passing * edited validator tests * powchain tests passing * halfway thru sync tests * more sync test fixes * add in tests for state/ * working through rpc tests * assignments tests passed * almost done with rpc/beacon tests * resolved painful validator test * fixed up even more tests * resolve tests * fix build * reduce a randao mixes copy * fixes under //beacon-chain/blockchain/... * build //beacon-chain/core/... * fixes * Runtime Optimizations (#4648) * parallelize shuffling * clean up * lint * fix build * use callback to read from registry * fix array roots and size map * new improvements * reduce hash allocs * improved shuffling * terence's review * use different method * raul's comment * new array roots * remove clone in pre-compute * Update beacon-chain/state/types.go Co-Authored-By: Raul Jordan <raul@prysmaticlabs.com> * raul's review * lint * fix build issues * fix visibility Co-authored-by: Raul Jordan <raul@prysmaticlabs.com> * fix visibility * build works for all * fix blockchain test * fix a few tests * fix more tests * update validator in slashing * archiver passing * fixed rpc/validator * progress on core tests * resolve broken rpc tests * blockchain tests passed * fix up some tests in core * fix message diff * remove unnecessary save * Save validator after slashing * Update validators one by one * another update * fix everything * fix more precompute tests * fix blocks tests * more elegant fix * more helper fixes * change back ? * fix test * fix skip slot * fix test * reset caches * fix testutil * raceoff fixed * passing * Retrieve cached state in the beginning * lint * Fixed tests part 1 * Fixed rest of the tests * Minor changes to avoid copying, small refactor to reduce deplicated code * Handle att req for slot 0 * New beacon state: Only populate merkle layers as needed, copy merkle layers on copy/clone. (#4689) * Only populate merkle layers as needed, copy merkle layers on copy/clone. * use custom copy * Make maps of correct size * slightly fast, doesn't wait for lock Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com> * Target root can't be 0x00 * Don't use cache for current slot (may not be the right fix) * fixed up tests * Remove some copy for init sync. Not sure if it is safe enough for runtime though... testing... * Align with prev logic for process slots cachedState.Slot() < slot * Fix Initial Sync Flag (#4692) * fixes * fix up some test failures due to lack of nil checks * fix up some test failures due to lack of nil checks * fix up imports * revert some changes * imports Co-authored-by: Raul Jordan <raul@prysmaticlabs.com> * resolving further conflicts * Better skip slot cache (#4694) * Return copy of skip slot cache state, disable skip slot cache on sync * fix * Fix pruning * fix up issues with broken tests Co-authored-by: Nishant Das <nish1993@hotmail.com> Co-authored-by: Preston Van Loon <preston@prysmaticlabs.com> Co-authored-by: shayzluf <thezluf@gmail.com> Co-authored-by: terence tsao <terence@prysmaticlabs.com> Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com>
126 lines
6.4 KiB
Go
126 lines
6.4 KiB
Go
// Package iface exists to prevent circular dependencies when implementing the database interface.
|
|
package iface
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
|
|
"github.com/ethereum/go-ethereum/common"
|
|
eth "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
ethpb "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/db/filters"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/state"
|
|
"github.com/prysmaticlabs/prysm/proto/beacon/db"
|
|
ethereum_beacon_p2p_v1 "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1"
|
|
)
|
|
|
|
// ReadOnlyDatabase -- See github.com/prysmaticlabs/prysm/beacon-chain/db.ReadOnlyDatabase
|
|
type ReadOnlyDatabase interface {
|
|
// Attestation related methods.
|
|
AttestationsByDataRoot(ctx context.Context, attDataRoot [32]byte) ([]*eth.Attestation, error)
|
|
Attestations(ctx context.Context, f *filters.QueryFilter) ([]*eth.Attestation, error)
|
|
HasAttestation(ctx context.Context, attDataRoot [32]byte) bool
|
|
// Block related methods.
|
|
Block(ctx context.Context, blockRoot [32]byte) (*eth.SignedBeaconBlock, error)
|
|
Blocks(ctx context.Context, f *filters.QueryFilter) ([]*eth.SignedBeaconBlock, error)
|
|
BlockRoots(ctx context.Context, f *filters.QueryFilter) ([][32]byte, error)
|
|
HasBlock(ctx context.Context, blockRoot [32]byte) bool
|
|
GenesisBlock(ctx context.Context) (*ethpb.SignedBeaconBlock, error)
|
|
IsFinalizedBlock(ctx context.Context, blockRoot [32]byte) bool
|
|
// Validator related methods.
|
|
ValidatorIndex(ctx context.Context, publicKey []byte) (uint64, bool, error)
|
|
HasValidatorIndex(ctx context.Context, publicKey []byte) bool
|
|
// State related methods.
|
|
State(ctx context.Context, blockRoot [32]byte) (*state.BeaconState, error)
|
|
GenesisState(ctx context.Context) (*state.BeaconState, error)
|
|
HasState(ctx context.Context, blockRoot [32]byte) bool
|
|
// Slashing operations.
|
|
ProposerSlashing(ctx context.Context, slashingRoot [32]byte) (*eth.ProposerSlashing, error)
|
|
AttesterSlashing(ctx context.Context, slashingRoot [32]byte) (*eth.AttesterSlashing, error)
|
|
HasProposerSlashing(ctx context.Context, slashingRoot [32]byte) bool
|
|
HasAttesterSlashing(ctx context.Context, slashingRoot [32]byte) bool
|
|
// Block operations.
|
|
VoluntaryExit(ctx context.Context, exitRoot [32]byte) (*eth.VoluntaryExit, error)
|
|
HasVoluntaryExit(ctx context.Context, exitRoot [32]byte) bool
|
|
// Checkpoint operations.
|
|
JustifiedCheckpoint(ctx context.Context) (*eth.Checkpoint, error)
|
|
FinalizedCheckpoint(ctx context.Context) (*eth.Checkpoint, error)
|
|
// Archival data handlers for storing/retrieving historical beacon node information.
|
|
ArchivedActiveValidatorChanges(ctx context.Context, epoch uint64) (*ethereum_beacon_p2p_v1.ArchivedActiveSetChanges, error)
|
|
ArchivedCommitteeInfo(ctx context.Context, epoch uint64) (*ethereum_beacon_p2p_v1.ArchivedCommitteeInfo, error)
|
|
ArchivedBalances(ctx context.Context, epoch uint64) ([]uint64, error)
|
|
ArchivedValidatorParticipation(ctx context.Context, epoch uint64) (*eth.ValidatorParticipation, error)
|
|
// Deposit contract related handlers.
|
|
DepositContractAddress(ctx context.Context) ([]byte, error)
|
|
// Powchain operations.
|
|
PowchainData(ctx context.Context) (*db.ETH1ChainData, error)
|
|
}
|
|
|
|
// NoHeadAccessDatabase -- See github.com/prysmaticlabs/prysm/beacon-chain/db.NoHeadAccessDatabase
|
|
type NoHeadAccessDatabase interface {
|
|
ReadOnlyDatabase
|
|
|
|
// Attestation related methods.
|
|
DeleteAttestation(ctx context.Context, attDataRoot [32]byte) error
|
|
DeleteAttestations(ctx context.Context, attDataRoots [][32]byte) error
|
|
SaveAttestation(ctx context.Context, att *eth.Attestation) error
|
|
SaveAttestations(ctx context.Context, atts []*eth.Attestation) error
|
|
// Block related methods.
|
|
DeleteBlock(ctx context.Context, blockRoot [32]byte) error
|
|
DeleteBlocks(ctx context.Context, blockRoots [][32]byte) error
|
|
SaveBlock(ctx context.Context, block *eth.SignedBeaconBlock) error
|
|
SaveBlocks(ctx context.Context, blocks []*eth.SignedBeaconBlock) error
|
|
SaveGenesisBlockRoot(ctx context.Context, blockRoot [32]byte) error
|
|
// Validator related methods.
|
|
DeleteValidatorIndex(ctx context.Context, publicKey []byte) error
|
|
SaveValidatorIndex(ctx context.Context, publicKey []byte, validatorIdx uint64) error
|
|
SaveValidatorIndices(ctx context.Context, publicKeys [][48]byte, validatorIndices []uint64) error
|
|
// State related methods.
|
|
SaveState(ctx context.Context, state *state.BeaconState, blockRoot [32]byte) error
|
|
DeleteState(ctx context.Context, blockRoot [32]byte) error
|
|
DeleteStates(ctx context.Context, blockRoots [][32]byte) error
|
|
// Slashing operations.
|
|
SaveProposerSlashing(ctx context.Context, slashing *eth.ProposerSlashing) error
|
|
SaveAttesterSlashing(ctx context.Context, slashing *eth.AttesterSlashing) error
|
|
DeleteProposerSlashing(ctx context.Context, slashingRoot [32]byte) error
|
|
DeleteAttesterSlashing(ctx context.Context, slashingRoot [32]byte) error
|
|
// Block operations.
|
|
SaveVoluntaryExit(ctx context.Context, exit *eth.VoluntaryExit) error
|
|
DeleteVoluntaryExit(ctx context.Context, exitRoot [32]byte) error
|
|
// Checkpoint operations.
|
|
SaveJustifiedCheckpoint(ctx context.Context, checkpoint *eth.Checkpoint) error
|
|
SaveFinalizedCheckpoint(ctx context.Context, checkpoint *eth.Checkpoint) error
|
|
// Archival data handlers for storing/retrieving historical beacon node information.
|
|
SaveArchivedActiveValidatorChanges(ctx context.Context, epoch uint64, changes *ethereum_beacon_p2p_v1.ArchivedActiveSetChanges) error
|
|
SaveArchivedCommitteeInfo(ctx context.Context, epoch uint64, info *ethereum_beacon_p2p_v1.ArchivedCommitteeInfo) error
|
|
SaveArchivedBalances(ctx context.Context, epoch uint64, balances []uint64) error
|
|
SaveArchivedValidatorParticipation(ctx context.Context, epoch uint64, part *eth.ValidatorParticipation) error
|
|
// Deposit contract related handlers.
|
|
SaveDepositContractAddress(ctx context.Context, addr common.Address) error
|
|
// Powchain operations.
|
|
SavePowchainData(ctx context.Context, data *db.ETH1ChainData) error
|
|
}
|
|
|
|
// HeadAccessDatabase -- See github.com/prysmaticlabs/prysm/beacon-chain/db.HeadAccessDatabase
|
|
type HeadAccessDatabase interface {
|
|
NoHeadAccessDatabase
|
|
|
|
// Block related methods.
|
|
HeadBlock(ctx context.Context) (*eth.SignedBeaconBlock, error)
|
|
SaveHeadBlockRoot(ctx context.Context, blockRoot [32]byte) error
|
|
// State related methods.
|
|
HeadState(ctx context.Context) (*state.BeaconState, error)
|
|
}
|
|
|
|
// Database -- See github.com/prysmaticlabs/prysm/beacon-chain/db.Database
|
|
type Database interface {
|
|
io.Closer
|
|
HeadAccessDatabase
|
|
|
|
DatabasePath() string
|
|
ClearDB() error
|
|
|
|
// Backup and restore methods
|
|
Backup(ctx context.Context) error
|
|
}
|