handling for err status and already in queue for mc messages
parent
530be231e3
commit
7afb928123
|
@ -21,6 +21,26 @@ func HandleMinecraftMessage(conn *websocket.Conn, msg []byte) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if status == kraProtocol.StatusErrTryAgain {
|
||||||
|
logger.Minecraft.Warnln("err StatusErrTryAgain cmdID", cmdID, "cmdNumber", cmdNumber)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if status == kraProtocol.StatusErrNoPerms {
|
||||||
|
logger.Minecraft.Warnln("err StatusErrNoPerms cmdID", cmdID, "cmdNumber", cmdNumber)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if status == kraProtocol.StatusErrArgLenTooBig {
|
||||||
|
logger.Minecraft.Warnln("err StatusErrArgLenTooBig cmdID", cmdID, "cmdNumber", cmdNumber)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if status == kraProtocol.StatusMessageAlreadyInQueue {
|
||||||
|
logger.Minecraft.Warnln("rec StatusMessageAlreadyInQueue cmdID", cmdID, "cmdNumber", cmdNumber)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
if status == kraProtocol.StatusReply {
|
if status == kraProtocol.StatusReply {
|
||||||
if isCmdIDInList(mcClient.CmdIDs, cmdID) {
|
if isCmdIDInList(mcClient.CmdIDs, cmdID) {
|
||||||
mcClient.RemoveCmdID(cmdID)
|
mcClient.RemoveCmdID(cmdID)
|
||||||
|
|
|
@ -86,5 +86,4 @@ func handleSendQueueMessage(currentTime time.Time, webClient *structs.WebClient,
|
||||||
msg.TrySendCount++
|
msg.TrySendCount++
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue