Krakatoa-Earth
/
Backend
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

ensure that messages are received through ack

master
Alex 2022-01-31 19:17:04 +01:00
parent b7c853770f
commit 3ccd014d69
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
serverCommunication/serverCommunication.go
View File

@ -30,13 +30,33 @@ func AckHandler() {
ticker := time.NewTicker(5 * time.Second) // 20 * time.Millisecond
for _ = range ticker.C {
currentTime := time.Now()
/*for uuid, webClient := range cache.WebClients {
logger.Web.Println("ackHandler web client", uuid, webClient.SendVoiceQueueMessages, webClient.SendMobileQueueMessages)
} */
for serverName, mcClient := range cache.MinecraftClients {
logger.Web.Println("ackHandler mc client", serverName, mcClient.SendQueueMessages, kraSettingsConfig.Cfg.WebSocket.AckTimeouts)
logger.Minecraft.Println("ackHandler mc client", serverName, mcClient.SendQueueMessages, kraSettingsConfig.Cfg.WebSocket.AckTimeouts)
for _, msg := range mcClient.SendQueueMessages {
logger.Minecraft.Println("msg", msg)
if msg.TrySendCount < 5 {
msg.TrySendCount++
}
logger.Minecraft.Println("ackHandler mc", msg.TrySendCount, currentTime.UnixMilli()-msg.Time.UnixMilli())
/*
if int(currentTime.UnixMilli())-int(msg.Time.UnixMilli()) > kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount] {
err := mcClient.SendBinaryMessage(msg.MessageRaw)
if err != nil {
logger.Minecraft.Println("ackHandler err sending msg", err)
}
} */
}
}
}
}