Skip to content

Commit 8d1a0f6

Browse files
committed
return ReadCloser
1 parent 0cfd431 commit 8d1a0f6

File tree

3 files changed

+5
-11
lines changed

3 files changed

+5
-11
lines changed

pkg/collect/ceph.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package collect
33
import (
44
"context"
55
"fmt"
6-
"io"
76
"os"
87
"path"
98
"strings"
@@ -203,10 +202,7 @@ func copyResult(srcResult CollectorResult, dstResult CollectorResult, bundlePath
203202
}
204203
return errors.Wrap(err, "failed to get reader")
205204
}
206-
207-
if reader, ok := reader.(io.ReadCloser); ok {
208-
defer reader.Close()
209-
}
205+
defer reader.Close()
210206

211207
err = dstResult.SaveResult(bundlePath, dstKey, reader)
212208
if err != nil {

pkg/collect/redact.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,7 @@ func redactResult(bundlePath string, input CollectorResult, additionalRedactors
2626
}
2727
return errors.Wrap(err, "failed to get reader")
2828
}
29-
if r, ok := r.(io.ReadCloser); ok {
30-
defer r.Close()
31-
}
29+
defer r.Close()
3230

3331
reader = r
3432
} else {

pkg/collect/result.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,17 +85,17 @@ func (r CollectorResult) ReplaceResult(bundlePath string, relativePath string, r
8585
return nil
8686
}
8787

88-
func (r CollectorResult) GetReader(bundlePath string, relativePath string) (io.Reader, error) {
88+
func (r CollectorResult) GetReader(bundlePath string, relativePath string) (io.ReadCloser, error) {
8989
if r[relativePath] != nil {
90-
return bytes.NewReader(r[relativePath]), nil
90+
return ioutil.NopCloser(bytes.NewReader(r[relativePath])), nil
9191
}
9292

9393
if bundlePath == "" {
9494
return nil, errors.New("cannot create reader, bundle path is empty")
9595
}
9696

9797
filename := filepath.Join(bundlePath, relativePath)
98-
f, err := os.Open(filename) // does this ever close?
98+
f, err := os.Open(filename)
9999
if err != nil {
100100
return nil, errors.Wrap(err, "failed to open file")
101101
}

0 commit comments

Comments
 (0)