demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-10 07:02:02 +01:00
Code Issues Packages Projects Releases Wiki Activity

[insteon] Fix legacy all link broadcast message not processed (#18049)

Browse Source 
Signed-off-by: Jeremy Setton <jeremy.setton@gmail.com>
This commit is contained in:
Jeremy 2025-01-06 07:08:17 -05:00 committed by GitHub
parent b4bcf802f4
commit 19ca89c301
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/InsteonLegacyBinding.java
View File

@ -514,7 +514,7 @@ public class InsteonLegacyBinding implements LegacyDriverListener, LegacyPortLis
private void handleInsteonMessage(Msg msg) throws FieldException { private void handleInsteonMessage(Msg msg) throws FieldException {
InsteonAddress toAddr = msg.getInsteonAddress("toAddress"); InsteonAddress toAddr = msg.getInsteonAddress("toAddress");
if (!msg.isBroadcast() && !driver.isMsgForUs(toAddr)) { if (!msg.isBroadcast() && !msg.isAllLinkBroadcast() && !driver.isMsgForUs(toAddr)) {
// not for one of our modems, do not process // not for one of our modems, do not process
return; return;
} }

4
bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/device/LegacyDevice.java
View File

@ -334,7 +334,7 @@ public class LegacyDevice {
if (qe == null) { if (qe == null) {
return 0L; return 0L;
} }
if (!qe.getMsg().isBroadcast()) { if (!qe.getMsg().isAllLinkBroadcast()) {
logger.debug("qe taken off direct: {} {}", qe.getFeature(), qe.getMsg()); logger.debug("qe taken off direct: {} {}", qe.getFeature(), qe.getMsg());
lastQueryTime = timeNow; lastQueryTime = timeNow;
// mark feature as pending // mark feature as pending
@ -382,7 +382,7 @@ public class LegacyDevice {
synchronized (mrequestQueue) { synchronized (mrequestQueue) {
mrequestQueue.add(new QEntry(feature, msg, now + delay)); mrequestQueue.add(new QEntry(feature, msg, now + delay));
} }
if (!msg.isBroadcast()) { if (!msg.isAllLinkBroadcast()) {
msg.setQuietTime(QUIET_TIME_DIRECT_MESSAGE); msg.setQuietTime(QUIET_TIME_DIRECT_MESSAGE);
} }
logger.trace("enqueing direct message with delay {}", delay); logger.trace("enqueing direct message with delay {}", delay);