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

Merge branch 'Fix-high-CPU-usage'

Browse Source
This commit is contained in:
Christian
2022-07-12 11:57:03 +02:00
parent b10a69a0ae 76e54dc49b
commit 422945929e
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/ReleaseNotes.md
+2 -1
View File
@@ -3,4 +3,5 @@
* [ManagedClient] The managed client now sends the entire topic filter including new MQTTv5 properties when subscribing. * [ManagedClient] The managed client now sends the entire topic filter including new MQTTv5 properties when subscribing.
* [Server] Fixed reporting of _MaximumQoS_ in _ConnAck_ packet (MQTTv5 only) (#1442). * [Server] Fixed reporting of _MaximumQoS_ in _ConnAck_ packet (MQTTv5 only) (#1442).
* [Server] Fix cross thread issue in session message storage for QoS 1 and 2. * [Server] Fix cross thread issue in session message storage for QoS 1 and 2.
* [Server] The event _ClientSubscribedTopicAsync_ is now fired after the subscription is completely processed internally (#1435). * [Server] The event _ClientSubscribedTopicAsync_ is now fired after the subscription is completely processed internally (#1435).
* [Server] Improved CPU usage on lower end machines (#788).
Source/MQTTnet/Server/Internal/MqttClient.cs
+6
View File
@@ -188,6 +188,8 @@ namespace MQTTnet.Server
// own exception in the reading loop! // own exception in the reading loop!
while (!cancellationToken.IsCancellationRequested) while (!cancellationToken.IsCancellationRequested)
{ {
await Task.Yield();
var packet = await ChannelAdapter.ReceivePacketAsync(cancellationToken).ConfigureAwait(false); var packet = await ChannelAdapter.ReceivePacketAsync(cancellationToken).ConfigureAwait(false);
if (packet == null) if (packet == null)
{ {
@@ -315,6 +317,10 @@ namespace MQTTnet.Server
{ {
packetBusItem.MarkAsFailed(exception); packetBusItem.MarkAsFailed(exception);
} }
finally
{
await Task.Yield();
}
} }
} }
catch (OperationCanceledException) catch (OperationCanceledException)