From 066f2add226c29ffaa4d2a5950f766a24cedb7ca Mon Sep 17 00:00:00 2001
From: rudolfkoenig <rudolfkoenig@2b470e98-0d58-463d-a4d8-8e2adae1ed80>
Date: Fri, 30 Aug 2019 11:12:48 +0000
Subject: [PATCH] 00_MQTT2_CLIENT.pm: check for PINGRESP (Forum #103347)

git-svn-id: https://svn.fhem.de/fhem/trunk@20081 2b470e98-0d58-463d-a4d8-8e2adae1ed80
---
 fhem/FHEM/00_MQTT2_CLIENT.pm | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/fhem/FHEM/00_MQTT2_CLIENT.pm b/fhem/FHEM/00_MQTT2_CLIENT.pm
index f8f3c84e3..d08231745 100644
--- a/fhem/FHEM/00_MQTT2_CLIENT.pm
+++ b/fhem/FHEM/00_MQTT2_CLIENT.pm
@@ -154,11 +154,17 @@ MQTT2_CLIENT_keepalive($)
 {
   my ($hash) = @_;
   my $name = $hash->{NAME};
+  if($hash->{waitingForPingRespSince}) {
+    Log3 $name, 2, "$hash->{NAME}: No PINGRESP for last PINGREQ (".
+            "at $hash->{waitingForPingRespSince}), disconnecting";
+    delete $hash->{waitingForPingRespSince};
+    return  MQTT2_CLIENT_Disco($hash);
+  }
   my $keepalive = AttrVal($name, "keepaliveTimeout", 30);
   $keepalive = 30 if($keepalive !~ m/^[0-9]+$/);
   return if(ReadingsVal($name, "state", "") ne "opened" || $hash->{connecting});
-  Log3 $name, 5, "$name: keepalive $keepalive";
   MQTT2_CLIENT_send($hash, pack("C",0xC0).pack("C",0)); # PINGREQ
+  $hash->{waitingForPingRespSince} = TimeNow();
   InternalTimer(gettimeofday()+$keepalive, "MQTT2_CLIENT_keepalive", $hash, 0);
 }
 
@@ -330,7 +336,9 @@ MQTT2_CLIENT_Read($@)
         if($onc && $onc =~ m/^(-r\s)?([^\s]*)\s*(.*)$/);
     }
 
-  } elsif($cpt eq "PINGRESP") { # ignore it
+  } elsif($cpt eq "PINGRESP") {
+    delete($hash->{waitingForPingRespSince});
+    
   } elsif($cpt eq "PUBLISH")  {
     my $cf = ord(substr($fb,0,1)) & 0xf;
     my $qos = ($cf & 0x06) >> 1;