sem/Proftaak-RH-B4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rewrote OnRead

Browse Source
This commit is contained in:
shinichi
2020-09-25 12:58:12 +02:00
parent 2139fcf2b2
commit 96f2e6e973
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
Server/Client.cs
View File

@@ -37,30 +37,28 @@ namespace Server
Array.Copy(buffer, 0, totalBuffer, totalBufferReceived, receivedBytes); Array.Copy(buffer, 0, totalBuffer, totalBufferReceived, receivedBytes);
totalBufferReceived += receivedBytes; totalBufferReceived += receivedBytes;
int expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0); int expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
while (totalBufferReceived >= expectedMessageLength) while (totalBufferReceived >= expectedMessageLength)
{ {
//volledig packet binnen //volledig packet binnen
byte[] packetBytes = new byte[expectedMessageLength]; byte[] messageBytes = new byte[expectedMessageLength];
Array.Copy(totalBuffer, 5, packetBytes, 0, expectedMessageLength - 5); Array.Copy(totalBuffer, 0, messageBytes, 0, expectedMessageLength);
HandleData(messageBytes);
//Array.Copy(totalBuffer, expectedMessageLength, totalBuffer, 0, (totalBufferReceived - expectedMessageLength)); //maybe unsafe idk
totalBuffer = totalBuffer.Skip(expectedMessageLength).ToArray();
Console.WriteLine(Encoding.ASCII.GetString(packetBytes) + " " + expectedMessageLength);
Array.Copy(totalBuffer, expectedMessageLength, totalBuffer, 0, (totalBufferReceived - expectedMessageLength));
totalBufferReceived -= expectedMessageLength; totalBufferReceived -= expectedMessageLength;
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0); expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
} }
this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null); this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null);
} }
/// <summary>
/// TODO
/// </summary>
/// <param name="message">including message length and messageId (can be changed)</param>
private void HandleData(byte[] message) private void HandleData(byte[] message)
{ {
//Console.WriteLine("Data " + packet); //Console.WriteLine("Data " + packet);