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

Improve logging.

Browse Source
This commit is contained in:
Christian Kratky
2019-06-23 15:57:12 +02:00
parent 6f8272210c
commit 6ee3d1640f
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientConnection.cs
+2 -3
View File
@@ -7,6 +7,7 @@ using MQTTnet.Client;
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using MQTTnet.Exceptions; using MQTTnet.Exceptions;
using MQTTnet.Formatter; using MQTTnet.Formatter;
using MQTTnet.Internal;
using MQTTnet.PacketDispatcher; using MQTTnet.PacketDispatcher;
using MQTTnet.Packets; using MQTTnet.Packets;
using MQTTnet.Protocol; using MQTTnet.Protocol;
@@ -134,9 +135,7 @@ namespace MQTTnet.Server
Session.WillMessage = _connectPacket.WillMessage; Session.WillMessage = _connectPacket.WillMessage;
#pragma warning disable 4014 Task.Run(() => SendPendingPacketsAsync(_cancellationToken.Token), _cancellationToken.Token).Forget(_logger);
Task.Run(() => SendPendingPacketsAsync(_cancellationToken.Token), _cancellationToken.Token);
#pragma warning restore 4014
// TODO: Change to single thread in SessionManager. Or use SessionManager and stats from KeepAliveMonitor. // TODO: Change to single thread in SessionManager. Or use SessionManager and stats from KeepAliveMonitor.
_keepAliveMonitor.Start(_connectPacket.KeepAlivePeriod, _cancellationToken.Token); _keepAliveMonitor.Start(_connectPacket.KeepAlivePeriod, _cancellationToken.Token);
Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs
+2 -1
View File
@@ -3,6 +3,7 @@ using System.Diagnostics;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using MQTTnet.Internal;
namespace MQTTnet.Server namespace MQTTnet.Server
{ {
@@ -32,7 +33,7 @@ namespace MQTTnet.Server
return; return;
} }
Task.Run(() => RunAsync(keepAlivePeriod, cancellationToken), cancellationToken).ConfigureAwait(false); Task.Run(() => RunAsync(keepAlivePeriod, cancellationToken), cancellationToken).Forget(_logger);
} }
public void Pause() public void Pause()
Source/MQTTnet/Server/MqttClientSessionsManager.cs
+1 -1
View File
@@ -47,7 +47,7 @@ namespace MQTTnet.Server
public void Start() public void Start()
{ {
Task.Run(() => TryProcessQueuedApplicationMessagesAsync(_cancellationToken), _cancellationToken); Task.Run(() => TryProcessQueuedApplicationMessagesAsync(_cancellationToken), _cancellationToken).Forget(_logger);
} }
public async Task StopAsync() public async Task StopAsync()