lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-08-01 08:00:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

adjust uncompress data

Browse Source
This commit is contained in:
Chris Lu 2020-06-20 08:01:00 -07:00
parent ca3516ac6d
commit a735fd767c
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
weed/util/compression.go
View File

@ -4,6 +4,7 @@ import (
"bytes" "bytes"
"compress/flate" "compress/flate"
"compress/gzip" "compress/gzip"
"fmt"
"io/ioutil" "io/ioutil"
"strings" "strings"
@ -29,18 +30,7 @@ func UnCompressData(input []byte) ([]byte, error) {
if IsGzippedContent(input) { if IsGzippedContent(input) {
return ungzipData(input) return ungzipData(input)
} }
return nil, fmt.Errorf("unsupported compression")
}
func ungzipData(input []byte) ([]byte, error) {
buf := bytes.NewBuffer(input)
r, _ := gzip.NewReader(buf)
defer r.Close()
output, err := ioutil.ReadAll(r)
if err != nil {
glog.V(2).Infoln("error uncompressing data:", err)
}
return output, err
} }
func ungzipData(input []byte) ([]byte, error) { func ungzipData(input []byte) ([]byte, error) {