GitHub/Facepunch.Steamworks
2
0
Fork 0
mirror of https://github.com/Facepunch/Facepunch.Steamworks.git synced 2025-02-26 21:41:19 +03:00
Code Issues Projects Releases Wiki Activity

fixed SourceServerQuery shared buffer errors

Browse Source
This commit is contained in:
Garry Newman 2019-12-06 14:27:38 +00:00
parent 127de84c8c
commit 2e6db5fe37
2 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Facepunch.Steamworks/Utility/SourceServerQuery.cs
View File

@ -32,7 +32,7 @@ namespace Steamworks
} }
catch ( System.Exception e ) catch ( System.Exception e )
{ {
Console.Error.WriteLine( e.Message ); //Console.Error.WriteLine( e.Message );
return null; return null;
} }
} }
@ -54,14 +54,14 @@ namespace Steamworks
var numRules = br.ReadUInt16(); var numRules = br.ReadUInt16();
for ( int index = 0; index < numRules; index++ ) for ( int index = 0; index < numRules; index++ )
{ {
rules.Add( br.ReadNullTerminatedUTF8String( readBuffer ), br.ReadNullTerminatedUTF8String( readBuffer ) ); rules.Add( br.ReadNullTerminatedUTF8String(), br.ReadNullTerminatedUTF8String() );
} }
} }
return rules; return rules;
} }
static byte[] readBuffer = new byte[1024 * 8];
static async Task<byte[]> Receive( UdpClient client ) static async Task<byte[]> Receive( UdpClient client )
{ {
@ -120,10 +120,10 @@ namespace Steamworks
return challengeData; return challengeData;
} }
static byte[] sendBuffer = new byte[1024];
static async Task Send( UdpClient client, byte[] message ) static async Task Send( UdpClient client, byte[] message )
{ {
var sendBuffer = new byte[message.Length + 4];
sendBuffer[0] = 0xFF; sendBuffer[0] = 0xFF;
sendBuffer[1] = 0xFF; sendBuffer[1] = 0xFF;
sendBuffer[2] = 0xFF; sendBuffer[2] = 0xFF;

24
Facepunch.Steamworks/Utility/Utility.cs
View File

@ -80,20 +80,22 @@ namespace Steamworks
} }
} }
public static string ReadNullTerminatedUTF8String( this BinaryReader br, byte[] buffer = null ) static byte[] readBuffer = new byte[1024 * 8];
public static string ReadNullTerminatedUTF8String( this BinaryReader br )
{ {
if ( buffer == null ) lock ( readBuffer )
buffer = new byte[1024];
byte chr;
int i = 0;
while ( (chr = br.ReadByte()) != 0 && i < buffer.Length )
{ {
buffer[i] = chr; byte chr;
i++; int i = 0;
} while ( (chr = br.ReadByte()) != 0 && i < readBuffer.Length )
{
readBuffer[i] = chr;
i++;
}
return Encoding.UTF8.GetString( buffer, 0, i ); return Encoding.UTF8.GetString( readBuffer, 0, i );
}
} }
} }
} }