Backups/RAGECOOP-V
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Small fix

Browse Source
This commit is contained in:
EntenKoeniq
2022-04-11 14:22:51 +02:00
parent 0bcca6b3af
commit 625ae2aa7b
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
Server/DownloadManager.cs
View File

@ -135,7 +135,7 @@ namespace CoopServer
/// We try to remove the client when all files have been sent /// We try to remove the client when all files have been sent
/// </summary> /// </summary>
/// <param name="nethandle"></param> /// <param name="nethandle"></param>
/// <param name="id">Not currently used but maybe we can need this sometime</param> /// <param name="id"></param>
public static void TryToRemoveClient(long nethandle, int id) public static void TryToRemoveClient(long nethandle, int id)
{ {
lock (_clients) lock (_clients)
@ -146,12 +146,14 @@ namespace CoopServer
return; return;
} }
if (client.IsCurrentFile(id))
{
client.FilePosition++; client.FilePosition++;
}
if (client.DownloadComplete()) if (client.DownloadComplete())
{ {
client.Finish(); AddClientToRemove(client.NetHandle);
_clients.Remove(client);
} }
} }
} }
@ -159,11 +161,14 @@ namespace CoopServer
public static void AddClientToRemove(long nethandle) public static void AddClientToRemove(long nethandle)
{ {
lock (_clientsToDelete) lock (_clientsToDelete)
{
if (!_clientsToDelete.Contains(nethandle))
{ {
_clientsToDelete.Add(nethandle); _clientsToDelete.Add(nethandle);
} }
} }
} }
}
internal class DownloadClient internal class DownloadClient
{ {
@ -253,6 +258,11 @@ namespace CoopServer
Server.MainNetServer.SendMessage(outgoingMessage, conn, NetDeliveryMethod.ReliableUnordered, (byte)ConnectionChannel.File); Server.MainNetServer.SendMessage(outgoingMessage, conn, NetDeliveryMethod.ReliableUnordered, (byte)ConnectionChannel.File);
} }
public bool IsCurrentFile(int id)
{
return _files[FilePosition].FileID == id;
}
public bool DownloadComplete() public bool DownloadComplete()
{ {
return FilePosition >= _files.Count; return FilePosition >= _files.Count;