From 873f4adc7ec02e20d3e7a9ae2d09b63eea09fa2f Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Mon, 18 Nov 2024 00:32:17 -0600 Subject: [PATCH] faster sync proposal --- node/consensus/data/main_data_loop.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/node/consensus/data/main_data_loop.go b/node/consensus/data/main_data_loop.go index 4da1fcc..3838851 100644 --- a/node/consensus/data/main_data_loop.go +++ b/node/consensus/data/main_data_loop.go @@ -94,14 +94,20 @@ func (e *DataClockConsensusEngine) runSync() { if _, err := e.collect(enqueuedFrame); err != nil { e.logger.Error("could not collect", zap.Error(err)) } - case <-time.After(20 * time.Second): + case <-time.After(300 * time.Millisecond): if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) { continue } + head, err := e.dataTimeReel.Head() if err != nil { panic(err) } + + if head.Timestamp > time.Now().UnixMilli()-15000 { + continue + } + if _, err := e.collect(head); err != nil { e.logger.Error("could not collect", zap.Error(err)) }