| | |
| | | if tryCount > util.ShmMaxTryCount { |
| | | socket.Sock.Close() |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | | logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT") |
| | | logger.Info("=========CAMERA RECV SHM ERROR=========") |
| | | logger.Info("CAMERA RECV FROM:", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT") |
| | | tryCount = 0 |
| | | continue |
| | | } |
| | |
| | | } else { |
| | | taskIDs := GetAllTaskByID(imagemsg.Cid) |
| | | for _, taskID := range taskIDs { |
| | | logger.Debug("id: ", imagemsg.Cid, " taskid: ", taskID) |
| | | doTaskList(imagemsg.Cid, "", taskID, recvmessage) |
| | | } |
| | | } |