Skip to content

Commit

Permalink
Add log when switchover is complete
Browse files Browse the repository at this point in the history
  • Loading branch information
amsanghi committed Oct 16, 2024
1 parent 96b40eb commit 247fb1f
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions arbnode/seq_coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -653,6 +653,9 @@ func (c *SeqCoordinator) update(ctx context.Context) time.Duration {
readUntil = min(readUntil, c.prevRedisMessageCount)
client = c.prevRedisCoordinator.Client
}
if c.prevRedisMessageCount != 0 && localMsgCount >= c.prevRedisMessageCount {
log.Info("coordinator caught up to prev redis coordinator", "msgcount", localMsgCount, "prevMsgCount", c.prevRedisMessageCount)
}
var messages []arbostypes.MessageWithMetadata
msgToRead := localMsgCount
var msgReadErr error
Expand Down

0 comments on commit 247fb1f

Please sign in to comment.