diff --git a/pkg/protocol/engine/syncmanager/trivialsyncmanager/syncmanager.go b/pkg/protocol/engine/syncmanager/trivialsyncmanager/syncmanager.go index 85c625f48..ca17d7ad0 100644 --- a/pkg/protocol/engine/syncmanager/trivialsyncmanager/syncmanager.go +++ b/pkg/protocol/engine/syncmanager/trivialsyncmanager/syncmanager.go @@ -272,7 +272,8 @@ func (s *SyncManager) updateSyncStatus() (changed bool) { s.isSyncedLock.Lock() defer s.isSyncedLock.Unlock() - isSynced := s.IsBootstrapped() && time.Since(s.engine.Clock.Accepted().RelativeTime()) < s.optsSyncThreshold + snapshot := s.engine.Clock.Snapshot() + isSynced := s.IsBootstrapped() && ((snapshot.RelativeAcceptedTime.Sub(snapshot.AcceptedTime)) < s.optsSyncThreshold) if s.isSynced != isSynced { s.isSynced = isSynced