Skip to content

Commit 778e487

Browse files
committed
refactor: address double-sign review feedback
1 parent da54c68 commit 778e487

2 files changed

Lines changed: 4 additions & 7 deletions

File tree

block/internal/syncing/doublesign.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -105,16 +105,12 @@ func reportDoubleSign(
105105
firstHashStr := ev.FirstHeader.Hash().String()
106106
key := store.GetDoubleSignEvidenceKey(ev.Height, ev.AlternateHeader.Hash())
107107

108-
// Persist on every call: idempotent, and a retry covers a transient
109-
// failure on the first attempt.
110-
persistErr := persistEvidence(ctx, st, ev)
111-
112108
if seen != nil && !seen.markSeen(ev.Height, altHashStr) {
113109
return nil
114110
}
115111

116-
if persistErr != nil {
117-
logger.Error().Err(persistErr).
112+
if err := persistEvidence(ctx, st, ev); err != nil {
113+
logger.Error().Err(err).
118114
Uint64("height", ev.Height).
119115
Str("first_hash", firstHashStr).
120116
Str("alternate_hash", altHashStr).

block/internal/syncing/syncer.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1088,7 +1088,8 @@ func (s *Syncer) detectDoubleSign(ctx context.Context, header *types.SignedHeade
10881088
}
10891089
prior, priorSource, err := firstObservation(ctx, s.store, s.cache, header.Height())
10901090
if err != nil {
1091-
s.logger.Warn().Err(err).Uint64("height", header.Height()).Msg("double-sign detection error")
1091+
// Detection bypassed for this observation, still cached below so a later arrival can match against this header
1092+
s.logger.Error().Err(err).Uint64("height", header.Height()).Msg("double-sign detection bypassed")
10921093
} else if ev := buildEvidenceFromPair(prior, header, priorSource, source); ev != nil {
10931094
s.handleDoubleSign(ctx, ev)
10941095
return true

0 commit comments

Comments
 (0)