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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
| package work
|
| import (
| "basic.com/valib/deliver.git"
|
| "basic.com/pubsub/protomsg.git"
| )
|
| const (
| FDetect = "FaceDetect"
| // FExtract = "FaceExtract"
| // FProperty = "FaceProperty"
| FCompare = "FaceCompare"
| FtTract = "FaceTrack"
| FtDetect = "FaceTrackDetect"
| FtOnly = "FaceTrackOnly"
| YDetect = "Yolo"
| PlateID = "Plate"
| )
|
| var (
| SDK = []string{
| YDetect,
| FDetect,
| FCompare,
| PlateID,
| // FtTract,
| // FtOnly,
| }
| )
|
| 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
| }
|
|
