--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2013 Association for Decentralized Information Management\r
+ * in Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ * VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.diagram.participant;\r
+\r
+import java.util.ArrayList;\r
+import java.util.Collection;\r
+import java.util.Collections;\r
+import java.util.Map;\r
+import java.util.concurrent.ConcurrentHashMap;\r
+\r
+import org.eclipse.ui.contexts.IContextActivation;\r
+import org.eclipse.ui.contexts.IContextService;\r
+import org.simantics.g2d.canvas.ICanvasContext;\r
+import org.simantics.g2d.canvas.impl.AbstractCanvasParticipant;\r
+import org.simantics.utils.ObjectUtils;\r
+import org.simantics.utils.threads.IThreadWorkQueue;\r
+import org.simantics.utils.threads.ThreadUtils;\r
+\r
+/**\r
+ * ContextUtil manages the activeness of Eclipse Workbench UI context related to\r
+ * an ICanvasContext and an IContextService (possibly local to a workbench part).\r
+ * \r
+ * @author Tuukka Lehtonen\r
+ */\r
+public class ContextUtil extends AbstractCanvasParticipant {\r
+\r
+ private static final boolean DEBUG = false;\r
+\r
+ private final IContextService service;\r
+\r
+ private final IThreadWorkQueue thread;\r
+\r
+ private final Map<String, IContextActivation> activations = new ConcurrentHashMap<String, IContextActivation>();\r
+\r
+ public ContextUtil(IContextService service, IThreadWorkQueue contextManipulationThread) {\r
+ assert service != null;\r
+ assert contextManipulationThread != null;\r
+ this.service = service;\r
+ this.thread = contextManipulationThread;\r
+ }\r
+\r
+ public void inContextThread(Runnable r) {\r
+ exec(r, true);\r
+ }\r
+\r
+ private void debug(String s) {\r
+ debug(false, s);\r
+ }\r
+\r
+ private void debug(boolean trace, String s) {\r
+ if (DEBUG) {\r
+ System.out.println(getClass().getSimpleName() + "(" + ObjectUtils.hashCode(getContext()) + "): " + s);\r
+ if (trace) {\r
+ StackTraceElement[] es = new Exception().getStackTrace();\r
+ int e = 0;\r
+ System.out.println("Invoked from: ");\r
+ for (int i = 0; i < 2 && e < es.length; ++e) {\r
+ if (es[e].getClassName().equals(getClass().getName()))\r
+ continue;\r
+ System.out.println("\t" + es[e].toString());\r
+ ++i;\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ private void checkThread() {\r
+ if (!thread.currentThreadAccess()) {\r
+ throw new IllegalStateException("not in context thread, use ContextUtil.inContextThread(Runnable)");\r
+ }\r
+ }\r
+\r
+ private void exec(Runnable r) {\r
+ exec(r, false);\r
+ }\r
+\r
+ private void exec(Runnable r, boolean allowSchedule) {\r
+ if (!allowSchedule)\r
+ checkThread();\r
+\r
+ // Context access thread is disposed already?\r
+ if (thread.getThread() == null)\r
+ return;\r
+\r
+ if (thread.currentThreadAccess()) {\r
+ if (DEBUG)\r
+ debug("RUNNING " + r);\r
+ r.run();\r
+ } else {\r
+ if (DEBUG)\r
+ debug("SCHEDULING " + r);\r
+ ThreadUtils.asyncExec(thread, r);\r
+ }\r
+ }\r
+\r
+ @Override\r
+ public void removedFromContext(ICanvasContext ctx) {\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ deactivateAll();\r
+ }\r
+ }, true);\r
+ super.removedFromContext(ctx);\r
+ }\r
+\r
+ private void doActivate(String contextId) {\r
+ if(!activations.containsKey(contextId)) {\r
+ IContextActivation activation = service.activateContext(contextId);\r
+ if (activation != null) {\r
+ if (DEBUG)\r
+ debug("ACTIVATED context: " + contextId);\r
+ activations.put(contextId, activation);\r
+ }\r
+ } else {\r
+ if (DEBUG)\r
+ debug("TRIED TO ACTIVATE DUPLICATE CONTEXT: " + contextId);\r
+ }\r
+ }\r
+\r
+ public void activate(final String contextId) {\r
+ checkThread();\r
+ if (DEBUG)\r
+ debug(true, "activate(" + contextId + ")");\r
+ assert contextId != null;\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ doActivate(contextId);\r
+ }\r
+ });\r
+ }\r
+\r
+ public void activate(final Collection<String> contextIds) {\r
+ if (DEBUG)\r
+ debug(true, "activate contexts (" + contextIds + ")");\r
+ if (contextIds.isEmpty())\r
+ return;\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ for (String id : contextIds) {\r
+ doActivate(id);\r
+ }\r
+ }\r
+ });\r
+ }\r
+\r
+// public void deactivate(String contextId) {\r
+// checkThread();\r
+// assert contextId != null;\r
+// final IContextActivation activation = activations.remove(contextId);\r
+// if (activation == null) {\r
+// debug("WARNING: cannot deactivate inactive context: " + contextId);\r
+// return;\r
+// }\r
+// exec(new Runnable() {\r
+// @Override\r
+// public void run() {\r
+// if (DEBUG_ACTIVATIONS)\r
+// debug("DE-ACT context: " + activation.getContextId());\r
+// service.deactivateContext(activation);\r
+// }\r
+// });\r
+// }\r
+\r
+ public void deactivate(Collection<String> contextIds) {\r
+ checkThread();\r
+ assert contextIds != null;\r
+ for(String id : contextIds) {\r
+ final IContextActivation a = activations.remove(id);\r
+ if (DEBUG)\r
+ debug(true, "deactivate(" + id + "): " + a);\r
+ if (a != null)\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ if (DEBUG)\r
+ debug("DE-ACT context: " + a.getContextId());\r
+ service.deactivateContext(a);\r
+ }\r
+ });\r
+ }\r
+ }\r
+\r
+ public void deactivate(IContextActivation activation) {\r
+ checkThread();\r
+ assert activation != null;\r
+ final IContextActivation a = activations.remove(activation.getContextId());\r
+ if (DEBUG)\r
+ debug(true, "deactivate(" + activation + "): " + a);\r
+ if (a == activation)\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ if (DEBUG)\r
+ debug("DE-ACT context: " + a.getContextId());\r
+ service.deactivateContext(a);\r
+ }\r
+ });\r
+ }\r
+\r
+ public void deactivateAll() {\r
+ checkThread();\r
+ final Collection<IContextActivation> acts = getActivations();\r
+ if (DEBUG)\r
+ debug(true, "DE-ACTIVATE ALL INVOKED, " + acts.size() + " contexts to deactivate");\r
+ activations.clear();\r
+ exec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ if (DEBUG)\r
+ debug("\tDE-ACTIVATE ALL " + acts.size() + " contexts:");\r
+ for (IContextActivation a : acts) {\r
+ if (DEBUG)\r
+ debug("\t\tDE-ACT context: " + a.getContextId());\r
+ service.deactivateContext(a);\r
+ }\r
+ }\r
+ });\r
+ }\r
+\r
+ public synchronized Collection<IContextActivation> getActivations() {\r
+ return Collections.unmodifiableCollection(new ArrayList<IContextActivation>(activations.values()));\r
+ }\r
+\r
+ public synchronized Collection<String> getActivatedContextIds() {\r
+ return Collections.unmodifiableCollection(new ArrayList<String>(activations.keySet()));\r
+ }\r
+\r
+}\r