debug msg
parent
54237b2df7
commit
530be231e3
|
@ -63,29 +63,28 @@ func handleSendQueueMessage(currentTime time.Time, webClient *structs.WebClient,
|
|||
if int(currentTime.UnixMilli())-int(msg.Time.UnixMilli()) > kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount] {
|
||||
var err error
|
||||
|
||||
if webClient != nil && mcClient != nil {
|
||||
msg.Time = currentTime
|
||||
msg.Time = currentTime
|
||||
|
||||
if webClient != nil {
|
||||
if isVoice {
|
||||
logger.WebVoice.Debugln("ackHandler -> send msg to voice client")
|
||||
err = webClient.SendBinaryMessage(webClient.VoiceConn, msg.MessageRaw)
|
||||
} else {
|
||||
logger.WebMobile.Debugln("ackHandler -> send msg to mobile client")
|
||||
err = webClient.SendBinaryMessage(webClient.MobileConn, msg.MessageRaw)
|
||||
}
|
||||
if webClient != nil {
|
||||
if isVoice {
|
||||
logger.WebVoice.Debugln("ackHandler -> send msg to voice client")
|
||||
err = webClient.SendBinaryMessage(webClient.VoiceConn, msg.MessageRaw)
|
||||
} else {
|
||||
logger.Minecraft.Debugln("ackHandler -> send msg to mc client", mcClient.Name)
|
||||
err = mcClient.SendBinaryMessage(msg.MessageRaw)
|
||||
logger.WebMobile.Debugln("ackHandler -> send msg to mobile client")
|
||||
err = webClient.SendBinaryMessage(webClient.MobileConn, msg.MessageRaw)
|
||||
}
|
||||
} else {
|
||||
logger.Minecraft.Debugln("ackHandler -> send msg to mc client", mcClient.Name)
|
||||
err = mcClient.SendBinaryMessage(msg.MessageRaw)
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
logger.Web.Println("ackHandler err sending msg", err)
|
||||
}
|
||||
if err != nil {
|
||||
logger.Web.Println("ackHandler err sending msg", err)
|
||||
}
|
||||
|
||||
if msg.TrySendCount < 4 {
|
||||
msg.TrySendCount++
|
||||
}
|
||||
if msg.TrySendCount < 4 {
|
||||
msg.TrySendCount++
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue