diff --git a/internal/gameServer/server.go b/internal/gameServer/server.go index 7e3b064..adfb785 100644 --- a/internal/gameServer/server.go +++ b/internal/gameServer/server.go @@ -115,18 +115,14 @@ func (g *GameServer) ManageBuffer() { return } - // Find the largest buffer health var bufferHealth float32 - var activePlayers bool var leadPlayer int g.gameDataMutex.Lock() // BufferHealth can be modified by processUDP in a different thread for i := range 4 { var err error g.gameData.averageBufferHealth[i], err = g.averageBufferHealth(i) if err == nil && g.gameData.countLag[i] == 0 { - activePlayers = true - - if g.gameData.averageBufferHealth[i] > bufferHealth { + if leadPlayer == 0 { bufferHealth = g.gameData.averageBufferHealth[i] leadPlayer = i + 1 } @@ -134,7 +130,7 @@ func (g *GameServer) ManageBuffer() { } g.gameDataMutex.Unlock() - if activePlayers { + if leadPlayer > 0 { if bufferHealth > float32(g.BufferTarget)+0.75 && g.gameData.bufferSize > 0 { g.gameData.bufferSize-- g.Logger.Info("reduced buffer size", "bufferHealth", bufferHealth, "bufferSize", g.gameData.bufferSize, "leadPlayer", leadPlayer)