[velux] force flush receive buffer

Signed-off-by: Andrew Fiddian-Green <[email protected]>
openhab · Feb 28, 2021 · 2dc7f16 · 2dc7f16 · gs4711 · Feb 28, 2021
1 parent 4083279
commit 2dc7f16
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/...in/java/org/openhab/binding/velux/internal/bridge/slip/io/DataInputStreamWithTimeout.java b/...in/java/org/openhab/binding/velux/internal/bridge/slip/io/DataInputStreamWithTimeout.java
@@ -97,9 +97,14 @@ public Boolean call() throws Exception {
             pollException = null;
             slipMessageQueue.clear();
 
-            // loop forever or until internally or externally interrupted
-            while ((!interrupted) && (!Thread.interrupted())) {
+            // loop forever or until externally interrupted
+            while (!Thread.interrupted()) {
                 try {
+                    if (interrupted) {
+                        // fully flush the input buffer
+                        inputStream.readAllBytes();
+                        break;
+                    }
                     byt = inputStream.read();
                     if (byt < 0) {
                         // end of stream is OK => keep on polling