Fijxu
/
BattleBit-Community-Server-API
mirror of https://github.com/MrOkiDoki/BattleBit-Community-Server-API.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

All events non blocking

This commit is contained in:
MrOkiDoki 2023-08-11 13:09:54 +03:00
parent 40fa8aa623
commit 98d8ae180f
3 changed files with 39 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
.vs/CommunityServerAPI/FileContentIndex/4bc209c6-45ab-4e70-9a0d-e85e9ce724bb.vsidx
View File

Binary file not shown.

BIN
.vs/CommunityServerAPI/FileContentIndex/4fde6a0c-cacf-49c4-a174-e6359477eec0.vsidx Normal file
View File

Binary file not shown.

42
BattleBitAPI/Server/ServerListener.cs
View File

@ -32,6 +32,33 @@ namespace BattleBitAPI.Server
/// </value>
public Func<IPAddress, Task<bool>> OnGameServerConnecting { get; set; }
/// <summary>
/// Fired when a game server connects.
/// </summary>
///
/// <remarks>
/// GameServer: Game server that is connecting.<br/>
/// </remarks>
public Func<GameServer<TPlayer>, Task> OnGameServerConnected { get; set; }
/// <summary>
/// Fired when a game server reconnects. (When game server connects while a socket is already open)
/// </summary>
///
/// <remarks>
/// GameServer: Game server that is reconnecting.<br/>
/// </remarks>
public Func<GameServer<TPlayer>, Task> OnGameServerReconnected { get; set; }
/// <summary>
/// Fired when a game server disconnects. Check (GameServer.TerminationReason) to see the reason.
/// </summary>
///
/// <remarks>
/// GameServer: Game server that disconnected.<br/>
/// </remarks>
public Func<GameServer<TPlayer>, Task> OnGameServerDisconnected { get; set; }
// --- Private ---
private TcpListener mSocket;
private Dictionary<ulong, (TGameServer server, GameServer<TPlayer>.Internal resources)> mActiveConnections;
@ -523,12 +550,16 @@ namespace BattleBitAPI.Server
if (!connectionExist)
{
//New connection!
await server.OnConnected();
server.OnConnected();
if (this.OnGameServerConnected != null)
this.OnGameServerConnected(server);
}
else
{
//Reconnection
await server.OnReconnected();
server.OnReconnected();
if (this.OnGameServerReconnected != null)
this.OnGameServerReconnected(server);
}
//Set the buffer sizes.
@ -551,7 +582,12 @@ namespace BattleBitAPI.Server
}
if (!server.ReconnectFlag)
await server.OnDisconnected();
{
server.OnDisconnected();
if (this.OnGameServerDisconnected!= null)
this.OnGameServerDisconnected(server);
}
}
//Remove from list.