Skip to content

Commit ef4563b

Browse files
author
Rui Hu
committed
cloud: fix incorrect rebase of ResumingReader open at size patch
Recently cockroachdb#103462 was merged after incorrectly rebasing and did not correctly incorporate the addition of the NoFileSize read option for external storages. This patch fixes the rebase in GCS storage and in cloud unit tests. Fixes: cockroachdb#107136 Fixes: cockroachdb#107138 Release note: None
1 parent 43d5804 commit ef4563b

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

pkg/cloud/amazon/s3_storage_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -631,7 +631,7 @@ func TestReadFileAtReturnsSize(t *testing.T) {
631631
_, err = w.Write(data)
632632
require.NoError(t, err)
633633
require.NoError(t, w.Close())
634-
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{NoFileSize: true})
634+
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{})
635635
require.NoError(t, err)
636636

637637
rr, ok := reader.(*cloud.ResumingReader)

pkg/cloud/gcp/gcs_storage.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -294,7 +294,7 @@ func (g *gcsStorage) ReadFile(
294294
return nil, 0, io.EOF
295295
}
296296
}
297-
r, err := g.bucket.Object(object).NewRangeReader(ctx, pos, -1)
297+
r, err := g.bucket.Object(object).NewRangeReader(ctx, pos, length)
298298
if err != nil {
299299
return nil, 0, err
300300
}

pkg/cloud/gcp/gcs_storage_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -480,7 +480,7 @@ func TestReadFileAtReturnsSize(t *testing.T) {
480480
_, err = w.Write(data)
481481
require.NoError(t, err)
482482
require.NoError(t, w.Close())
483-
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{NoFileSize: true})
483+
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{})
484484
require.NoError(t, err)
485485

486486
rr, ok := reader.(*cloud.ResumingReader)

pkg/cloud/httpsink/http_storage_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -486,7 +486,7 @@ func TestReadFileAtReturnsSize(t *testing.T) {
486486
_, err = w.Write(data)
487487
require.NoError(t, err)
488488
require.NoError(t, w.Close())
489-
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{NoFileSize: true})
489+
reader, _, err := s.ReadFile(ctx, file, cloud.ReadOptions{})
490490
require.NoError(t, err)
491491

492492
rr, ok := reader.(*cloud.ResumingReader)

0 commit comments

Comments
 (0)