From 455a7bb3e42582a62a02d7baf1b1d4495bf6107c Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 20 一月 2020 11:50:52 +0800
Subject: [PATCH] "$1"
---
common/helper.go | 78 ---------------------------------------
1 files changed, 0 insertions(+), 78 deletions(-)
diff --git a/common/helper.go b/common/helper.go
index 0e016c3..29fa255 100644
--- a/common/helper.go
+++ b/common/helper.go
@@ -8,13 +8,9 @@
"strconv"
"time"
- "basic.com/libgowrapper/sdkstruct.git"
"basic.com/pubsub/protomsg.git"
- "basic.com/valib/deliver.git"
"github.com/gogo/protobuf/proto"
)
-
-const mode = deliver.PushPull
// GetIpcAddress get ipc
func GetIpcAddress(shm bool, id string) string {
@@ -81,80 +77,6 @@
time.Sleep(10 * time.Millisecond)
}
}
-}
-
-// Msg2MsgSDK msg->msgsdk
-func Msg2MsgSDK(msg protomsg.SdkMessage) *sdkstruct.MsgSDK {
-
- d, err := proto.Marshal(&msg)
- if err != nil {
- return nil
- }
-
- index, count := int(msg.Tasklab.Index), len(msg.Tasklab.Sdkinfos)
- if index >= count {
- return &sdkstruct.MsgSDK{
- MsgData: d,
- SdkCount: count,
- SdkIndex: index,
- SdkDataLen: 0,
- }
- }
-
- return &sdkstruct.MsgSDK{
- MsgData: d,
- SdkCount: count,
- SdkIndex: index,
- SdkDataLen: len(d),
- }
-}
-
-// EjectResult eject
-func EjectResult(res []byte, msg protomsg.SdkMessage, out chan<- sdkstruct.MsgSDK) {
-
- if res == nil {
- s := Msg2MsgSDK(msg)
- if s == nil {
- return
- }
- out <- *s
- return
- }
-
- msg.Tasklab.Sdkinfos[int(msg.Tasklab.Index)].Sdkdata = res
-
- s := Msg2MsgSDK(msg)
- if s == nil {
- return
- }
- out <- *s
-}
-
-/////////////////////////////////////////////////////////////
-
-// ValidRemoteMessage valid or not
-func ValidRemoteMessage(msg protomsg.SdkMessage, fnName string, fn func(...interface{})) bool {
- if msg.Tasklab == nil {
- fn(fnName, " recieve msg nil")
- return false
- }
-
- sdkLen := len(msg.Tasklab.Sdkinfos)
- if sdkLen == 0 {
- fn(fnName, " has no sdk info")
- return false
- }
-
- curIndex := int(msg.Tasklab.Index)
- if curIndex < 0 || curIndex >= sdkLen {
- fn(fnName, " tasklab index ", curIndex, " error")
- return false
- }
- if msg.Tasklab.Sdkinfos[curIndex].Sdktype != fnName {
- fn(fnName, " is different from ", msg.Tasklab.Sdkinfos[curIndex].Sdktype)
- return false
- }
- return true
}
// UnpackImage unpack
--
Gitblit v1.8.0