mirrors/fcast
1
0
Fork 0
mirror of https://gitlab.com/futo-org/fcast.git synced 2025-08-07 17:52:49 +00:00
Code Activity

Added fixes to C# implementation of FCast.

Browse source
This commit is contained in:
Koen 2024-03-06 09:53:33 +01:00
parent ba8cd46e4c
commit 176dcc0a62
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
clients/terminal-dotnet/FCastClient/FCastSession.cs
View file

@ -97,7 +97,7 @@ public class FCastSession : IDisposable
} }
} }
public async Task ReceiveLoopAsync(CancellationToken cancellationToken) public async Task ReceiveLoopAsync(CancellationToken cancellationToken = default)
{ {
Console.WriteLine("Start receiving."); Console.WriteLine("Start receiving.");
_state = SessionState.WaitingForLength; _state = SessionState.WaitingForLength;
@ -150,7 +150,7 @@ public class FCastSession : IDisposable
private async Task HandleLengthBytesAsync(byte[] receivedBytes, int offset, int length, CancellationToken cancellationToken) private async Task HandleLengthBytesAsync(byte[] receivedBytes, int offset, int length, CancellationToken cancellationToken)
{ {
int bytesToRead = Math.Min(LengthBytes, length); int bytesToRead = Math.Min(LengthBytes, length);
Buffer.BlockCopy(receivedBytes, offset, _buffer, 0, bytesToRead); Buffer.BlockCopy(receivedBytes, offset, _buffer, _bytesRead, bytesToRead);
_bytesRead += bytesToRead; _bytesRead += bytesToRead;
Console.WriteLine($"handleLengthBytes: Read {bytesToRead} bytes from packet"); Console.WriteLine($"handleLengthBytes: Read {bytesToRead} bytes from packet");
@ -173,7 +173,7 @@ public class FCastSession : IDisposable
if (length > bytesToRead) if (length > bytesToRead)
{ {
await HandlePacketBytesAsync(receivedBytes, bytesToRead, length - bytesToRead, cancellationToken); await HandlePacketBytesAsync(receivedBytes, offset + bytesToRead, length - bytesToRead, cancellationToken);
} }
} }
} }
@ -181,7 +181,7 @@ public class FCastSession : IDisposable
private async Task HandlePacketBytesAsync(byte[] receivedBytes, int offset, int length, CancellationToken cancellationToken) private async Task HandlePacketBytesAsync(byte[] receivedBytes, int offset, int length, CancellationToken cancellationToken)
{ {
int bytesToRead = Math.Min(_packetLength, length); int bytesToRead = Math.Min(_packetLength, length);
Buffer.BlockCopy(receivedBytes, offset, _buffer, 0, bytesToRead); Buffer.BlockCopy(receivedBytes, offset, _buffer, _bytesRead, bytesToRead);
_bytesRead += bytesToRead; _bytesRead += bytesToRead;
Console.WriteLine($"handlePacketBytes: Read {bytesToRead} bytes from packet"); Console.WriteLine($"handlePacketBytes: Read {bytesToRead} bytes from packet");
@ -197,7 +197,7 @@ public class FCastSession : IDisposable
if (length > bytesToRead) if (length > bytesToRead)
{ {
await HandleLengthBytesAsync(receivedBytes, bytesToRead, length - bytesToRead, cancellationToken); await HandleLengthBytesAsync(receivedBytes, offset + bytesToRead, length - bytesToRead, cancellationToken);
} }
} }
} }