7 "github.com/aws/aws-sdk-go/internal/sdkio"
10 // offsetReader is a thread-safe io.ReadCloser to prevent racing
11 // with retrying requests
12 type offsetReader struct {
18 func newOffsetReader(buf io.ReadSeeker, offset int64) *offsetReader {
19 reader := &offsetReader{}
20 buf.Seek(offset, sdkio.SeekStart)
26 // Close will close the instance of the offset reader's access to
27 // the underlying io.ReadSeeker.
28 func (o *offsetReader) Close() error {
35 // Read is a thread-safe read of the underlying io.ReadSeeker
36 func (o *offsetReader) Read(p []byte) (int, error) {
47 // Seek is a thread-safe seeking operation.
48 func (o *offsetReader) Seek(offset int64, whence int) (int64, error) {
52 return o.buf.Seek(offset, whence)
55 // CloseAndCopy will return a new offsetReader with a copy of the old buffer
56 // and close the old buffer.
57 func (o *offsetReader) CloseAndCopy(offset int64) *offsetReader {
59 return newOffsetReader(o.buf, offset)