| | |
| | | |
| | | func Recv(socket util.SocketContext) { |
| | | |
| | | tryCount := 0 |
| | | |
| | | var recvmessage []byte |
| | | var imagemsg protomsg.Image |
| | | var err error |
| | |
| | | default: |
| | | if recvmessage, err = socket.Sock.Recv(); err != nil { |
| | | //logger.Error("[camera] err is: ", err) |
| | | // fmt.Println("CAMERA RECV ERROR: ", err) |
| | | |
| | | if socket.UseSHM { |
| | | if tryCount > util.SHMMaxTryCount { |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | | fmt.Println("CAMERA SHM TRY :", tryCount, " RESTART IT") |
| | | |
| | | tryCount = 0 |
| | | |
| | | continue |
| | | } |
| | | tryCount++ |
| | | } |
| | | continue |
| | | } |
| | | |
| | |
| | | for _, camsingle := range util.CameraTasks { |
| | | if cid == camsingle.Camera.Id { |
| | | for _, tasksingle := range camsingle.Tasks { |
| | | if !tasksingle.Enable { |
| | | continue |
| | | } |
| | | tasks = append(tasks, tasksingle.Taskid) |
| | | } |
| | | return |