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

MsgPack perf (#1845)

This commit is contained in:
BrennanConroy 2018-04-04 07:11:16 -07:00 committed by GitHub
parent e7b84b753b
commit afa56e3012
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Microsoft.AspNetCore.SignalR.Protocols.MsgPack/Internal/Protocol/MessagePackHubProtocol.cs
View File

@ -322,7 +322,11 @@ namespace Microsoft.AspNetCore.SignalR.Internal.Protocol
packer.PackString(message.InvocationId); packer.PackString(message.InvocationId);
} }
packer.PackString(message.Target); packer.PackString(message.Target);
packer.PackObject(message.Arguments, SerializationContext); packer.PackArrayHeader(message.Arguments.Length);
foreach (var arg in message.Arguments)
{
packer.PackObject(arg, SerializationContext);
}
} }
private void WriteStreamInvocationMessage(StreamInvocationMessage message, Packer packer) private void WriteStreamInvocationMessage(StreamInvocationMessage message, Packer packer)
@ -332,7 +336,11 @@ namespace Microsoft.AspNetCore.SignalR.Internal.Protocol
PackHeaders(packer, message.Headers); PackHeaders(packer, message.Headers);
packer.PackString(message.InvocationId); packer.PackString(message.InvocationId);
packer.PackString(message.Target); packer.PackString(message.Target);
packer.PackObject(message.Arguments, SerializationContext); packer.PackArrayHeader(message.Arguments.Length);
foreach (var arg in message.Arguments)
{
packer.PackObject(arg, SerializationContext);
}
} }
private void WriteStreamingItemMessage(StreamItemMessage message, Packer packer) private void WriteStreamingItemMessage(StreamItemMessage message, Packer packer)