Skip to content

Commit

Permalink
otelhttp: nil check wrappedBody.Close
Browse files Browse the repository at this point in the history
  • Loading branch information
adamdecaf committed Apr 6, 2022
1 parent 8cf7954 commit 78437aa
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 1 deletion.
4 changes: 4 additions & 0 deletions CHANGELOG.md
Expand Up @@ -19,6 +19,10 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
- Upgraded all dependencies on stable modules from `go.opentelemetry.io/otel` from v1.5.0 to v1.6.1. (#2134)
- Upgraded all dependencies on metric modules from `go.opentelemetry.io/otel` from v0.27.0 to v0.28.0. (#1977)

### Fixed

- otelhttp: nil check wrappedBody.Close

## [1.5.0/0.30.0/0.1.0] - 2022-03-16

### Added
Expand Down
5 changes: 4 additions & 1 deletion instrumentation/net/http/otelhttp/transport.go
Expand Up @@ -186,5 +186,8 @@ func (wb *wrappedBody) Read(b []byte) (int, error) {

func (wb *wrappedBody) Close() error {
wb.span.End()
return wb.body.Close()
if wb.body != nil {
return wb.body.Close()
}
return nil
}
4 changes: 4 additions & 0 deletions instrumentation/net/http/otelhttp/transport_test.go
Expand Up @@ -279,6 +279,10 @@ func TestWrappedBodyClose(t *testing.T) {
wb := &wrappedBody{span: trace.Span(s), body: readCloser{}}
assert.NoError(t, wb.Close())
s.assert(t, true, nil, codes.Unset, "")

var body io.ReadCloser
wb2 := newWrappedBody(s, body)
assert.NoError(t, wb2.Close())
}

func TestWrappedBodyCloseError(t *testing.T) {
Expand Down

0 comments on commit 78437aa

Please sign in to comment.