--- /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 fi.vtt.simantics.procore.internal;\r
+\r
+import gnu.trove.map.hash.THashMap;\r
+\r
+import java.io.File;\r
+import java.io.FileInputStream;\r
+import java.io.IOException;\r
+import java.io.InputStream;\r
+import java.util.Properties;\r
+import java.util.Set;\r
+import java.util.concurrent.atomic.AtomicLong;\r
+\r
+import org.simantics.db.ClusterCreator;\r
+import org.simantics.db.Database;\r
+import org.simantics.db.SessionReference;\r
+import org.simantics.db.Database.Session;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.impl.support.VirtualGraphServerSupport;\r
+import org.simantics.db.procore.protocol.Constants;\r
+import org.simantics.db.server.ProCoreException;\r
+import org.simantics.db.service.ClusterUID;\r
+\r
+class GraphSessionVirtual extends GraphSession { // Äsh! This extends relation was/is a pure design choice.\r
+ private static String FileName = "virtualGraph.builtins.dat";\r
+ private static long BuiltinClusterId = -1; // Virtual graph doesn't have clusters.\r
+ static class VirtualSession implements Session {\r
+ @Override\r
+ public Database getDatabase() {\r
+ return null;\r
+ }\r
+ @Override\r
+ public void close() throws ProCoreException {\r
+ }\r
+ @Override\r
+ public void open() throws ProCoreException {\r
+ }\r
+ @Override\r
+ public boolean isClosed() throws ProCoreException {\r
+ return false;\r
+ }\r
+ @Override\r
+ public String execute(String command) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public void acceptCommit(long transactionId, long changeSetId, byte[] metadata) throws ProCoreException {\r
+ }\r
+ @Override\r
+ public long cancelCommit(long transactionId, long changeSetId, byte[] metadata, OnChangeSetUpdate on) throws ProCoreException {\r
+ return 0;\r
+ }\r
+ @Override\r
+ public Transaction askReadTransaction() throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public Transaction askWriteTransaction(long transactionId) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public long endTransaction(long transactionId) throws ProCoreException {\r
+ return 0;\r
+ }\r
+ @Override\r
+ public byte[] getChangeSetMetadata(long changeSetId) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public ChangeSetData getChangeSetData(long minChangeSetId, long maxChangeSetId, OnChangeSetUpdate on) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public ChangeSetIds getChangeSetIds() throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public Cluster getCluster(byte[] clusterId) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public ClusterChanges getClusterChanges(long changeSetId, byte[] clusterId) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public ClusterIds getClusterIds() throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public Information getInformation() throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public Refresh getRefresh(long changeSetId) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public ResourceSegment getResourceSegment(byte[] clusterUID, int resourceIndex, long offset, short size) throws ProCoreException {\r
+ return null;\r
+ }\r
+ @Override\r
+ public long reserveIds(int count) throws ProCoreException {\r
+ return 0;\r
+ }\r
+ @Override\r
+ public void updateCluster(byte[] operations) throws ProCoreException {\r
+ }\r
+ @Override\r
+ public boolean undo(long[] cChangeSetIds, OnChangeSetUpdate onChangeSetUpdate) throws ProCoreException {\r
+ return false;\r
+ }\r
+ @Override\r
+ public <T> T clone(ClusterUID clusterUID, ClusterCreator clusterCreator) throws DatabaseException {\r
+ throw new UnsupportedOperationException();\r
+ }\r
+ @Override\r
+ public boolean refreshEnabled() {\r
+ return false;\r
+ }\r
+ }\r
+ private AtomicLong changeSetId = new AtomicLong(Constants.NullChangeSetId);\r
+ private AtomicLong transactionId = new AtomicLong(Constants.NullTransactionId);\r
+ public static ServerInformationImpl serverInfo = new ServerInformationImpl("serverId", "protocolId", "databaseId", 0);\r
+ private VirtualGraphServerSupport virtualGraphServerSupport;\r
+ public GraphSessionVirtual(SessionImplSocket sessionImpl, SessionReference sessionReference, VirtualGraphServerSupport vgss) {\r
+ super(sessionImpl, sessionReference, new VirtualSession()); // Super does not expect null session.\r
+ virtualGraphServerSupport = vgss;\r
+ }\r
+ protected THashMap<String, BuiltinData> initBuiltinMap()\r
+ throws DatabaseException {\r
+ try {\r
+ Properties props = new Properties();\r
+ File from = new File(FileName);\r
+ InputStream in = new FileInputStream(from);\r
+ props.load(in);\r
+ THashMap<String, BuiltinData> builtins = new THashMap<String, BuiltinData>();\r
+ Set<String> keys = props.stringPropertyNames();\r
+ for (String key : keys) {\r
+ long resourceId = Long.parseLong(key);\r
+ long cluster = BuiltinClusterId;\r
+ int resourceIndex = (int)resourceId;\r
+ String uri = props.getProperty(key);\r
+ BuiltinData bd = new BuiltinData(resourceIndex, cluster);\r
+ builtins.put(uri, bd);\r
+ }\r
+ return builtins;\r
+ } catch(IOException e) {\r
+ if (DEBUG)\r
+ e.printStackTrace();\r
+ throw new DatabaseException("Failed to read builtins.", e);\r
+ }\r
+ }\r
+ @Override\r
+ protected ServerInformationImpl getServerInformation() {\r
+ return serverInfo;\r
+ }\r
+ @Override\r
+ public void acceptCommit(long transactionId, long csid, byte[] metadata)\r
+ throws DatabaseException {\r
+ changeSetId.incrementAndGet();\r
+ }\r
+\r
+ @Override\r
+ public void cancelCommit(long transactionId, long csid, byte[] metadata, SynchronizeContextI context)\r
+ throws DatabaseException {\r
+ changeSetId.incrementAndGet();\r
+ }\r
+\r
+ @Override\r
+ public void endTransaction(long transactionId, boolean write)\r
+ throws DatabaseException {\r
+\r
+ }\r
+\r
+ @Override\r
+ public long askWriteTransaction(int thread, long transactionId)\r
+ throws DatabaseException {\r
+ if (Constants.NullTransactionId != transactionId)\r
+ return transactionId;\r
+ else\r
+ return this.transactionId.incrementAndGet();\r
+ }\r
+ @Override\r
+ public long askReadTransaction(int thread)\r
+ throws DatabaseException {\r
+ return transactionId.incrementAndGet();\r
+ }\r
+ @Override\r
+ public void stop() throws DatabaseException {\r
+ if (DEBUG)\r
+ System.out.println("GraphSessionVirtual: stop.");\r
+\r
+ }\r
+ @Override\r
+ public long reserveIds(int count)\r
+ throws DatabaseException {\r
+// VirtualGraphServerSupport s = session.getService(VirtualGraphServerSupport.class);\r
+ long id = Constants.NullSubjectId;\r
+ for (int i=0; i<count; ++i)\r
+ id = virtualGraphServerSupport.createVirtual();\r
+ return id;\r
+ }\r
+}
\ No newline at end of file
Code Review / simantics / platform.git / blobdiff