From a32abda1a3fb696687739805faa1f5444d86c5fa Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 7 Apr 2019 11:01:28 -0700 Subject: [PATCH] adjust compression to optimize for speed --- weed/operation/compress.go | 2 +- weed/operation/upload_content.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/weed/operation/compress.go b/weed/operation/compress.go index a28fb33ec..7190eeeb2 100644 --- a/weed/operation/compress.go +++ b/weed/operation/compress.go @@ -72,7 +72,7 @@ func IsGzippableFileType(ext, mtype string) (shouldBeZipped, iAmSure bool) { func GzipData(input []byte) ([]byte, error) { buf := new(bytes.Buffer) - w, _ := gzip.NewWriterLevel(buf, flate.BestCompression) + w, _ := gzip.NewWriterLevel(buf, flate.BestSpeed) if _, err := w.Write(input); err != nil { glog.V(2).Infoln("error compressing data:", err) return nil, err diff --git a/weed/operation/upload_content.go b/weed/operation/upload_content.go index 6bd299826..dcab1a0ae 100644 --- a/weed/operation/upload_content.go +++ b/weed/operation/upload_content.go @@ -2,6 +2,7 @@ package operation import ( "bytes" + "compress/flate" "compress/gzip" "encoding/json" "errors" @@ -50,7 +51,7 @@ func Upload(uploadUrl string, filename string, reader io.Reader, isGzipped bool, } return upload_content(uploadUrl, func(w io.Writer) (err error) { if shouldGzipNow { - gzWriter := gzip.NewWriter(w) + gzWriter, _ := gzip.NewWriterLevel(w, flate.BestSpeed) _, err = io.Copy(gzWriter, reader) gzWriter.Close() } else {