FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-01-31 18:59:33 +00:00
Code Issues Releases Wiki Activity

00_MQTT2_CLIENT.pm: check for PINGRESP (Forum #103347)

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@20081 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
rudolfkoenig 2019-08-30 11:12:48 +00:00
parent 9f59e9ab31
commit 17f649319e
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fhem/FHEM/00_MQTT2_CLIENT.pm
View File

@ -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;