From 4fd6955c5a63f5819560ccd737db68c79e892801 Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Fri, 25 Oct 2024 05:40:28 -0500 Subject: [PATCH] resolve separate frames --- node/consensus/time/data_time_reel.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/node/consensus/time/data_time_reel.go b/node/consensus/time/data_time_reel.go index 4280f03..04dfa45 100644 --- a/node/consensus/time/data_time_reel.go +++ b/node/consensus/time/data_time_reel.go @@ -512,6 +512,12 @@ func (d *DataTimeReel) processPending( for { next := d.head.FrameNumber + 1 + sel, err := d.head.GetSelector() + if err != nil { + panic(err) + } + + selector := sel.FillBytes(make([]byte, 32)) // d.logger.Debug( // "checking frame set", // zap.Uint64("pending_frame_number", f), @@ -530,6 +536,10 @@ func (d *DataTimeReel) processPending( } for _, rawFrame := range rawFrames { + if !bytes.Equal(rawFrame.ParentSelector, selector) { + continue + } + d.logger.Debug( "processing frame", zap.Uint64("frame_number", rawFrame.FrameNumber),