update

zhangmeng

2019-12-13 2d25b62b60da018412ed164b6fd29470498cea17

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package work
 
import (
    "basic.com/valib/deliver.git"
 
    "basic.com/pubsub/protomsg.git"
)
 
const mode = deliver.PushPull
 
// MsgRS msg recv and snd
type MsgRS struct {
    Msg protomsg.SdkMessage
}
 
func snappyCompress(in []byte) ([]byte, error) {
    return in, nil
    // out := snappy.Encode(nil, in)
    // return out, nil
}
 
// Compress compress
func Compress(in []byte) ([]byte, error) {
    return in, nil
    // return lz4Compress(in)
    // return snappyCompress(in)
}
 
func lz4Compress(in []byte) ([]byte, error) {
    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 {
    //     logo.Errorln(err)
    //     return nil, err
    // }
    // if n >= len(in) {
    //     logo.Infoln("image is not compressible")
    // }
    // out = out[:n] // compressed data
    // return out, nil
}
 
////////////////////////////////////////////////////////////////
func snappyUncompress(in []byte) ([]byte, error) {
    return in, nil
    // out, err := snappy.Decode(nil, in)
    // return out, err
}
 
// UnCompress uncompress
func UnCompress(in []byte) ([]byte, error) {
    return in, nil
    // return lz4Uncompress(in)
    // return snappyUncompress(in)
}
 
func lz4Uncompress(in []byte) ([]byte, error) {
    return in, nil
 
    // out := make([]byte, 10*len(in))
    // n, err := lz4.UncompressBlock(in, out)
    // if err != nil {
    //     logo.Errorln(err)
    //     return nil, err
    // }
    // out = out[:n] // uncompressed data
    // return out, nil
}