camera/camera.go
@@ -124,6 +124,8 @@ func Recv(socket util.SocketContext) { tryCount := 0 var recvmessage []byte var imagemsg protomsg.Image var err error @@ -135,6 +137,17 @@ default: if recvmessage, err = socket.Sock.Recv(); err != nil { //logger.Error("[camera] err is: ", 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 }