Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/develop'
Browse files Browse the repository at this point in the history
  • Loading branch information
shinji62 committed Dec 27, 2017
2 parents 63dd90c + 970b590 commit 65e2782
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions firehoseclient/firehoseclient.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,8 @@ func (f *FirehoseNozzle) ReadLogsBuffer(ctx context.Context) {
default:
envelope, empty := f.envelopeBuffer.TryNext()
if envelope == nil && !empty {
// Brief sleep to Avoid hammering on CPU
time.Sleep(1 * time.Millisecond)
continue
}
f.handleMessage(envelope)
Expand Down

0 comments on commit 65e2782

Please sign in to comment.