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

Apply timeout to automatic ping. (#1495)

Browse Source 
Co-authored-by: Stan Wijckmans <stanw@aviobook.aero>
This commit is contained in:
Stan Wijckmans
2022-08-13 12:53:55 +02:00
committed by GitHub
co-authored by Stan Wijckmans
parent 12dd815421
commit c5cec60809
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Client/MqttClient.cs
+5 -1
View File
@@ -523,7 +523,11 @@ namespace MQTTnet.Client
if (timeWithoutPacketSent > keepAlivePeriod) if (timeWithoutPacketSent > keepAlivePeriod)
{ {
await PingAsync(cancellationToken).ConfigureAwait(false); using (var timeoutCancellationTokenSource = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken))
{
timeoutCancellationTokenSource.CancelAfter(Options.Timeout);
await PingAsync(timeoutCancellationTokenSource.Token).ConfigureAwait(false);
}
} }
// Wait a fixed time in all cases. Calculation of the remaining time is complicated // Wait a fixed time in all cases. Calculation of the remaining time is complicated