coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 10:27:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

more adjustments

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-04 21:10:21 -06:00
parent 0106afa298
commit ee8b344dde
No known key found for this signature in database
GPG Key ID: 6352152859385958
5 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/execution/intrinsics/token/application/token_handle_prover_join.go
View File

@ -58,7 +58,7 @@ func (a *TokenApplication) handleDataAnnounceProverJoin(
t.PublicKeySignatureEd448.Signature == nil ||
t.PublicKeySignatureEd448.PublicKey.KeyValue == nil ||
t.Filter == nil || len(t.Filter) != 32 ||
t.FrameNumber < currentFrameNumber-1 || t.FrameNumber > currentFrameNumber {
t.FrameNumber > currentFrameNumber {
a.Logger.Debug(
"bad payload",
zap.Uint64("given_frame_number", t.FrameNumber),

2
node/execution/intrinsics/token/application/token_handle_prover_leave.go
View File

@ -25,7 +25,7 @@ func (a *TokenApplication) handleDataAnnounceProverLeave(
t.PublicKeySignatureEd448.Signature == nil ||
t.PublicKeySignatureEd448.PublicKey.KeyValue == nil ||
t.Filter == nil || len(t.Filter) != 32 ||
t.FrameNumber < currentFrameNumber-1 || t.FrameNumber > currentFrameNumber {
t.FrameNumber > currentFrameNumber {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle leave")
}

2
node/execution/intrinsics/token/application/token_handle_prover_pause.go
View File

@ -25,7 +25,7 @@ func (a *TokenApplication) handleDataAnnounceProverPause(
t.PublicKeySignatureEd448.Signature == nil ||
t.PublicKeySignatureEd448.PublicKey.KeyValue == nil ||
t.Filter == nil || len(t.Filter) != 32 ||
t.FrameNumber < currentFrameNumber-1 || t.FrameNumber > currentFrameNumber {
t.FrameNumber > currentFrameNumber {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle pause")
}
if _, touched := lockMap[string(

2
node/execution/intrinsics/token/application/token_handle_prover_resume.go
View File

@ -25,7 +25,7 @@ func (a *TokenApplication) handleDataAnnounceProverResume(
t.PublicKeySignatureEd448.Signature == nil ||
t.PublicKeySignatureEd448.PublicKey.KeyValue == nil ||
t.Filter == nil || len(t.Filter) != 32 ||
t.FrameNumber < currentFrameNumber-1 || t.FrameNumber > currentFrameNumber {
t.FrameNumber > currentFrameNumber {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle resume")
}

9
node/p2p/blossomsub.go
View File

@ -317,13 +317,16 @@ func NewBlossomSub(
util.Advertise(ctx, routingDiscovery, getNetworkNamespace(p2pConfig.Network))
verifyReachability(p2pConfig)
minBootstraps := minBootstrapPeers
if p2pConfig.Network != 0 {
minBootstraps = 1
}
bootstrap := internal.NewPeerConnector(
ctx,
logger.Named("bootstrap"),
h,
idService,
minBootstrapPeers,
minBootstraps,
bootstrapParallelism,
internal.NewStaticPeerSource(bootstrappers, true),
)
@ -334,7 +337,7 @@ func NewBlossomSub(
ctx,
internal.NewNotEnoughPeersCondition(
h,
minBootstrapPeers,
minBootstraps,
internal.PeerAddrInfosToPeerIDMap(bootstrappers),
),
bootstrap,