From 1bb4d137919cae4f57f95a2572ee612dcabb3b3d Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期五, 17 一月 2020 09:31:09 +0800
Subject: [PATCH] add some log for recv/send
---
run.go | 5 +++++
rpc/recv.go | 2 +-
2 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/rpc/recv.go b/rpc/recv.go
index 6bf4986..3cc3e56 100644
--- a/rpc/recv.go
+++ b/rpc/recv.go
@@ -8,7 +8,7 @@
"basic.com/valib/deliver.git"
)
-const mode = deliver.Shm
+const mode = deliver.PushPull
// Reciever recv from ipc
type Reciever struct {
diff --git a/run.go b/run.go
index 95a9958..661263f 100644
--- a/run.go
+++ b/run.go
@@ -144,6 +144,7 @@
return
case msg := <-chMsg:
if len(msg.Tasklab.Sdkinfos) == 0 || int(msg.Tasklab.Index) >= len(msg.Tasklab.Sdkinfos) {
+ s.fnLogger("reid !!!!!! recv msg error")
continue
}
i := sdkhelper.UnpackImage(msg, "reid", s.fnLogger)
@@ -153,6 +154,8 @@
}
sdkInfo := msg.Tasklab.Sdkinfos[int(msg.Tasklab.Index)]
+ s.fnLogger("reid !!!!!! recv from humantrack len: ", len(sdkInfo))
+
res := &protomsg.HumanTrackResult{}
if err := proto.Unmarshal(sdkInfo.Sdkdata, res); err != nil {
s.fnLogger(err, " sdkinfo msg Unmarshal 澶勭悊寮傚父")
@@ -183,6 +186,8 @@
s.fnLogger(err, " msg Marshal 澶勭悊寮傚父")
continue
}
+ s.fnLogger("reid !!!!!! send to humantrack len: ", len(data))
+
chSnd <- data
}
}
--
Gitblit v1.8.0