GitHub/Facepunch.Steamworks
2
0
Fork 0
mirror of https://github.com/Facepunch/Facepunch.Steamworks.git synced 2024-12-26 14:45:51 +03:00
Code Issues Projects Releases Wiki Activity

ISocketManager.OnDisconnected is in charge of calling Connection.Close so custom parameters can be used

Browse Source
This commit is contained in:
André Straubmeier 2020-08-17 13:49:22 +02:00
parent 5fdffff5c4
commit 498c1b9a32
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Facepunch.Steamworks/Networking/ISocketManager.cs
View File

@ -16,7 +16,7 @@ public interface ISocketManager
void OnConnected( Connection connection, ConnectionInfo info ); void OnConnected( Connection connection, ConnectionInfo info );
/// <summary> /// <summary>
/// Called when the connection leaves /// Called when the connection leaves. Must call Close on the connection
/// </summary> /// </summary>
void OnDisconnected( Connection connection, ConnectionInfo info ); void OnDisconnected( Connection connection, ConnectionInfo info );

19
Facepunch.Steamworks/Networking/SocketManager.cs
View File

@ -50,6 +50,7 @@ public virtual void OnConnectionChanged( Connection connection, ConnectionInfo i
if ( !Connecting.Contains( connection ) ) if ( !Connecting.Contains( connection ) )
{ {
Connecting.Add( connection ); Connecting.Add( connection );
OnConnecting( connection, info ); OnConnecting( connection, info );
} }
break; break;
@ -67,6 +68,9 @@ public virtual void OnConnectionChanged( Connection connection, ConnectionInfo i
case ConnectionState.None: case ConnectionState.None:
if ( Connecting.Contains( connection ) || Connected.Contains( connection ) ) if ( Connecting.Contains( connection ) || Connected.Contains( connection ) )
{ {
Connecting.Remove( connection );
Connected.Remove( connection );
OnDisconnected( connection, info ); OnDisconnected( connection, info );
} }
break; break;
@ -81,7 +85,6 @@ public virtual void OnConnecting( Connection connection, ConnectionInfo info )
if ( Interface != null ) if ( Interface != null )
{ {
Interface.OnConnecting( connection, info ); Interface.OnConnecting( connection, info );
return;
} }
else else
{ {
@ -106,12 +109,14 @@ public virtual void OnDisconnected( Connection connection, ConnectionInfo info )
{ {
SteamNetworkingSockets.Internal.SetConnectionPollGroup( connection, 0 ); SteamNetworkingSockets.Internal.SetConnectionPollGroup( connection, 0 );
connection.Close(); if ( Interface != null )
{
Connecting.Remove( connection ); Interface.OnDisconnected( connection, info );
Connected.Remove( connection ); }
else
Interface?.OnDisconnected( connection, info ); {
connection.Close();
}
} }
public void Receive( int bufferSize = 32 ) public void Receive( int bufferSize = 32 )