| | |
| | | logger.Debug("readFromUploadImg err:",err) |
| | | return nil,err,i |
| | | } |
| | | tStart = time.Now() |
| | | bc, err := ImgCompress(i) |
| | | logger.Debug("ImgCompress用时:", time.Since(tStart)) |
| | | if err !=nil { |
| | |
| | | } |
| | | |
| | | func ImgCompress(i *protomsg.Image) ([]byte,error){ |
| | | t1 := time.Now() |
| | | if b, err := proto.Marshal(i); err != nil { |
| | | logger.Debug("protoImage marshal err") |
| | | return nil,err |
| | | } else { |
| | | logger.Debug("proto.Marshal用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | | bc := make([]byte, len(b)) |
| | | ht := make([]int, 64<<10) |
| | | n, err := lz4.CompressBlock(b, bc, ht) |
| | | logger.Debug("lz4.CompressBlock用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | | if err != nil { |
| | | logger.Debug(err) |
| | | return nil,err |
| | |
| | | return nil,errors.New("compressed len is 0") |
| | | } |
| | | bc = bc[:n] |
| | | logger.Debug("bc用时:", time.Since(t1)) |
| | | return bc,nil |
| | | } |
| | | } |