From e6982607fbbeaa96d3d14409df780266646b793d Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 01 十一月 2019 18:22:44 +0800 Subject: [PATCH] 换一个chan --- util/common.go | 46 ++++++++++++++++++++++------------------------ 1 files changed, 22 insertions(+), 24 deletions(-) diff --git a/util/common.go b/util/common.go index 294883d..a5c4a17 100644 --- a/util/common.go +++ b/util/common.go @@ -1,13 +1,9 @@ package util import ( - "fmt" - "basic.com/valib/deliver.git" "basic.com/pubsub/protomsg.git" - - "github.com/pierrec/lz4" ) const ( @@ -30,28 +26,30 @@ // UnCompress uncompress func UnCompress(in []byte) ([]byte, error) { - out := make([]byte, 10*len(in)) - n, err := lz4.UncompressBlock(in, out) - if err != nil { - fmt.Println(err) - return nil, err - } - out = out[:n] // uncompressed data - return out, nil + return in,nil + //out := make([]byte, 10*len(in)) + //n, err := lz4.UncompressBlock(in, out) + //if err != nil { + // fmt.Println(err) + // return nil, err + //} + //out = out[:n] // uncompressed data + //return out, nil } // Compress compress func Compress(in []byte) ([]byte, error) { - out := make([]byte, len(in)) - ht := make([]int, 64<<10) // buffer for the compression table - n, err := lz4.CompressBlock(in, out, ht) - if err != nil { - fmt.Println(err) - return nil, err - } - if n >= len(in) { - fmt.Println("image is not compressible") - } - out = out[:n] // compressed data - return out, nil + return in,nil + //out := make([]byte, len(in)) + //ht := make([]int, 64<<10) // buffer for the compression table + //n, err := lz4.CompressBlock(in, out, ht) + //if err != nil { + // fmt.Println(err) + // return nil, err + //} + //if n >= len(in) { + // fmt.Println("image is not compressible") + //} + //out = out[:n] // compressed data + //return out, nil } -- Gitblit v1.8.0