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: "dynamic" packet identifier (Forum #91304)

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@22280 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
rudolfkoenig 2020-06-27 09:14:04 +00:00
parent fe6d2b9e10
commit d6e70552ab
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fhem/FHEM/00_MQTT2_CLIENT.pm
View File

@ -258,6 +258,7 @@ MQTT2_CLIENT_Attr(@)
return "qosMaxQueueLength must be an integer" if($param[0] !~ m/^\d+$/);
$hash->{qosMaxQueueLength} = $param[0];
$hash->{qosQueue} = [];
$hash->{qosCnt} = 0;
} else {
delete $hash->{qosQueue};
delete $hash->{qosMaxQueueLength};
@ -424,6 +425,7 @@ MQTT2_CLIENT_Read($@)
######################################
# send topic to client if its subscriptions matches the topic
sub
MQTT2_CLIENT_doPublish($@)
{
@ -439,7 +441,7 @@ MQTT2_CLIENT_doPublish($@)
@{$hash->{qosQueue}} < $hash->{qosMaxQueueLength}) {
$hdr += 2; # QoS:1
push(@{$hash->{qosQueue}}, [$topic,$val,$retain]);
$pi = "FM"; # Packet Identifier, if QoS > 0
$pi = pack("n",1+($hash->{qosCnt}++%65535)); # Packet Identifier, if QoS > 0
}
my $msg = pack("C", $hdr).
MQTT2_CLIENT_calcRemainingLength(2+length($topic)+length($val)+
@ -468,7 +470,7 @@ MQTT2_CLIENT_send($$;$$)
if($immediate) {
DevIo_SimpleWrite($hash, $msg, 0);
} else {
addToWritebuffer($hash, $msg);
addToWritebuffer($hash, $msg, undef, 1); # nolimit
}
}