Skip to content

Commit

Permalink
chore: nolint cases where the linter is wrong.
Browse files Browse the repository at this point in the history
  • Loading branch information
jaqx0r committed Apr 27, 2023
1 parent 49ea79a commit ae6ee2f
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 0 deletions.
2 changes: 2 additions & 0 deletions internal/mtail/mtail.go
Original file line number Diff line number Diff line change
Expand Up @@ -200,12 +200,14 @@ func New(ctx context.Context, store *metrics.Store, options ...Option) (*Server,
if err := m.initExporter(); err != nil {
return nil, err
}
//nolint:contextcheck // TODO
if err := m.initRuntime(); err != nil {
return nil, err
}
if err := m.initTailer(); err != nil {
return nil, err
}
//nolint:contextcheck // TODO
if err := m.initHTTPServer(); err != nil {
return nil, err
}
Expand Down
1 change: 1 addition & 0 deletions internal/tailer/logstream/dgramstream.go
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,7 @@ func (ss *dgramStream) stream(ctx context.Context, wg *sync.WaitGroup, waker wak

if n > 0 {
total += n
//nolint:contextcheck
decodeAndSend(ss.ctx, ss.lines, ss.address, n, b[:n], partial)
ss.mu.Lock()
ss.lastReadTime = time.Now()
Expand Down
1 change: 1 addition & 0 deletions internal/tailer/logstream/pipestream.go
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,7 @@ func (ps *pipeStream) stream(ctx context.Context, wg *sync.WaitGroup, waker wake

if n > 0 {
total += n
//nolint:contextcheck
decodeAndSend(ps.ctx, ps.lines, ps.pathname, n, b[:n], partial)
// Update the last read time if we were able to read anything.
ps.mu.Lock()
Expand Down
1 change: 1 addition & 0 deletions internal/tailer/logstream/socketstream.go
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,7 @@ func (ss *socketStream) handleConn(ctx context.Context, wg *sync.WaitGroup, wake

if n > 0 {
total += n
//nolint:contextcheck
decodeAndSend(ss.ctx, ss.lines, ss.address, n, b[:n], partial)
ss.mu.Lock()
ss.lastReadTime = time.Now()
Expand Down

0 comments on commit ae6ee2f

Please sign in to comment.