X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.modeling.ui%2Fsrc%2Forg%2Fsimantics%2Fmodeling%2Fui%2Fdiagram%2Fmonitor%2FMonitorListener.java;fp=bundles%2Forg.simantics.modeling.ui%2Fsrc%2Forg%2Fsimantics%2Fmodeling%2Fui%2Fdiagram%2Fmonitor%2FMonitorListener.java;h=fe5e5c21baf811082dd9e9fa7478ee7301b3dcd2;hp=0000000000000000000000000000000000000000;hb=969bd23cab98a79ca9101af33334000879fb60c5;hpb=866dba5cd5a3929bbeae85991796acb212338a08

diff --git a/bundles/org.simantics.modeling.ui/src/org/simantics/modeling/ui/diagram/monitor/MonitorListener.java b/bundles/org.simantics.modeling.ui/src/org/simantics/modeling/ui/diagram/monitor/MonitorListener.java
new file mode 100644
index 000000000..fe5e5c21b
--- /dev/null
+++ b/bundles/org.simantics.modeling.ui/src/org/simantics/modeling/ui/diagram/monitor/MonitorListener.java
@@ -0,0 +1,173 @@
+/*******************************************************************************
+ * Copyright (c) 2012 Association for Decentralized Information Management in
+ * Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+package org.simantics.modeling.ui.diagram.monitor;
+
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicReference;
+
+import org.simantics.db.Disposable;
+import org.simantics.db.Resource;
+import org.simantics.db.procedure.Listener;
+import org.simantics.diagram.elements.MonitorClass;
+import org.simantics.g2d.canvas.Hints;
+import org.simantics.g2d.canvas.ICanvasContext;
+import org.simantics.g2d.diagram.IDiagram;
+import org.simantics.g2d.element.ElementUtils;
+import org.simantics.g2d.element.IElement;
+import org.simantics.utils.threads.ThreadUtils;
+import org.simantics.utils.ui.ErrorLogger;
+
+/**
+ * @author Tuukka Lehtonen
+ */
+public class MonitorListener implements Listener<MonitorVariableValue>, Runnable, Disposable {
+
+    private final Resource                                  element;
+    private ICanvasContext                                  canvas;
+    private IDiagram                                        diagram;
+    private final Map<String, String>                       substitutions;
+
+    private transient AtomicReference<MonitorVariableValue> lastScheduledUpdate   = null;
+    private transient AtomicBoolean                         inUpdate = null;
+
+    public MonitorListener(Resource element, ICanvasContext canvas, IDiagram diagram, Map<String, String> substitutions) {
+        if (element == null)
+            throw new NullPointerException("null element");
+        if (canvas == null)
+            throw new NullPointerException("null canvas");
+        if (diagram == null)
+            throw new NullPointerException("null diagram");
+        if (substitutions == null)
+            throw new NullPointerException("null substitutions");
+        this.element = element;
+        this.canvas = canvas;
+        this.diagram = diagram;
+        this.substitutions = substitutions;
+    }
+
+    @Override
+    public void dispose() {
+        canvas = null;
+        diagram = null;
+    }
+
+    @Override
+    public void execute(MonitorVariableValue result) {
+        // Implement some kind of throttling for AWT thread element
+        // update scheduling to keep the amount of AWT scheduling
+        // down to a minimum.
+        if (inUpdate == null)
+            inUpdate = new AtomicBoolean(false);
+        if (lastScheduledUpdate == null)
+            lastScheduledUpdate = new AtomicReference<MonitorVariableValue>();
+
+        lastScheduledUpdate.set(result);
+
+        // Don't schedule update if there was already one in the pipe.
+        synchronized (inUpdate) {
+            if (!inUpdate.compareAndSet(false, true))
+                return;
+        }
+
+        //System.out.println(this + ".execute(" + result + "+")");
+        scheduleUpdate();
+    }
+
+    @Override
+    public void run() {
+        if (isDisposed())
+            return;
+
+        IElement el = ElementUtils.getByData(diagram, element);
+        if (el == null)
+            return;
+
+        try {
+            performUpdate(el);
+        } finally {
+            // Mark null to allow new update scheduling to commence.
+            synchronized (inUpdate) {
+                if (lastScheduledUpdate.get() != null)
+                    scheduleUpdate();
+                else
+                    inUpdate.set(false);
+            }
+        }
+    }
+
+    private void scheduleUpdate() {
+        ICanvasContext canvas = this.canvas;
+        if (!isDisposed())
+            ThreadUtils.asyncExec(canvas.getThreadAccess(), this);
+    }
+
+    private void performUpdate(IElement el) {
+        // Get the last updated monitor value but don't yet
+        // mark the container null to keep the outer code
+        // from scheduling new updates until this one is
+        // finished.
+        MonitorVariableValue result = lastScheduledUpdate.getAndSet(null);
+
+        String value = "<no variable>";
+        if (result != null) {
+            if (result.getValue() != null) {
+                value = result.getValue();//ValueFormatUtil.valueStr(result.getValue(), format);
+            } else {
+                value = "<no value>";
+            }
+            el.setHint(MonitorClass.KEY_MONITOR_COMPONENT, result.getMonitorVariable().getMonitorComponent());
+            ElementUtils.setOrRemoveHint(el, MonitorClass.KEY_MONITOR_IS_EXTERNAL, result.getMonitorVariable().isExternal());
+        } else {
+            el.removeHint(MonitorClass.KEY_MONITOR_COMPONENT);
+            el.removeHint(MonitorClass.KEY_MONITOR_IS_EXTERNAL);
+        }
+
+        substitutions.put("#v1", value);
+
+        final Map<String, String> subs = el.getHint(MonitorClass.KEY_MONITOR_SUBSTITUTIONS);
+        if (substitutions != subs)
+            el.setHint(MonitorClass.KEY_MONITOR_SUBSTITUTIONS, substitutions);
+
+        //System.out.println("REPLACING #v1: " + substitutions.get("#v1"));
+
+        el.setHint(Hints.KEY_DIRTY, Hints.VALUE_SG_DELAYED_UPDATE);
+    }
+
+    @Override
+    public void exception(Throwable t) {
+        ErrorLogger.defaultLogError(t);
+    }
+
+    @Override
+    public boolean isDisposed() {
+        return canvas == null || diagram == null || canvas.isDisposed();
+    }
+
+    @Override
+    public int hashCode() {
+        return element.hashCode();
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        MonitorListener other = (MonitorListener) obj;
+        return element.equals(other.element);
+    }
+
+}
\ No newline at end of file