From f8beddf554ab00dafa95fbd3cecd2c05e5f0e72f Mon Sep 17 00:00:00 2001
From: 龙赣华 <slongertian@gmail.com>
Date: 星期二, 14 五月 2019 13:54:22 +0800
Subject: [PATCH] change json to photobuf
---
camera/camera.go | 12 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/camera/camera.go b/camera/camera.go
index 8ee4409..7a98f50 100644
--- a/camera/camera.go
+++ b/camera/camera.go
@@ -37,11 +37,14 @@
func Taskdolist(cid string, taskid string, data []byte) {
+ fmt.Println("======================================")
+ fmt.Println()
// 鏁版嵁鍔犲伐(鎵撴爣绛�)
sdkmsg := sdk.SdkData(cid, taskid, data)
- fmt.Println("============================")
-
- fmt.Println("sdk 鎵撴爣绛撅細 ", cid, taskid, len(data))
+ if sdkmsg.Tasklab == nil {
+ fmt.Println("cid:%s 娌℃湁浠诲姟%s", cid, taskid)
+ return
+ }
// 璁＄畻鍒嗗彂鐨勪富棰�
SendTopic := sdk.SdkSendTopic(sdkmsg)
@@ -82,7 +85,6 @@
i++
}
}
-
}
func Recv(cameraid string, socket SocketContext) {
@@ -100,7 +102,7 @@
continue
} else {
for _, taskid := range GetAlltask(cameraid) {
- Taskdolist(cameraid, taskid, msg)
+ go Taskdolist(cameraid, taskid, msg)
fmt.Println("receive: ", len(msg), "cameraid: ", cameraid, "taskid: ", taskid)
}
}
--
Gitblit v1.8.0