aboutsummaryrefslogtreecommitdiff
path: root/weed/replication
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-12-07 01:57:55 -0800
committerChris Lu <chris.lu@gmail.com>2018-12-07 01:57:55 -0800
commit1bfb96f34df19085e99392b4e9af376b617806ad (patch)
treedcba98459a8cf484497946b1dea61e3d22116ed3 /weed/replication
parent29f1673d9766f11b256ca1c0d653aaa7d99e13aa (diff)
downloadseaweedfs-1bfb96f34df19085e99392b4e9af376b617806ad.tar.xz
seaweedfs-1bfb96f34df19085e99392b4e9af376b617806ad.zip
optimization for reading whole chunk with gzip encoding
Diffstat (limited to 'weed/replication')
-rw-r--r--weed/replication/sink/s3sink/s3_write.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sink/s3sink/s3_write.go b/weed/replication/sink/s3sink/s3_write.go
index 8ff722e67..5c4be7aee 100644
--- a/weed/replication/sink/s3sink/s3_write.go
+++ b/weed/replication/sink/s3sink/s3_write.go
@@ -161,6 +161,6 @@ func (s3sink *S3Sink) buildReadSeeker(chunk *filer2.ChunkView) (io.ReadSeeker, e
return nil, err
}
buf := make([]byte, chunk.Size)
- util.ReadUrl(fileUrl, chunk.Offset, int(chunk.Size), buf)
+ util.ReadUrl(fileUrl, chunk.Offset, int(chunk.Size), buf, true)
return bytes.NewReader(buf), nil
}