From 5bce33216fc09f83a6c6a40e0a09fdf32ecf657f Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Thu, 5 Oct 2023 17:01:16 -0500 Subject: [PATCH] fix: handle large consensus batches --- node/consensus/ceremony/consensus_frames.go | 24 ++++++++++----------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/node/consensus/ceremony/consensus_frames.go b/node/consensus/ceremony/consensus_frames.go index 9d30732..a02a53e 100644 --- a/node/consensus/ceremony/consensus_frames.go +++ b/node/consensus/ceremony/consensus_frames.go @@ -687,12 +687,12 @@ func (e *CeremonyDataClockConsensusEngine) commitLongestPath( zap.Int("commit_depth", len(runningFrames[0])), ) - txn, err := e.clockStore.NewTransaction() - if err != nil { - return nil, errors.Wrap(err, "commit longest path") - } - for _, s := range runningFrames[0][1:] { + txn, err := e.clockStore.NewTransaction() + if err != nil { + return nil, errors.Wrap(err, "commit longest path") + } + e.logger.Info( "committing candidate", zap.Uint64("frame_number", s.FrameNumber), @@ -796,14 +796,14 @@ func (e *CeremonyDataClockConsensusEngine) commitLongestPath( } } } - } - if err := txn.Commit(); err != nil { - e.logger.Error( - "could not commit candidates", - zap.Error(err), - ) - return nil, errors.Wrap(err, "commit longest path") + if err := txn.Commit(); err != nil { + e.logger.Error( + "could not commit candidates", + zap.Error(err), + ) + return nil, errors.Wrap(err, "commit longest path") + } } runningFrames = [][]*protobufs.ClockFrame{