0.79.0

- Coalesce database saves.
- Sync file descriptor on database save.
- Minor threading fixes in lists and subscriptions.

Author: a-hansen

build.gradle

@@ -4,7 +4,7 @@ subprojects {
     apply plugin: 'maven-publish'
 
     group 'org.iot-dsa'
-    version '0.78.0'
+    version '0.79.0'
 
     targetCompatibility = JavaVersion.VERSION_1_8
     sourceCompatibility = JavaVersion.VERSION_1_8

dslink-v2/src/main/java/com/acuity/iot/dsa/dslink/protocol/responder/DSInboundList.java

@@ -72,12 +72,6 @@ public boolean canWrite(DSSession session) {
 
     @Override
     public void close() {
-        if (isOpen()) {
-            //we don't actually close the stream because an object could be added back at this path
-            send("$disconnectedTs", DSDateTime.now().toElement());
-            sendStreamOpen = true;
-            state = StreamState.DISCONNECTED;
-        }
         if (subscription != null) {
             subscription.close();
             subscription = null;
@@ -90,6 +84,12 @@ public void close() {
             }
             response = null;
         }
+        if (isOpen()) {
+            //we don't actually close the stream because an object could be added back at this path
+            send("$disconnectedTs", DSDateTime.now().toElement());
+            sendStreamOpen = true;
+            state = StreamState.DISCONNECTED;
+        }
     }
 
     @Override
@@ -152,6 +152,10 @@ public void onEvent(DSEvent event, DSNode node, DSInfo<?> child, DSIValue data)
                 }
                 break;
             case DSNode.VALUE_CHANGED:
+                if (child == null) {
+                    // The node is a value node and this will be repeated for the parent.
+                    return;
+                }
                 char ch = child.getName().charAt(0);
                 if ((ch == '@') || (ch == '$')) {
                     send(child.getName(), child.getElement());