GameCult/CultLib
Watch
9
0
Fork
You've already forked CultLib
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Expose TCP schema host health

Browse source
This commit is contained in:
Meta Vens 2026-07-19 18:53:08 +01:00
commit 638b33b830
1 changed files with 17 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/GameCult.Networking/CultNetTcpSchemaTransport.cs
View file

@ -110,6 +110,8 @@ namespace GameCult.Networking
private readonly ConcurrentDictionary<Type, Delegate> _handlers = new();
private readonly ConcurrentDictionary<TcpPeer, byte> _peers = new();
private readonly CancellationTokenSource _shutdown = new();
private readonly TaskCompletionSource<Exception> _backgroundFailure = new(
TaskCreationOptions.RunContinuationsAsynchronously);
private bool _disposed;
public TcpFramedCultNetSchemaServer(TcpListener listener)
@ -120,7 +122,14 @@ namespace GameCult.Networking
}
public event Action<ICultNetSchemaServerPeer>? PeerDisconnected;
/// <summary>Raised when one peer connection fails without stopping the listener.</summary>
public event Action<EndPoint?, Exception>? PeerFailed;
/// <summary>Gets the bound TCP endpoint.</summary>
public IPEndPoint LocalEndPoint => (IPEndPoint)_listener.LocalEndpoint;
/// <summary>Gets the number of active TCP peers.</summary>
public int PeerCount => _peers.Count;
/// <summary>Completes if the background accept loop fails.</summary>
public Task<Exception> BackgroundFailure => _backgroundFailure.Task;
public void OnCultNet<TMessage>(Func<TMessage, ICultNetSchemaServerPeer, Task> callback)
where TMessage : ICultNetSchemaMessage
@ -162,6 +171,10 @@ namespace GameCult.Networking
catch (Exception) when (_disposed || cancellationToken.IsCancellationRequested)
{
}
catch (Exception error)
{
_backgroundFailure.TrySetResult(error);
}
}
private async Task ServePeerAsync(TcpPeer peer, CancellationToken cancellationToken)
@ -182,6 +195,10 @@ namespace GameCult.Networking
catch (Exception) when (_disposed || cancellationToken.IsCancellationRequested || !peer.Connected)
{
}
catch (Exception error)
{
PeerFailed?.Invoke(peer.RemoteEndPoint, error);
}
finally
{
if (_peers.TryRemove(peer, out _)) PeerDisconnected?.Invoke(peer);