mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-12 20:50:05 +00:00
parent
4c9ff7012c
commit
b5e7f9dd6d
@ -310,7 +310,7 @@ func (vs *Server) deposits(ctx context.Context, currentVote *ethpb.Eth1Data) ([]
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, "could not generate historical deposit trie from deposits")
|
return nil, errors.Wrap(err, "could not generate historical deposit trie from deposits")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Deposits need to be received in order of merkle index root, so this has to make sure
|
// Deposits need to be received in order of merkle index root, so this has to make sure
|
||||||
// deposits are sorted from lowest to highest.
|
// deposits are sorted from lowest to highest.
|
||||||
var pendingDeps []*dbpb.DepositContainer
|
var pendingDeps []*dbpb.DepositContainer
|
||||||
|
@ -89,7 +89,7 @@ func newBlocksFetcher(ctx context.Context, cfg *blocksFetcherConfig) *blocksFetc
|
|||||||
rateLimiter := leakybucket.NewCollector(
|
rateLimiter := leakybucket.NewCollector(
|
||||||
allowedBlocksPerSecond, /* rate */
|
allowedBlocksPerSecond, /* rate */
|
||||||
allowedBlocksPerSecond, /* capacity */
|
allowedBlocksPerSecond, /* capacity */
|
||||||
false /* deleteEmptyBuckets */)
|
false /* deleteEmptyBuckets */)
|
||||||
|
|
||||||
return &blocksFetcher{
|
return &blocksFetcher{
|
||||||
ctx: ctx,
|
ctx: ctx,
|
||||||
|
@ -15,10 +15,10 @@ import (
|
|||||||
dbtest "github.com/prysmaticlabs/prysm/beacon-chain/db/testing"
|
dbtest "github.com/prysmaticlabs/prysm/beacon-chain/db/testing"
|
||||||
"github.com/prysmaticlabs/prysm/beacon-chain/operations/attestations"
|
"github.com/prysmaticlabs/prysm/beacon-chain/operations/attestations"
|
||||||
p2ptest "github.com/prysmaticlabs/prysm/beacon-chain/p2p/testing"
|
p2ptest "github.com/prysmaticlabs/prysm/beacon-chain/p2p/testing"
|
||||||
|
"github.com/prysmaticlabs/prysm/beacon-chain/state/stateutil"
|
||||||
mockSync "github.com/prysmaticlabs/prysm/beacon-chain/sync/initial-sync/testing"
|
mockSync "github.com/prysmaticlabs/prysm/beacon-chain/sync/initial-sync/testing"
|
||||||
"github.com/prysmaticlabs/prysm/shared/featureconfig"
|
"github.com/prysmaticlabs/prysm/shared/featureconfig"
|
||||||
"github.com/prysmaticlabs/prysm/shared/testutil"
|
"github.com/prysmaticlabs/prysm/shared/testutil"
|
||||||
"github.com/prysmaticlabs/prysm/beacon-chain/state/stateutil"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestService_committeeIndexBeaconAttestationSubscriber_ValidMessage(t *testing.T) {
|
func TestService_committeeIndexBeaconAttestationSubscriber_ValidMessage(t *testing.T) {
|
||||||
|
@ -16,11 +16,11 @@ import (
|
|||||||
"github.com/prysmaticlabs/prysm/beacon-chain/cache"
|
"github.com/prysmaticlabs/prysm/beacon-chain/cache"
|
||||||
dbtest "github.com/prysmaticlabs/prysm/beacon-chain/db/testing"
|
dbtest "github.com/prysmaticlabs/prysm/beacon-chain/db/testing"
|
||||||
p2ptest "github.com/prysmaticlabs/prysm/beacon-chain/p2p/testing"
|
p2ptest "github.com/prysmaticlabs/prysm/beacon-chain/p2p/testing"
|
||||||
|
"github.com/prysmaticlabs/prysm/beacon-chain/state/stateutil"
|
||||||
mockSync "github.com/prysmaticlabs/prysm/beacon-chain/sync/initial-sync/testing"
|
mockSync "github.com/prysmaticlabs/prysm/beacon-chain/sync/initial-sync/testing"
|
||||||
"github.com/prysmaticlabs/prysm/shared/bytesutil"
|
"github.com/prysmaticlabs/prysm/shared/bytesutil"
|
||||||
"github.com/prysmaticlabs/prysm/shared/params"
|
"github.com/prysmaticlabs/prysm/shared/params"
|
||||||
"github.com/prysmaticlabs/prysm/shared/testutil"
|
"github.com/prysmaticlabs/prysm/shared/testutil"
|
||||||
"github.com/prysmaticlabs/prysm/beacon-chain/state/stateutil"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestService_validateCommitteeIndexBeaconAttestation(t *testing.T) {
|
func TestService_validateCommitteeIndexBeaconAttestation(t *testing.T) {
|
||||||
|
Loading…
Reference in New Issue
Block a user