--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2010 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.debug.ui;\r
+\r
+import org.eclipse.core.runtime.Assert;\r
+import org.eclipse.jface.viewers.ITreeContentProvider;\r
+import org.eclipse.jface.viewers.TreeViewer;\r
+import org.eclipse.jface.viewers.Viewer;\r
+import org.eclipse.swt.SWT;\r
+import org.eclipse.swt.events.DisposeEvent;\r
+import org.eclipse.swt.events.DisposeListener;\r
+import org.eclipse.swt.layout.GridData;\r
+import org.eclipse.swt.layout.GridLayout;\r
+import org.eclipse.swt.widgets.Composite;\r
+import org.simantics.db.Session;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.common.processor.MergingGraphRequestProcessor;\r
+import org.simantics.db.common.request.ReadRequest;\r
+import org.simantics.db.event.ChangeEvent;\r
+import org.simantics.db.event.ChangeListener;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.service.GraphChangeListenerSupport;\r
+\r
+\r
+public class SessionDebugger extends Composite {\r
+ \r
+ /**\r
+ * The Session used to access the graph. Received from outside of this\r
+ * class and therefore it is not disposed here, just used.\r
+ */\r
+ private Session session;\r
+ \r
+ private MergingGraphRequestProcessor updater;\r
+ \r
+ private TreeViewer clusters;\r
+ \r
+ private ChangeListener changeListener = new ChangeListener() {\r
+ public void graphChanged(ChangeEvent e) {\r
+ // This makes sure that the transaction for updating this\r
+ // GraphDebugger get executed in a serialized fashion.\r
+ updater.asyncRequest(new ReadRequest() {\r
+ @Override\r
+ public void run(ReadGraph g) throws DatabaseException {\r
+ updateContent();\r
+ }\r
+ });\r
+ }\r
+ };\r
+\r
+ /**\r
+ * @param parent\r
+ * @param style\r
+ * @param session\r
+ * @param resource the initial resource to debug or <code>null</code> for\r
+ * initially blank UI.\r
+ */\r
+ public SessionDebugger(Composite parent, int style, final Session session) {\r
+ super(parent, style);\r
+ Assert.isNotNull(session, "session is null");\r
+ this.session = session;\r
+ updater = new MergingGraphRequestProcessor(session, 100);\r
+ \r
+ addDisposeListener(new DisposeListener() {\r
+ @Override\r
+ public void widgetDisposed(DisposeEvent e) {\r
+ GraphChangeListenerSupport support = session.getService(GraphChangeListenerSupport.class);\r
+ support.removeListener(changeListener);\r
+ }\r
+ });\r
+ \r
+ }\r
+ \r
+ public void initializeUI() {\r
+ \r
+ setLayout(new GridLayout(1, false));\r
+ setLayoutData(new GridData(SWT.FILL, SWT.FILL, true, true));\r
+\r
+ createViewer(this);\r
+ \r
+ }\r
+\r
+ public TreeViewer createViewer(Composite parent) {\r
+\r
+ clusters = new TreeViewer(parent, SWT.NONE);\r
+ clusters.getTree().setLayoutData(new GridData(SWT.FILL, SWT.FILL, true, true));\r
+\r
+ clusters.setContentProvider(new ITreeContentProvider() {\r
+\r
+ @Override\r
+ public Object[] getChildren(Object parentElement) {\r
+ return new Object[0];\r
+ }\r
+\r
+ @Override\r
+ public Object getParent(Object element) {\r
+ return null;\r
+ }\r
+\r
+ @Override\r
+ public boolean hasChildren(Object element) {\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public Object[] getElements(Object inputElement) {\r
+// return session.getDebug().getActiveClusters();\r
+ return new Object[0];\r
+ }\r
+\r
+ @Override\r
+ public void dispose() {\r
+ }\r
+\r
+ @Override\r
+ public void inputChanged(Viewer viewer, Object oldInput, Object newInput) {\r
+ }\r
+ \r
+ });\r
+ \r
+ // Schedule a request that updates the browser content.\r
+ refreshClusters();\r
+ GraphChangeListenerSupport support = session.getService(GraphChangeListenerSupport.class);\r
+ support.addListener(changeListener);\r
+\r
+ return clusters;\r
+ \r
+ }\r
+\r
+ public void refreshClusters() {\r
+ \r
+ // Schedule a request that updates the browser content.\r
+ updater.asyncRequest(new ReadRequest() {\r
+ @Override\r
+ public void run(ReadGraph g) throws DatabaseException {\r
+ updateContent();\r
+ }\r
+ });\r
+ \r
+ }\r
+ \r
+ public void updateContent() {\r
+\r
+ clusters.getTree().getDisplay().asyncExec(new Runnable() {\r
+\r
+ @Override\r
+ public void run() {\r
+ \r
+ if(clusters.getTree().isDisposed()) return;\r
+ clusters.setInput(new Object());\r
+ \r
+ }\r
+ \r
+ });\r
+ \r
+ }\r
+\r
+}\r