From 5ecfc78b116f41fa7f6c029285f1930cbd040520 Mon Sep 17 00:00:00 2001 From: Alex Date: Mon, 31 Jan 2022 20:33:31 +0100 Subject: [PATCH] logrus test --- modules/structs/MinecraftClient.go | 1 + serverCommunication/serverCommunication.go | 8 ++++---- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/modules/structs/MinecraftClient.go b/modules/structs/MinecraftClient.go index dd4005a..7302f1e 100644 --- a/modules/structs/MinecraftClient.go +++ b/modules/structs/MinecraftClient.go @@ -24,6 +24,7 @@ type MinecraftClient struct { func (mcClient *MinecraftClient) SendBinaryMessage(msg []byte) error { mcClient.connMu.Lock() defer mcClient.connMu.Unlock() + logger.Minecraft.Debugln("SendBinaryMessage") return mcClient.Conn.WriteMessage(websocket.BinaryMessage, msg) } diff --git a/serverCommunication/serverCommunication.go b/serverCommunication/serverCommunication.go index 85605e4..b34dbe3 100644 --- a/serverCommunication/serverCommunication.go +++ b/serverCommunication/serverCommunication.go @@ -43,10 +43,6 @@ func AckHandler() { for _, msg := range mcClient.SendQueueMessages { logger.Minecraft.Println("msg", msg) - if msg.TrySendCount < 4 { - msg.TrySendCount++ - } - logger.Minecraft.Println("ackHandler mc", msg.TrySendCount, kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount], currentTime.UnixMilli()-msg.Time.UnixMilli()) if int(currentTime.UnixMilli())-int(msg.Time.UnixMilli()) > kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount] { @@ -58,6 +54,10 @@ func AckHandler() { logger.Minecraft.Println("ackHandler err sending msg", err) } } + + if msg.TrySendCount < 4 { + msg.TrySendCount++ + } } } }