---

panlei

2019-11-07 52713b8d85e26a984ecaeef926c815e8cf8075b7

 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
}