huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Sync shared code from runtime (#24000) 

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
This commit is contained in:
github-actions[bot] 2020-07-16 06:57:05 -07:00 committed by GitHub
parent 763ccb21b5
commit 410eb6db53
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Shared/runtime/Quic/Implementations/Mock/MockConnection.cs
View File

@ -93,7 +93,7 @@ namespace System.Net.Quic.Implementations.Mock
int bytesRead = 0; int bytesRead = 0;
do do
{ {
bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None).ConfigureAwait(false); bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None, cancellationToken).ConfigureAwait(false);
} while (bytesRead != buffer.Length); } while (bytesRead != buffer.Length);
int peerListenPort = BinaryPrimitives.ReadInt32LittleEndian(buffer); int peerListenPort = BinaryPrimitives.ReadInt32LittleEndian(buffer);
@ -163,7 +163,7 @@ namespace System.Net.Quic.Implementations.Mock
int bytesRead = 0; int bytesRead = 0;
do do
{ {
bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None).ConfigureAwait(false); bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None, cancellationToken).ConfigureAwait(false);
} while (bytesRead != buffer.Length); } while (bytesRead != buffer.Length);
long streamId = BinaryPrimitives.ReadInt64LittleEndian(buffer); long streamId = BinaryPrimitives.ReadInt64LittleEndian(buffer);

2
src/Shared/runtime/Quic/Implementations/Mock/MockListener.cs
View File

@ -45,7 +45,7 @@ namespace System.Net.Quic.Implementations.Mock
int bytesRead = 0; int bytesRead = 0;
do do
{ {
bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None).ConfigureAwait(false); bytesRead += await socket.ReceiveAsync(buffer.AsMemory().Slice(bytesRead), SocketFlags.None, cancellationToken).ConfigureAwait(false);
} while (bytesRead != buffer.Length); } while (bytesRead != buffer.Length);
int peerListenPort = BinaryPrimitives.ReadInt32LittleEndian(buffer); int peerListenPort = BinaryPrimitives.ReadInt32LittleEndian(buffer);