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

rearrange prover sync

Browse Source
This commit is contained in:
Cassandra Heart 2025-12-27 20:14:50 -06:00
parent 655b4c11a8
commit 96066fee33
No known key found for this signature in database
GPG Key ID: 371083BFA6C240AA
1 changed files with 32 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
node/consensus/global/global_consensus_engine.go
View File

@ -1625,23 +1625,49 @@ func (e *GlobalConsensusEngine) materialize(
return errors.Wrap(err, "materialize")
}
var expectedRootHex string
localRootHex := ""
// Check prover root BEFORE processing transactions. If there's a mismatch,
// we need to sync first, otherwise we'll apply transactions on top of
// divergent state and then sync will delete the newly added records.
if len(expectedProverRoot) > 0 {
localRoot, localErr := e.computeLocalProverRoot(frameNumber)
if localErr == nil && len(localRoot) > 0 {
if !bytes.Equal(localRoot, expectedProverRoot) {
localProverRoot, localRootErr := e.computeLocalProverRoot(frameNumber)
if localRootErr != nil {
e.logger.Warn(
"failed to compute local prover root",
zap.Uint64("frame_number", frameNumber),
zap.Error(localRootErr),
)
}
if localRootErr == nil && len(localProverRoot) > 0 {
if !bytes.Equal(localProverRoot, expectedProverRoot) {
e.logger.Info(
"prover root mismatch detected before processing frame, syncing first",
zap.Uint64("frame_number", frameNumber),
zap.String("expected_root", hex.EncodeToString(expectedProverRoot)),
zap.String("local_root", hex.EncodeToString(localRoot)),
zap.String("local_root", hex.EncodeToString(localProverRoot)),
)
// Perform blocking hypersync before continuing
e.performBlockingProverHypersync(proposer, expectedProverRoot)
}
}
// Publish the snapshot generation with the new root so clients can sync
// against this specific state.
if len(localProverRoot) > 0 {
if hgCRDT, ok := e.hypergraph.(*hgcrdt.HypergraphCRDT); ok {
hgCRDT.PublishSnapshot(localProverRoot)
}
}
if len(expectedProverRoot) > 0 {
expectedRootHex = hex.EncodeToString(expectedProverRoot)
}
if len(localProverRoot) > 0 {
localRootHex = hex.EncodeToString(localProverRoot)
}
}
var state state.State
@ -1755,41 +1781,8 @@ func (e *GlobalConsensusEngine) materialize(
return errors.Wrap(err, "materialize")
}
localProverRoot, localRootErr := e.computeLocalProverRoot(frameNumber)
if localRootErr != nil {
e.logger.Warn(
"failed to compute local prover root",
zap.Uint64("frame_number", frameNumber),
zap.Error(localRootErr),
)
}
// Publish the snapshot generation with the new root so clients can sync
// against this specific state.
if len(localProverRoot) > 0 {
if hgCRDT, ok := e.hypergraph.(*hgcrdt.HypergraphCRDT); ok {
hgCRDT.PublishSnapshot(localProverRoot)
}
}
if len(localProverRoot) > 0 {
if e.verifyProverRoot(
frameNumber,
expectedProverRoot,
localProverRoot,
proposer,
) {
e.reconcileLocalWorkerAllocations()
}
}
var expectedRootHex string
if len(expectedProverRoot) > 0 {
expectedRootHex = hex.EncodeToString(expectedProverRoot)
}
localRootHex := ""
if len(localProverRoot) > 0 {
localRootHex = hex.EncodeToString(localProverRoot)
if len(localRootHex) > 0 {
e.reconcileLocalWorkerAllocations()
}
e.logger.Info(