---

panlei

2019-09-02 18e59e7adb100e6b43535ab67b1efefa6b2d6baf

---

 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
}