Skip to content
This repository has been archived by the owner on Feb 18, 2021. It is now read-only.

Commit

Permalink
fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
kiranrg committed Jun 20, 2017
1 parent c013923 commit 90c03c0
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion services/outputhost/replicaconnection.go
Expand Up @@ -262,7 +262,8 @@ loop:
enqueueTime := common.UnixNanoTime(msg.Message.GetEnqueueTimeUtc())
now := common.Now()

// check if the messages have already 'expired'; ie, if it falls outside the skip-older window
// check if the messages have already 'expired'; ie, if it falls outside the
// skip-older window. ignore (ie, don't skip any messages), if skip-older is '0'.
if skipOlderNanos > 0 && enqueueTime < (now-skipOlderNanos) {
continue loop
}
Expand Down

0 comments on commit 90c03c0

Please sign in to comment.