Skip to content

Commit

Permalink
fix backlog lint error
Browse files Browse the repository at this point in the history
  • Loading branch information
lambchr committed Nov 15, 2023
1 parent ea46fd9 commit 60ce382
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions broadcaster/backlog/backlog.go
Original file line number Diff line number Diff line change
Expand Up @@ -339,10 +339,7 @@ func (s *backlogSegment) Contains(i uint64) bool {
s.messagesLock.RLock()
msg := s.messages[msgIndex]
s.messagesLock.RUnlock()
if uint64(msg.SequenceNumber) != i {
return false
}
return true
return uint64(msg.SequenceNumber) == i
}

func (s *backlogSegment) delete(confirmed uint64) error {
Expand Down

0 comments on commit 60ce382

Please sign in to comment.