| | |
| | | } else { |
| | | taskIDs := GetAllTaskByID(imagemsg.Cid) |
| | | for _, taskID := range taskIDs { |
| | | logger.Info("id: ", imagemsg.Cid, " taskid: ", taskID) |
| | | doTaskList(imagemsg.Cid, "", taskID, recvmessage) |
| | | } |
| | | } |
| | |
| | | func MaybeRestartSocket(socket SocketContext, tryCnt *int) SocketContext { |
| | | if socket.UseSHM { |
| | | if *tryCnt > ShmMaxTryCount { |
| | | logger.Info("SDK SEND SHM TRY :", ShmMaxTryCount, " RESTART IT") |
| | | logger.Info("SDK SEND SHM TRY :", ShmMaxTryCount, " RESTART: ", socket.URL) |
| | | |
| | | socket.Sock.Close() |
| | | newSocket, err := NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |