aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/stream.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-08 21:39:33 -0700
committerChris Lu <chris.lu@gmail.com>2020-03-08 21:39:33 -0700
commit2e3f6ad3a97bc7fad349e63289695547f92c1f8b (patch)
tree036cbe846cb6387a3a22cc0a19a1d6d770b061e7 /weed/filer2/stream.go
parent5ac6297c685a3bd6c9b8a3d0f2328dde01f7013a (diff)
downloadseaweedfs-2e3f6ad3a97bc7fad349e63289695547f92c1f8b.tar.xz
seaweedfs-2e3f6ad3a97bc7fad349e63289695547f92c1f8b.zip
filer: remember content is gzipped or not
Diffstat (limited to 'weed/filer2/stream.go')
-rw-r--r--weed/filer2/stream.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/filer2/stream.go b/weed/filer2/stream.go
index 0a1f943ea..381d99144 100644
--- a/weed/filer2/stream.go
+++ b/weed/filer2/stream.go
@@ -26,8 +26,9 @@ func StreamContent(masterClient *wdclient.MasterClient, w io.Writer, chunks []*f
}
for _, chunkView := range chunkViews {
+
urlString := fileId2Url[chunkView.FileId]
- err := util.ReadUrlAsStream(urlString, chunkView.CipherKey, chunkView.IsFullChunk, chunkView.Offset, int(chunkView.Size), func(data []byte) {
+ err := util.ReadUrlAsStream(urlString, chunkView.CipherKey, chunkView.isGzipped, chunkView.IsFullChunk, chunkView.Offset, int(chunkView.Size), func(data []byte) {
w.Write(data)
})
if err != nil {