From 5a0e125d6b05c42cf26d3e341249be7a2fd80d6d Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期一, 22 七月 2019 13:39:28 +0800
Subject: [PATCH] release without log
---
camera/camera.go | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/camera/camera.go b/camera/camera.go
index db904fc..5719fd4 100644
--- a/camera/camera.go
+++ b/camera/camera.go
@@ -13,7 +13,9 @@
"context"
"fmt"
"sync"
- // "time"
+ //"time"
+ "os"
+
)
var SocketManage sync.Map
@@ -52,6 +54,7 @@
fmt.Println("create socket error")
return
}
+
go Recv(socketlisten, remote)
}
}
@@ -79,6 +82,8 @@
for key, op := range cameraChanDel {
if op == "add" {
CreateCamera(key, "camera")
+ fmt.Println("add new camera id=========================")
+ os.Exit(1)
} else {
if sock, ok := SocketManage.Load(key); ok {
if socket, sok := sock.(SocketContext); sok {
@@ -140,8 +145,9 @@
// fmt.Println(imagemsg.Cid)
switch remote {
case "camera":
+ fmt.Printf("=== cid: has %d task\n", len(GetAlltask(imagemsg.Cid)))
for _, taskid := range GetAlltask(imagemsg.Cid) {
- // time.Sleep(5 * time.Second)
+ //time.Sleep(5 * time.Second)
fmt.Println("id: ", imagemsg.Cid, " taskid: ", taskid)
Taskdolist(imagemsg.Cid, "", taskid, recvmessage)
}
@@ -169,6 +175,7 @@
func Taskdolist(cid string, caddr string, taskid string, data []byte) {
// 鏁版嵁鍔犲伐(鎵撴爣绛�)
+ fmt.Printf("taskid %s: has %d data[]byte\n", taskid, len(data))
sdkmsg := sdk.SdkData(cid, caddr, taskid, data)
if sdkmsg.Tasklab == nil {
fmt.Printf("cid:%s 娌℃湁浠诲姟%s\n", cid, taskid)
--
Gitblit v1.8.0