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

make idempotent

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

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

@ -89,14 +89,14 @@ func (a *TokenApplication) handleDataAnnounceProverJoin(
return nil, errors.Wrap(err, "handle join")
}
lockMap[string(t.PublicKeySignatureEd448.PublicKey.KeyValue)] = struct{}{}
for _, t := range a.Tries {
if t.Contains(address) {
a.Logger.Debug("prover already in trie", zap.Binary("address", address))
return nil, errors.Wrap(ErrInvalidStateTransition, "handle join")
// do nothing:
return []*protobufs.TokenOutput{}, nil
}
}
lockMap[string(t.PublicKeySignatureEd448.PublicKey.KeyValue)] = struct{}{}
return []*protobufs.TokenOutput{
&protobufs.TokenOutput{
Output: &protobufs.TokenOutput_Join{

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

@ -52,11 +52,11 @@ func (a *TokenApplication) handleDataAnnounceProverLeave(
inTries = inTries || t.Contains(address)
}
if !inTries {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle leave")
}
lockMap[string(t.PublicKeySignatureEd448.PublicKey.KeyValue)] = struct{}{}
if !inTries {
// do nothing:
return []*protobufs.TokenOutput{}, nil
}
return []*protobufs.TokenOutput{
&protobufs.TokenOutput{

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

@ -51,10 +51,11 @@ func (a *TokenApplication) handleDataAnnounceProverPause(
inTries = inTries || t.Contains(address)
}
if !inTries {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle pause")
}
lockMap[string(t.PublicKeySignatureEd448.PublicKey.KeyValue)] = struct{}{}
if !inTries {
// do nothing:
return []*protobufs.TokenOutput{}, nil
}
return []*protobufs.TokenOutput{
&protobufs.TokenOutput{
Output: &protobufs.TokenOutput_Pause{

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

@ -52,11 +52,11 @@ func (a *TokenApplication) handleDataAnnounceProverResume(
inTries = inTries || t.Contains(address)
}
if !inTries {
return nil, errors.Wrap(ErrInvalidStateTransition, "handle resume")
}
lockMap[string(t.PublicKeySignatureEd448.PublicKey.KeyValue)] = struct{}{}
if !inTries {
// do nothing:
return []*protobufs.TokenOutput{}, nil
}
return []*protobufs.TokenOutput{
&protobufs.TokenOutput{

4
node/execution/intrinsics/token/token_execution_engine.go
View File

@ -648,7 +648,9 @@ func (e *TokenExecutionEngine) ProcessFrame(
)
last = app.Tries[rings]
}
last.Add([]byte(addr.addr), frame.FrameNumber)
if !last.Contains([]byte(addr.addr)) {
last.Add([]byte(addr.addr), frame.FrameNumber)
}
}
for _, addr := range leaveReqs {
for _, t := range app.Tries {

2
node/tries/rolling_frecency_critbit_trie.go
View File

@ -134,7 +134,7 @@ func (t *RollingFrecencyCritbitTrie) FindNearestAndApproximateNeighbors(
var traverse func(p *Node, address []byte) bool
traverse = func(p *Node, address []byte) bool {
if len(ret) > 256 {
if len(ret) > 1024 {
return true
}