Add some experimental code to look at dynamic updates to a running Node

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1137548 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 186 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/HotUpdater.java b/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/HotUpdater.java
new file mode 100644
index 0000000000..7369ab385b
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/HotUpdater.java
@@ -0,0 +1,111 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+

+package org.apache.tuscany.sca.impl.hotupdate;

+

+import java.io.File;

+import java.util.HashMap;

+import java.util.HashSet;

+import java.util.Map;

+import java.util.Set;

+import java.util.concurrent.Executors;

+import java.util.concurrent.ScheduledExecutorService;

+import java.util.concurrent.TimeUnit;

+

+import org.apache.tuscany.sca.Node;

+import org.apache.tuscany.sca.impl.NodeImpl;

+

+/**

+ * Code to do dynamic updates to a running Node.

+ * Very experimental presently, mainly just to see what type of things are required 

+ */

+public class HotUpdater {

+

+    private final Node node;

+    private final File domainDir;

+

+    // key is contribution URI (which for exploded contributions is the directory name)

+    private final Map<String, LastModifiedTracker> contributions = new HashMap<String, LastModifiedTracker>();

+

+    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

+    

+    public HotUpdater(Node node, File domainDir){

+        this.node = node;

+        this.domainDir = domainDir;

+        

+        final Runnable checker = new Runnable() {

+            public void run() {

+                check();

+            }

+        };

+

+        scheduler.scheduleAtFixedRate(checker, 10, 10, TimeUnit.SECONDS);

+    }

+

+    private void check() {

+        Set<String> found = new HashSet<String>();

+        for (File f : domainDir.listFiles()) {

+            if (f.isDirectory() && !f.getName().startsWith(".")) {

+                found.add(f.getName());

+                LastModifiedTracker scanner = contributions.get(f.getName());

+                if (scanner == null) {

+                    //newContribution(f);

+                    contributions.put(f.getName(), new LastModifiedTracker(f));

+                } else {

+                    if (scanner.checkModified()) {

+                        updatedContribution(f);

+                    }

+                }

+            }

+        }

+        

+        HashSet<String> removed = new HashSet<String>(contributions.keySet());

+        removed.removeAll(found);

+        for (String curi : removed) {

+            removedContribution(curi);

+        }

+

+    }

+

+    private void removedContribution(String curi) {

+        try {

+            ((NodeImpl)node).uninstallContribution(curi, true);

+        } catch (Exception e) {

+            e.printStackTrace();

+        }

+        contributions.remove(curi);

+    }

+

+    private void updatedContribution(File f) {

+        try {

+            ((NodeImpl)node).updateContribution(f.getName(), f.toURI().toURL().toString(), null, null);

+        } catch (Exception e) {

+            e.printStackTrace();

+        }

+    }

+

+    private void newContribution(File f) {

+        try {

+            node.installContribution(f.getName(), f.toURI().toURL().toString(), null, null);

+            node.startDeployables(f.getName());

+        } catch (Exception e) {

+            e.printStackTrace();

+        }

+    }

+}

diff --git a/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/LastModifiedTracker.java b/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/LastModifiedTracker.java
new file mode 100644
index 0000000000..a129f4d0fe
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/domain-node/src/main/java/org/apache/tuscany/sca/impl/hotupdate/LastModifiedTracker.java
@@ -0,0 +1,75 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+

+package org.apache.tuscany.sca.impl.hotupdate;

+

+import java.io.File;

+

+/**

+ * Keeps track of if a file or directory has been modified since a previous check

+ */

+public class LastModifiedTracker {

+

+    private File targetFile;

+    private Long lastModified;

+

+    public LastModifiedTracker(File targetFile) {

+        this.targetFile = targetFile;

+        checkModified();

+    }

+    

+    public void reset() {

+        lastModified = null;

+    }

+    

+    public boolean checkModified() {

+        

+        long newLastModified = getNewLastModified(targetFile);

+

+        if (lastModified == null) {

+            lastModified = newLastModified;

+            return false;

+        }

+        

+        if (newLastModified > lastModified) {

+            lastModified = newLastModified;

+            return true;

+        }

+        

+        return false;

+    }

+

+    protected long getNewLastModified(File f) {

+

+        if (!f.exists()) return 0;

+        

+        if (f.isFile()) return f.lastModified();

+

+        long newLastModified = f.lastModified();

+

+        for (File fx : f.listFiles()) {

+            long fxLastModified = getNewLastModified(fx);

+            if (fxLastModified > newLastModified){

+                newLastModified = fxLastModified;

+            }

+        }

+

+        return newLastModified;

+    }

+}