From 2f5f0c75f3257b4ea9c37df6d02e5598b975740f Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 11 十二月 2019 17:10:27 +0800
Subject: [PATCH] copy from VAProcess
---
work/ipcsender.go | 24 ++----------------------
1 files changed, 2 insertions(+), 22 deletions(-)
diff --git a/work/ipcsender.go b/work/ipcsender.go
index b136fc9..e77d187 100644
--- a/work/ipcsender.go
+++ b/work/ipcsender.go
@@ -1,7 +1,6 @@
package work
import (
- "analysis/goconv"
"analysis/logo"
"context"
@@ -80,26 +79,7 @@
if int(i.Msg.Tasklab.Index+1) == len(i.Msg.Tasklab.Sdkinfos) {
if s.fn != nil {
- imgInfo := unpackImage(i, "sender")
- if imgInfo.Data == nil {
- continue
- }
- imgProto := protomsg.Image{
- Data: goconv.YUV2BGR(imgInfo.Data, int(imgInfo.Width), int(imgInfo.Height)),
- Width: int32(imgInfo.Width),
- Height: int32(imgInfo.Height),
- Timestamp: imgInfo.Timestamp,
- Id: imgInfo.Id,
- Cid: imgInfo.Cid,
- }
- var sendData []byte
- if b, err := proto.Marshal(&imgProto); err == nil {
- i.Msg.Data = b
- sendData, err = proto.Marshal(&i.Msg)
- if err != nil {
- continue
- }
- }
+
sFlag := true
for _, v := range i.Msg.Tasklab.Sdkinfos {
if len(v.Sdkdata) < 2 {
@@ -107,7 +87,7 @@
break
}
}
- s.fn(sendData, sFlag)
+ s.fn(d, sFlag)
}
}
--
Gitblit v1.8.0