Skip to content

Commit

Permalink
[insteon] Fix legacy all link broadcast message not processed (#18049)
Browse files Browse the repository at this point in the history
Signed-off-by: Jeremy Setton <jeremy.setton@gmail.com>
  • Loading branch information
jsetton authored and lsiepel committed Jan 6, 2025
1 parent b0560d7 commit cac757a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -517,7 +517,7 @@ public void disconnected() {

private void handleInsteonMessage(Msg msg) throws FieldException {
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
return;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -336,7 +336,7 @@ public long processRequestQueue(long timeNow) {
if (qe == null) {
return 0L;
}
if (!qe.getMsg().isBroadcast()) {
if (!qe.getMsg().isAllLinkBroadcast()) {
logger.debug("qe taken off direct: {} {}", qe.getFeature(), qe.getMsg());
lastQueryTime = timeNow;
// mark feature as pending
Expand Down Expand Up @@ -384,7 +384,7 @@ public void enqueueDelayedMessage(Msg msg, LegacyDeviceFeature feature, long del
synchronized (mrequestQueue) {
mrequestQueue.add(new QEntry(feature, msg, now + delay));
}
if (!msg.isBroadcast()) {
if (!msg.isAllLinkBroadcast()) {
msg.setQuietTime(QUIET_TIME_DIRECT_MESSAGE);
}
logger.trace("enqueing direct message with delay {}", delay);
Expand Down

0 comments on commit cac757a

Please sign in to comment.