From 7c6a958f00e327a8991f48093456de7cb84cf918 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期三, 05 二月 2020 20:20:24 +0800
Subject: [PATCH] change log for proto marshal
---
run.go | 19 ++++++++++---------
1 files changed, 10 insertions(+), 9 deletions(-)
diff --git a/run.go b/run.go
index 9e51f9d..cef375d 100644
--- a/run.go
+++ b/run.go
@@ -48,7 +48,7 @@
"reid/rpc"
- "basic.com/libgowrapper/sdkhelper.git"
+ "reid/common"
"basic.com/valib/gogpu.git"
@@ -66,9 +66,9 @@
}
// Create Reid
-func Create(config string, typ, id string, gpu int, shm bool, ipc2Rule string, ruleMaxSize int, fn func(...interface{}), reserved map[string]interface{}) interface{} {
+func Create(config string, typ, id string, gpu int, shm bool, fn func(...interface{}), reserved map[string]interface{}) interface{} {
- cfg, err := sdkhelper.ReadConfig(config)
+ cfg, err := common.ReadConfig(config)
if err != nil {
fn("Reid SDK Create Error When Read Config: ", err)
return nil
@@ -88,7 +88,7 @@
}
}
- gpuM := sdkhelper.Atoi(cfg.Param[sGPU])
+ gpuM := common.Atoi(cfg.Param[sGPU])
rGPU := gpu
@@ -123,8 +123,8 @@
ipcSnd := s.ipc + postPush
ipcRcv := s.ipc + postPull
- sndURL := sdkhelper.GetIpcAddress(true, ipcSnd)
- rcvURL := sdkhelper.GetIpcAddress(true, ipcRcv)
+ sndURL := common.GetIpcAddress(true, ipcSnd)
+ rcvURL := common.GetIpcAddress(true, ipcRcv)
chSnd := make(chan []byte, 3)
chRcv := make(chan []byte, 3)
@@ -133,7 +133,7 @@
go recv.Run(ctx)
chMsg := make(chan protomsg.SdkMessage, 3)
- go sdkhelper.UnserilizeProto(ctx, chRcv, chMsg, s.fnLogger)
+ go common.UnserilizeProto(ctx, chRcv, chMsg, s.fnLogger)
send := rpc.NewSender(sndURL, chSnd, true, s.fnLogger)
go send.Run(ctx)
@@ -147,7 +147,7 @@
s.fnLogger("reid !!!!!! Recv Msg From Humantrack Error")
continue
}
- i := sdkhelper.UnpackImage(msg, "reid", s.fnLogger)
+ i := common.UnpackImage(msg, "reid", s.fnLogger)
if i == nil || i.Data == nil || i.Width <= 0 || i.Height <= 0 {
s.fnLogger("reid !!!!!! Unpack Image From Humantrack Msg Failed")
continue
@@ -181,6 +181,7 @@
if len(res.Result) > 0 {
if out, err := proto.Marshal(res); err == nil {
msg.Tasklab.Sdkinfos[int(msg.Tasklab.Index)].Sdkdata = out
+ s.fnLogger("reid !!!!!! Send To Humantrack Result Length:", len(out))
}
}
@@ -189,7 +190,7 @@
s.fnLogger("reid !!!!!! proto.Marshal Failed To Marshal proto.SdkMessage")
continue
}
- s.fnLogger("reid !!!!!! Send To Humantrack Result Length:", len(data))
+ // s.fnLogger("reid !!!!!! MSG Send Back To Humantrack Length:", len(data))
chSnd <- data
} else {
--
Gitblit v1.8.0