by 192.168.1.124

龙赣华

2019-06-05 d7ee5b3444e7681cfb4574681d54156e148c34da

 camera/camera.go

@@ -37,6 +37,7 @@
   }

   go CreateCamera(Initchannel)
   go AutoDelCamera(util.Cameraflag)

   for _, cam := range util.CameraIds {
      Initchannel <- cam.Id
@@ -57,6 +58,45 @@
         go func(cid string, sock SocketContext) {
            Recv(cid, sock)
         }(id, socketlisten)
      }
   }
}

//动态处理
func AutoDelCamera(cameraflag chan bool) {

   for _ = range cameraflag {
      fmt.Println("test autodelcameraflag")
      var oldcamera []string

      SocketManage.Range(func(k, v interface{}) bool {
         if str, ok := k.(string); ok {
            oldcamera = append(oldcamera, str)
         }
         return true
      })

      var newcamera []string

      for _, value := range util.CameraIds {
         newcamera = append(newcamera, value.Id)
      }

      cameraChanDel := util.Difference(oldcamera, newcamera)
      fmt.Println(cameraChanDel)

      for key, op := range cameraChanDel {
         if op == "add" {
            Initchannel <- key
         } else {
            if sock, ok := SocketManage.Load(key); ok {
               if socket, sok := sock.(SocketContext); sok {
                  socket.Cancel()
                  SocketManage.Delete(key)
               }
            }
            fmt.Println("删除camera server : ", key)
         }
      }
   }
}
@@ -122,7 +162,7 @@
   //  数据加工(打标签)
   sdkmsg := sdk.SdkData(cid, taskid, data)
   if sdkmsg.Tasklab == nil {
      fmt.Println("cid:%s 没有任务%s", cid, taskid)
      fmt.Printf("cid:%s 没有任务%s\n", cid, taskid)
      return
   }