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

Cache property access (#2030)

This commit is contained in:
BrennanConroy 2018-04-15 23:23:00 -07:00 committed by GitHub
parent 4f4dfe1d23
commit 927b08f893
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Microsoft.AspNetCore.SignalR.Core/HubConnectionHandler.cs
View File

@ -169,16 +169,18 @@ namespace Microsoft.AspNetCore.SignalR
try try
{ {
var input = connection.Input;
var protocol = connection.Protocol;
while (true) while (true)
{ {
var result = await connection.Input.ReadAsync(connection.ConnectionAborted); var result = await input.ReadAsync(connection.ConnectionAborted);
var buffer = result.Buffer; var buffer = result.Buffer;
try try
{ {
if (!buffer.IsEmpty) if (!buffer.IsEmpty)
{ {
while (connection.Protocol.TryParseMessage(ref buffer, _dispatcher, out var message)) while (protocol.TryParseMessage(ref buffer, _dispatcher, out var message))
{ {
// Don't wait on the result of execution, continue processing other // Don't wait on the result of execution, continue processing other
// incoming messages on this connection. // incoming messages on this connection.
@ -195,7 +197,7 @@ namespace Microsoft.AspNetCore.SignalR
// The buffer was sliced up to where it was consumed, so we can just advance to the start. // The buffer was sliced up to where it was consumed, so we can just advance to the start.
// We mark examined as buffer.End so that if we didn't receive a full frame, we'll wait for more data // We mark examined as buffer.End so that if we didn't receive a full frame, we'll wait for more data
// before yielding the read again. // before yielding the read again.
connection.Input.AdvanceTo(buffer.Start, buffer.End); input.AdvanceTo(buffer.Start, buffer.End);
} }
} }
} }