mirrors_public/schollz_croc
0
0
Fork 0
mirror of https://github.com/schollz/croc.git synced 2025-10-11 13:21:00 +02:00
Code Activity

revert back to flate instead of zstd

Browse source
This commit is contained in:
Zack Scholl 2022-09-16 09:19:58 -07:00
parent 786fc8d34f
commit 30f5a3e84e
3 changed files with 8 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/compress/compress.go
View file

@ -2,10 +2,9 @@ package compress
import (
"bytes"
"compress/flate"
"io"
"github.com/klauspost/compress/zstd"
log "github.com/schollz/logger"
)
@ -31,24 +30,22 @@ func Decompress(src []byte) []byte {
return deCompressedData.Bytes()
}
// compress uses zstd to compress a byte slice to a corresponding level
// compress uses flate to compress a byte slice to a corresponding level
func compress(src []byte, dest io.Writer, level int) {
compressor, err := zstd.NewWriter(dest, zstd.WithEncoderLevel(zstd.EncoderLevelFromZstd(level)))
compressor, err := flate.NewWriter(dest, level)
if err != nil {
panic(err)
log.Debugf("error level data: %v", err)
return
}
if _, err = compressor.Write(src); err != nil {
if _, err := compressor.Write(src); err != nil {
log.Debugf("error writing data: %v", err)
}
compressor.Close()
}
// decompress uses zstd to decompress an io.Reader
// compress uses flate to decompress an io.Reader
func decompress(src io.Reader, dest io.Writer) {
decompressor, err := zstd.NewReader(src)
if err != nil {
panic(err)
}
decompressor := flate.NewReader(src)
if _, err := io.Copy(dest, decompressor); err != nil {
log.Debugf("error copying data: %v", err)
}