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

handle forked genesis

Browse Source
This commit is contained in:
Cassandra Heart 2025-01-30 02:20:01 -06:00
parent b5fd0775bf
commit 772edd31be
No known key found for this signature in database
GPG Key ID: 6352152859385958
2 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
node/consensus/data/consensus_frames.go
View File

@ -411,22 +411,41 @@ func (e *DataClockConsensusEngine) syncWithPeer(
zap.Uint64("frame_number", response.ClockFrame.FrameNumber),
zap.Duration("frame_age", frametime.Since(response.ClockFrame)),
)
if !e.IsInProverTrie(
response.ClockFrame.GetPublicKeySignatureEd448().PublicKey.KeyValue,
) {
cooperative = false
}
if err := e.frameProver.VerifyDataClockFrame(
response.ClockFrame,
); err != nil {
return latest, doneChs, errors.Wrap(err, "sync")
}
// Useful for testnet, immediately handles equivocation from multiple
// genesis events:
if response.ClockFrame.FrameNumber == 1 {
genesis, _, _ := e.clockStore.GetDataClockFrame(e.filter, 0, true)
selector, _ := genesis.GetSelector()
if !bytes.Equal(
response.ClockFrame.ParentSelector,
selector.FillBytes(make([]byte, 32)),
) {
cooperative = false
return latest, doneChs, errors.Wrap(errors.New("invalid frame"), "sync")
}
}
doneCh, err := e.dataTimeReel.Insert(e.ctx, response.ClockFrame)
if err != nil {
return latest, doneChs, errors.Wrap(err, "sync")
}
doneChs = append(doneChs, doneCh)
latest = response.ClockFrame
if latest.FrameNumber >= maxFrame {
return latest, doneChs, nil
}

3
node/execution/intrinsics/token/application/token_application.go
View File

@ -414,6 +414,9 @@ func (a *TokenApplication) ApplyTransitions(
wg.Wait()
for i, transition := range set {
if transition == nil {
continue
}
if fails[i] != nil {
continue
}