| | |
| | | logger.Debug("readFromUploadImg err:",err) |
| | | return nil,err,i |
| | | } |
| | | bc, err := ImgCompress(i) |
| | | logger.Debug("ImgCompress用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | | if err !=nil { |
| | | logger.Debug("ImgCompress err:",err) |
| | | return nil,err,i |
| | | } |
| | | bc,_ := proto.Marshal(i) |
| | | //bc, err := ImgCompress(i) |
| | | //logger.Debug("ImgCompress用时:", time.Since(t1)) |
| | | //t1 = time.Now() |
| | | //if err !=nil { |
| | | // logger.Debug("ImgCompress err:",err) |
| | | // return nil,err,i |
| | | //} |
| | | s.PushImgMsg(bc) |
| | | logger.Debug("PushImgMsg用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | |
| | | } |
| | | rMsg := protomsg.SdkMessage{} |
| | | if err := proto.Unmarshal(resultBytes, &rMsg); err == nil { |
| | | logger.Debug("received MSG:", rMsg.Cid) |
| | | i := protomsg.Image{} |
| | | bdata, err := util.UnCompress(rMsg.Data) |
| | | if err !=nil { |