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

Fix build warnings.

Browse Source
This commit is contained in:
Christian
2021-12-01 20:28:59 +01:00
parent 2da2658035
commit 2d1b4b68e6
3 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Build/build.ps1
+1 -2
View File
@@ -13,8 +13,7 @@ Write-Host "MSBuild path = $msbuild"
Write-Host Write-Host
# Cleanup # Cleanup
Remove-Item -Path ".\..\" -Filter "*.nupkg" Get-ChildItem -Path ".\..\" -Filter "*.nupkg" -Recurse | Remove-Item
Remove-Item -Path ".\..\" -Filter "*.snupkg"
# Build and execute tests # Build and execute tests
&$msbuild ..\Tests\MQTTnet.Core.Tests\MQTTnet.Tests.csproj /t:Clean /t:Restore /t:Build /p:Configuration="Release" /p:TargetFramework="net5.0" /verbosity:m &$msbuild ..\Tests\MQTTnet.Core.Tests\MQTTnet.Tests.csproj /t:Clean /t:Restore /t:Build /p:Configuration="Release" /p:TargetFramework="net5.0" /verbosity:m
Source/MQTTnet/Implementations/MqttTcpServerAdapter.Uwp.cs
+9 -7
View File
@@ -13,9 +13,8 @@ namespace MQTTnet.Implementations
{ {
public sealed class MqttTcpServerAdapter : IMqttServerAdapter public sealed class MqttTcpServerAdapter : IMqttServerAdapter
{ {
readonly MqttNetSourceLogger _logger; MqttNetSourceLogger _logger;
readonly IMqttNetLogger _rootLogger;
MqttServerOptions _options; MqttServerOptions _options;
StreamSocketListener _listener; StreamSocketListener _listener;
@@ -25,8 +24,11 @@ namespace MQTTnet.Implementations
{ {
if (_listener != null) throw new InvalidOperationException("Server is already started."); if (_listener != null) throw new InvalidOperationException("Server is already started.");
if (logger is null) throw new ArgumentNullException(nameof(logger));
_logger = logger.WithSource(nameof(MqttTcpServerAdapter));
_options = options ?? throw new ArgumentNullException(nameof(options)); _options = options ?? throw new ArgumentNullException(nameof(options));
if (options.DefaultEndpointOptions.IsEnabled) if (options.DefaultEndpointOptions.IsEnabled)
{ {
_listener = new StreamSocketListener(); _listener = new StreamSocketListener();
@@ -36,7 +38,7 @@ namespace MQTTnet.Implementations
_listener.Control.KeepAlive = true; _listener.Control.KeepAlive = true;
_listener.Control.QualityOfService = SocketQualityOfService.LowLatency; _listener.Control.QualityOfService = SocketQualityOfService.LowLatency;
_listener.ConnectionReceived += OnConnectionReceivedAsync; _listener.ConnectionReceived += OnConnectionReceivedAsync;
await _listener.BindServiceNameAsync(options.DefaultEndpointOptions.Port.ToString(), SocketProtectionLevel.PlainSocket); await _listener.BindServiceNameAsync(options.DefaultEndpointOptions.Port.ToString(), SocketProtectionLevel.PlainSocket);
} }
@@ -82,7 +84,7 @@ namespace MQTTnet.Implementations
_logger.Warning(exception, "Unable to convert UWP certificate to X509Certificate2."); _logger.Warning(exception, "Unable to convert UWP certificate to X509Certificate2.");
} }
} }
using (var clientAdapter = new MqttChannelAdapter(new MqttTcpChannel(args.Socket, clientCertificate, _options), new MqttPacketFormatterAdapter(new MqttPacketWriter()), null, _rootLogger)) using (var clientAdapter = new MqttChannelAdapter(new MqttTcpChannel(args.Socket, clientCertificate, _options), new MqttPacketFormatterAdapter(new MqttPacketWriter()), null, _rootLogger))
{ {
await clientHandler(clientAdapter).ConfigureAwait(false); await clientHandler(clientAdapter).ConfigureAwait(false);
@@ -106,7 +108,7 @@ namespace MQTTnet.Implementations
args.Socket.Dispose(); args.Socket.Dispose();
} }
catch (Exception exception) catch (Exception exception)
{ {
_logger.Error(exception, "Error while cleaning up client connection."); _logger.Error(exception, "Error while cleaning up client connection.");
} }
} }
Source/MQTTnet/Implementations/MqttTcpServerAdapter.cs
+1 -1
View File
@@ -1,4 +1,4 @@
#if !WINDOWS_UWP #if !WINDOWS_UWP
using MQTTnet.Adapter; using MQTTnet.Adapter;
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using MQTTnet.Server; using MQTTnet.Server;