110 lines
3.1 KiB
C#
110 lines
3.1 KiB
C#
#region Copyright & License Information
|
|
/*
|
|
* Copyright 2007-2021 The OpenRA Developers (see AUTHORS)
|
|
* This file is part of OpenRA, which is free software. It is made
|
|
* available to you under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation, either version 3 of
|
|
* the License, or (at your option) any later version. For more
|
|
* information, see COPYING.
|
|
*/
|
|
#endregion
|
|
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using OpenRA.Server;
|
|
using S = OpenRA.Server.Server;
|
|
|
|
namespace OpenRA.Mods.Common.Server
|
|
{
|
|
public class PlayerPinger : ServerTrait, ITick
|
|
{
|
|
static readonly int PingInterval = 5000; // Ping every 5 seconds
|
|
static readonly int ConnReportInterval = 20000; // Report every 20 seconds
|
|
static readonly int ConnTimeout = 60000; // Drop unresponsive clients after 60 seconds
|
|
|
|
[TranslationReference]
|
|
static readonly string PlayerDropped = "player-dropped";
|
|
|
|
[TranslationReference("player")]
|
|
static readonly string ConnectionProblems = "connection-problems";
|
|
|
|
[TranslationReference("player")]
|
|
static readonly string Timeout = "timeout";
|
|
|
|
[TranslationReference("player", "timeout")]
|
|
static readonly string TimeoutIn = "timeout-in";
|
|
|
|
long lastPing = 0;
|
|
long lastConnReport = 0;
|
|
bool isInitialPing = true;
|
|
|
|
public void Tick(S server)
|
|
{
|
|
if ((Game.RunTime - lastPing > PingInterval) || isInitialPing)
|
|
{
|
|
isInitialPing = false;
|
|
lastPing = Game.RunTime;
|
|
|
|
// Ignore client timeout in singleplayer games to make debugging easier
|
|
var nonBotClientCount = 0;
|
|
lock (server.LobbyInfo)
|
|
nonBotClientCount = server.LobbyInfo.NonBotClients.Count();
|
|
|
|
if (nonBotClientCount >= 2 || server.Type == ServerType.Dedicated)
|
|
{
|
|
foreach (var c in server.Conns.ToList())
|
|
{
|
|
if (!c.Validated)
|
|
continue;
|
|
|
|
var client = server.GetClient(c);
|
|
if (client == null)
|
|
{
|
|
server.DropClient(c);
|
|
server.SendLocalizedMessage(PlayerDropped);
|
|
continue;
|
|
}
|
|
|
|
if (c.TimeSinceLastResponse < ConnTimeout)
|
|
{
|
|
if (!c.TimeoutMessageShown && c.TimeSinceLastResponse > PingInterval * 2)
|
|
{
|
|
server.SendLocalizedMessage(ConnectionProblems, Translation.Arguments("player", client.Name));
|
|
c.TimeoutMessageShown = true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
server.SendLocalizedMessage(Timeout, Translation.Arguments("player", client.Name));
|
|
server.DropClient(c);
|
|
}
|
|
}
|
|
|
|
if (Game.RunTime - lastConnReport > ConnReportInterval)
|
|
{
|
|
lastConnReport = Game.RunTime;
|
|
|
|
var timeouts = server.Conns
|
|
.Where(c => c.Validated && c.TimeSinceLastResponse > ConnReportInterval && c.TimeSinceLastResponse < ConnTimeout)
|
|
.OrderBy(c => c.TimeSinceLastResponse);
|
|
|
|
foreach (var c in timeouts)
|
|
{
|
|
var client = server.GetClient(c);
|
|
if (client != null)
|
|
{
|
|
var timeout = (ConnTimeout - c.TimeSinceLastResponse) / 1000;
|
|
server.SendLocalizedMessage(TimeoutIn, new Dictionary<string, object>()
|
|
{
|
|
{ "player", client.Name },
|
|
{ "timeout", timeout }
|
|
});
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|