GitHub/Facepunch.Steamworks
2
0
Fork 0
mirror of https://github.com/Facepunch/Facepunch.Steamworks.git synced 2024-10-16 23:37:02 +03:00
Code Issues Projects Releases Wiki Activity

Optimized Networking

Browse Source
This commit is contained in:
Garry Newman 2016-11-03 12:09:35 +00:00
parent 480daeb673
commit 44dcf4d150
3 changed files with 44 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Facepunch.Steamworks.Test/Client/Client.cs
View File

@ -90,11 +90,15 @@ public void VoiceOptimalSampleRate()
[TestMethod]
public void Update()
{
var sw = new Stopwatch();
using ( var client = new Facepunch.Steamworks.Client( 252490 ) )
{
for( int i=0; i<1024; i++ )
{
sw.Restart();
client.Update();
Console.WriteLine( $"{sw.Elapsed.TotalMilliseconds}ms" );
}
}
}

5
Facepunch.Steamworks.Test/Client/Networking.cs
View File

@ -21,6 +21,11 @@ public void PeerToPeerSend()
var OutputReceived = false;
var data = Encoding.UTF8.GetBytes( TestString );
//
// Enable listening on this channel
//
client.Networking.SetListenChannel( 0, true );
client.Networking.OnP2PData = ( steamid, ms, channel ) =>
{
var str = Encoding.UTF8.GetString( ms.GetBuffer() );

50
Facepunch.Steamworks/Interfaces/Networking.cs
View File

@ -12,6 +12,10 @@ public class Networking : IDisposable
public Func<ulong, bool> OnIncomingConnection;
public Action<ulong, SessionError> OnConnectionFailed;
private List<int> ListenChannels = new List<int>();
private MemoryStream ReceiveBuffer = new MemoryStream();
internal SteamNative.SteamNetworking networking;
internal Networking( BaseSteamworks steamworks, SteamNative.SteamNetworking networking )
@ -29,23 +33,39 @@ public void Dispose()
OnIncomingConnection = null;
OnConnectionFailed = null;
OnP2PData = null;
ListenChannels.Clear();
}
internal void Update()
{
for ( int i = 0; i < 32; i++ )
if ( OnP2PData == null )
return;
foreach ( var channel in ListenChannels )
{
// POOL ME
using ( var ms = new MemoryStream() )
while ( ReadP2PPacket( channel ) )
{
while( ReadP2PPacket( ms, i ) )
{
// Nothing Here.
}
// Nothing Here.
}
}
}
/// <summary>
/// Enable or disable listening on a specific channel.
/// If you donp't enable the channel we won't listen to it,
/// so you won't be able to receive messages on it.
/// </summary>
public void SetListenChannel( int ChannelId, bool Listen )
{
ListenChannels.RemoveAll( x => x == ChannelId );
if ( Listen )
{
ListenChannels.Add( ChannelId );
}
}
private void onP2PConnectionRequest( SteamNative.P2PSessionRequest_t o, bool b )
{
if ( OnIncomingConnection != null )
@ -132,28 +152,28 @@ public unsafe bool SendP2PPacket( ulong steamid, byte[] data, int length, SendTy
}
}
private unsafe bool ReadP2PPacket( MemoryStream ms, int channel = 0 )
private unsafe bool ReadP2PPacket( int channel )
{
uint DataAvailable = 0;
if ( !networking.IsP2PPacketAvailable( out DataAvailable, channel ) || DataAvailable == 0 )
return false;
if ( ms.Capacity < DataAvailable )
ms.Capacity = (int) DataAvailable;
if ( ReceiveBuffer.Capacity < DataAvailable )
ReceiveBuffer.Capacity = (int) DataAvailable;
ms.Position = 0;
ms.SetLength( DataAvailable );
ReceiveBuffer.Position = 0;
ReceiveBuffer.SetLength( DataAvailable );
fixed ( byte* p = ms.GetBuffer() )
fixed ( byte* p = ReceiveBuffer.GetBuffer() )
{
SteamNative.CSteamID steamid = 1;
if ( !networking.ReadP2PPacket( (IntPtr)p, (uint)DataAvailable, out DataAvailable, out steamid, channel ) || DataAvailable == 0 )
return false;
ms.SetLength( DataAvailable );
ReceiveBuffer.SetLength( DataAvailable );
OnP2PData?.Invoke( steamid, ms, channel );
OnP2PData?.Invoke( steamid, ReceiveBuffer, channel );
return true;
}
}