YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-11-03 21:16:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

dont use byte reader writer in critical paths

Browse Source
This commit is contained in:
Eggers Jan
2017-09-13 09:10:41 +02:00
parent c001897590
commit 323339b0b2
2 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MQTTnet.Core/Serializer/MqttPacketReader.cs
+1 -3
View File
@@ -52,9 +52,7 @@ namespace MQTTnet.Core.Serializer
public static MqttPacketHeader ReadHeaderFromSource(Stream stream) public static MqttPacketHeader ReadHeaderFromSource(Stream stream)
{ {
var fixedHeader = (byte)stream.ReadByte(); var fixedHeader = (byte)stream.ReadByte();
var byteReader = new ByteReader(fixedHeader); var controlPacketType = (MqttControlPacketType)(fixedHeader >> 4);
byteReader.Read(4);
var controlPacketType = (MqttControlPacketType)byteReader.Read(4);
var bodyLength = ReadBodyLengthFromSource(stream); var bodyLength = ReadBodyLengthFromSource(stream);
return new MqttPacketHeader() return new MqttPacketHeader()
MQTTnet.Core/Serializer/MqttPacketSerializer.cs
+14 -5
View File
@@ -512,12 +512,21 @@ namespace MQTTnet.Core.Serializer
writer.Write(packet.Payload); writer.Write(packet.Payload);
} }
var fixedHeader = new ByteWriter(); byte fixedHeader = 0;
fixedHeader.Write(packet.Retain);
fixedHeader.Write((byte)packet.QualityOfServiceLevel, 2);
fixedHeader.Write(packet.Dup);
return MqttPacketWriter.BuildFixedHeader(MqttControlPacketType.Publish, fixedHeader.Value); if (packet.Retain)
{
fixedHeader |= 0x01;
}
fixedHeader |= (byte)((byte)packet.QualityOfServiceLevel << 1);
if ( packet.Dup )
{
fixedHeader |= 0x08;
}
return MqttPacketWriter.BuildFixedHeader(MqttControlPacketType.Publish, fixedHeader);
} }
private static byte Serialize(MqttPubAckPacket packet, MqttPacketWriter writer) private static byte Serialize(MqttPubAckPacket packet, MqttPacketWriter writer)