From 61e8de9c3f0ed98fe12d3e73ae948f3839e79d48 Mon Sep 17 00:00:00 2001 From: colin <102356659+colinlyguo@users.noreply.github.com> Date: Wed, 27 Mar 2024 16:53:02 +0800 Subject: [PATCH] fix(sync-service): only add queue index when message index is not zero (#682) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix(sync-service): increase queue index only when L1 message index is not zero * bump version --------- Co-authored-by: Péter Garamvölgyi --- params/version.go | 2 +- rollup/sync_service/sync_service.go | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/params/version.go b/params/version.go index 217aaa3943..bedb0d47e4 100644 --- a/params/version.go +++ b/params/version.go @@ -24,7 +24,7 @@ import ( const ( VersionMajor = 5 // Major version component of the current release VersionMinor = 1 // Minor version component of the current release - VersionPatch = 26 // Patch version component of the current release + VersionPatch = 27 // Patch version component of the current release VersionMeta = "mainnet" // Version metadata to append to the version string ) diff --git a/rollup/sync_service/sync_service.go b/rollup/sync_service/sync_service.go index e8efd9a54e..05f95c47ab 100644 --- a/rollup/sync_service/sync_service.go +++ b/rollup/sync_service/sync_service.go @@ -220,7 +220,9 @@ func (s *SyncService) fetchMessages() { } for _, msg := range msgs { - queueIndex++ + if msg.QueueIndex > 0 { + queueIndex++ + } // check if received queue index matches expected queue index if msg.QueueIndex != queueIndex { log.Error("Unexpected queue index in SyncService", "expected", queueIndex, "got", msg.QueueIndex, "msg", msg)