From 6ee3d1640fe4b36e8ffc9094497571f0b460e6f5 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Sun, 23 Jun 2019 15:57:12 +0200 Subject: [PATCH] Improve logging. --- Source/MQTTnet/Server/MqttClientConnection.cs | 5 ++--- Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs | 3 ++- Source/MQTTnet/Server/MqttClientSessionsManager.cs | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/Source/MQTTnet/Server/MqttClientConnection.cs b/Source/MQTTnet/Server/MqttClientConnection.cs index 5ede2c66..ed378bb1 100644 --- a/Source/MQTTnet/Server/MqttClientConnection.cs +++ b/Source/MQTTnet/Server/MqttClientConnection.cs @@ -7,6 +7,7 @@ using MQTTnet.Client; using MQTTnet.Diagnostics; using MQTTnet.Exceptions; using MQTTnet.Formatter; +using MQTTnet.Internal; using MQTTnet.PacketDispatcher; using MQTTnet.Packets; using MQTTnet.Protocol; @@ -134,9 +135,7 @@ namespace MQTTnet.Server Session.WillMessage = _connectPacket.WillMessage; -#pragma warning disable 4014 - Task.Run(() => SendPendingPacketsAsync(_cancellationToken.Token), _cancellationToken.Token); -#pragma warning restore 4014 + Task.Run(() => SendPendingPacketsAsync(_cancellationToken.Token), _cancellationToken.Token).Forget(_logger); // TODO: Change to single thread in SessionManager. Or use SessionManager and stats from KeepAliveMonitor. _keepAliveMonitor.Start(_connectPacket.KeepAlivePeriod, _cancellationToken.Token); diff --git a/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs b/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs index 32effed4..deefe4ce 100644 --- a/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs +++ b/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs @@ -3,6 +3,7 @@ using System.Diagnostics; using System.Threading; using System.Threading.Tasks; using MQTTnet.Diagnostics; +using MQTTnet.Internal; namespace MQTTnet.Server { @@ -32,7 +33,7 @@ namespace MQTTnet.Server return; } - Task.Run(() => RunAsync(keepAlivePeriod, cancellationToken), cancellationToken).ConfigureAwait(false); + Task.Run(() => RunAsync(keepAlivePeriod, cancellationToken), cancellationToken).Forget(_logger); } public void Pause() diff --git a/Source/MQTTnet/Server/MqttClientSessionsManager.cs b/Source/MQTTnet/Server/MqttClientSessionsManager.cs index b18f4144..c2d56370 100644 --- a/Source/MQTTnet/Server/MqttClientSessionsManager.cs +++ b/Source/MQTTnet/Server/MqttClientSessionsManager.cs @@ -47,7 +47,7 @@ namespace MQTTnet.Server public void Start() { - Task.Run(() => TryProcessQueuedApplicationMessagesAsync(_cancellationToken), _cancellationToken); + Task.Run(() => TryProcessQueuedApplicationMessagesAsync(_cancellationToken), _cancellationToken).Forget(_logger); } public async Task StopAsync()