Skip to content

Commit

Permalink
Merge pull request #463 from google/downgrade-log
Browse files Browse the repository at this point in the history
Downgrade the timed out message from pipestream as it's expected.
  • Loading branch information
jaqx0r authored Feb 4, 2021
2 parents 641107c + 499147e commit 341ac73
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions internal/tailer/logstream/pipestream.go
Original file line number Diff line number Diff line change
Expand Up @@ -92,11 +92,11 @@ func (ps *pipeStream) stream(ctx context.Context, wg *sync.WaitGroup, waker wake

var perr *os.PathError
if errors.As(err, &perr) && perr.Timeout() && n == 0 {
glog.Info("timed out")
glog.V(2).Info("timed out")
timedout = true
// Named Pipes EOF when the writer has closed, so we look for a
// timeout on read to detect a writer stall and thus let us check
// below for cancellation.
// Named Pipes EOF only when the writer has closed, so we look
// for a timeout on read to detect a writer stall and thus let
// us check below for cancellation.
goto Sleep
}
// Per pipe(7): If all file descriptors referring to the write end
Expand Down

0 comments on commit 341ac73

Please sign in to comment.