Skip to content

Commit

Permalink
Merge pull request #42 from m-lab/sandbox-queue-check
Browse files Browse the repository at this point in the history
fix bug
  • Loading branch information
gfr10598 committed Apr 16, 2018
2 parents a38f665 + 3e50d05 commit f3e2e92
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cloud/tq/queuehandler.go
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ func (qh *ChannelQueueHandler) waitForEmptyQueue() {
}
log.Printf("Suspicious (%s): %+v\n", qh.Queue, stats)
}
if time.Since(inactiveStartTime) > 180*time.Second {
if inactiveStartTime != nullTime && time.Since(inactiveStartTime) > 180*time.Second {
// It's been long enough to assume the queue is really empty.
// Or possibly we've just been getting errors all this time.
log.Printf("Timeout. (%s) Last trusted was: %+v", qh.Queue, lastTrusted)
Expand Down

0 comments on commit f3e2e92

Please sign in to comment.