[jboss-svn-commits] JBL Code SVN: r26739 - in labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM: src and 20 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue May 26 12:28:19 EDT 2009
Author: whitingjr
Date: 2009-05-26 12:28:18 -0400 (Tue, 26 May 2009)
New Revision: 26739
Added:
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/dstm2/mvcc/adapter/GenerateSampleDSTM2AtomicObject.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/exception/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/exception/AbortedException.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/Configuration.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/TransactionFactory.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/TransactionImpl.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/Car.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/ICar.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/TransactionStatus.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ResourceManager.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Storable.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Transaction.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/TransactionManager.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/tracker/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/tracker/AbstractTracker.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/factory/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/factory/JUTestTestFactory.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/impl/
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/impl/JUTestMVCCStore.java
Modified:
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/.classpath
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/pom.xml
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/MVCCNodeFactory.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/MVCCStore.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/Isolation.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/ReadCommittedIsolationImpl.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/factory/IsolationFactory.java
labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ObjectStoreManager.java
Log:
Updated, added interfaces and some implementation classes.
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/.classpath
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/.classpath 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/.classpath 2009-05-26 16:28:18 UTC (rev 26739)
@@ -2,6 +2,7 @@
<classpath>
<classpathentry kind="src" output="target/classes" path="src/main/java"/>
<classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources"/>
+ <classpathentry kind="src" path="src/test/java"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.6"/>
<classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
<classpathentry kind="output" path="target/classes"/>
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/pom.xml
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/pom.xml 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/pom.xml 2009-05-26 16:28:18 UTC (rev 26739)
@@ -10,13 +10,19 @@
<artifactId>MVCCSampleSTM</artifactId>
<packaging>jar</packaging>
<dependencies>
-
+
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.5</version>
<scope>test</scope>
</dependency>
-
+ <dependency>
+ <groupId>org.apache.bcel</groupId>
+ <artifactId>bcel</artifactId>
+ <version>5.2</version>
+ <scope>test</scope>
+ </dependency>
+
</dependencies>
</project>
\ No newline at end of file
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/dstm2/mvcc/adapter/GenerateSampleDSTM2AtomicObject.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/dstm2/mvcc/adapter/GenerateSampleDSTM2AtomicObject.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/dstm2/mvcc/adapter/GenerateSampleDSTM2AtomicObject.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,18 @@
+package uk.ac.ncl.sdia.a8905943.dstm2.mvcc.adapter;
+
+import org.apache.log4j.Logger;
+
+import uk.ac.ncl.sdia.a8905943.model.Car;
+import dstm2.factory.TestFactory;
+import dstm2.factory.ofree.Adapter;
+
+public class GenerateSampleDSTM2AtomicObject {
+
+ private static final Logger logger = Logger.getLogger(GenerateSampleDSTM2AtomicObject.class);
+
+ public static void main(String[] args) {
+
+
+
+ }
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/exception/AbortedException.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/exception/AbortedException.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/exception/AbortedException.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,13 @@
+package uk.ac.ncl.sdia.a8905943.exception;
+
+public class AbortedException extends Exception{
+
+ public AbortedException()
+ {
+ super();
+ }
+ public AbortedException(String message)
+ {
+ super(message);
+ }
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/Configuration.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/Configuration.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/Configuration.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,7 @@
+package uk.ac.ncl.sdia.a8905943.factory;
+
+public class Configuration {
+
+ public static final boolean SUPPORT_WRITE_SKEW = false;
+
+}
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/MVCCNodeFactory.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/MVCCNodeFactory.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/MVCCNodeFactory.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -3,7 +3,12 @@
import java.util.Map;
import uk.ac.ncl.sdia.a8905943.spec.INode;
-
+/**
+ * This is based on JBoss Cache
+ *
+ * @param <K>
+ * @param <V>
+ */
public class MVCCNodeFactory<K, V> {
public INode createInternalNode(String fqcn)
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/TransactionFactory.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/TransactionFactory.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/factory/TransactionFactory.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,12 @@
+package uk.ac.ncl.sdia.a8905943.factory;
+
+import uk.ac.ncl.sdia.a8905943.impl.TransactionImpl;
+import uk.ac.ncl.sdia.a8905943.spec.Transaction;
+
+public class TransactionFactory {
+
+ public static Transaction createTransaction()
+ {
+ return new TransactionImpl();
+ }
+}
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/MVCCStore.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/MVCCStore.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/MVCCStore.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -24,4 +24,21 @@
return returnValue;
}
+ @Override
+ public void put(Object object)
+ {
+ // put object into the store, using the fqcn to lock serialized access while updating references
+ if (store.containsKey(object.getClass().getName()))
+ {
+ Map<Long>
+ }
+ else
+ {
+
+ }
+ Map<String, Map<String>>
+ store.put(key, value)
+
+ }
+
}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/TransactionImpl.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/TransactionImpl.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/impl/TransactionImpl.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,36 @@
+package uk.ac.ncl.sdia.a8905943.impl;
+
+import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
+
+import uk.ac.ncl.sdia.a8905943.model.TransactionStatus;
+import uk.ac.ncl.sdia.a8905943.spec.Transaction;
+
+public class TransactionImpl implements Transaction {
+
+ private volatile TransactionStatus status;
+ private final AtomicReferenceFieldUpdater<Transaction, TransactionStatus> statusModifier = AtomicReferenceFieldUpdater.newUpdater(Transaction.class, TransactionStatus.class, "statusModifier");
+
+ @Override
+ public void abort() {
+ // TODO see comments
+ // discard all versioned fields associated with this transaction
+ // set the status of this transaction
+ // notify all transactions (transaction manager) transaction has been aborted, cleanup the read or write traces
+ }
+
+ @Override
+ public void beginTransaction() {
+ // record the time in milli seconds transaction started
+ }
+
+ @Override
+ public void commit() {
+ // TODO: go through list of readers and writers depending on isolation. resolve any conflicts.
+ // make object versioned fields visible to all other transactions (depending on isolation)
+ // make versioned collection objects fields visible to all other transactions (depending on isolation)
+ // change status
+ // notify all transactions committed, cleanup reader and writer traces.
+ }
+
+}
+
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/Isolation.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/Isolation.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/Isolation.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -10,7 +10,7 @@
public void setWriteHistory(History history);
public boolean supportsRepeatableRead();
- public boolean supportsWriteSqueue();
+ public boolean supportsWriteSkew();
}
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/ReadCommittedIsolationImpl.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/ReadCommittedIsolationImpl.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/ReadCommittedIsolationImpl.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -22,9 +22,22 @@
return false;
}
+
@Override
- public boolean supportsWriteSqueue() {
+ public History getWriteHistory() {
// TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public void setWriteHistory(History history) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public boolean supportsWriteSkew() {
+ // TODO Auto-generated method stub
return false;
}
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/factory/IsolationFactory.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/factory/IsolationFactory.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/isolation/factory/IsolationFactory.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -3,24 +3,27 @@
import org.jboss.cache.lock.IsolationLevel;
import uk.ac.ncl.sdia.a8905943.isolation.Isolation;
+import uk.ac.ncl.sdia.a8905943.isolation.ReadCommittedIsolationImpl;
+import uk.ac.ncl.sdia.a8905943.isolation.RepeatableReadIsolationImpl;
+import uk.ac.ncl.sdia.a8905943.isolation.SerializableIsolationImpl;
public class IsolationFactory {
- public Isolation createIsolationLevel(IsolationLevel level)
+ public static Isolation createIsolationLevel(IsolationLevel level)
{
Isolation returnValue = null;
if (level.equals(IsolationLevel.READ_COMMITTED))
{
- //returnValue =
+ returnValue = new ReadCommittedIsolationImpl();
}
else if (level.equals(IsolationLevel.REPEATABLE_READ))
{
- //returnValue =
+ returnValue = new RepeatableReadIsolationImpl();
}
else if (level.equals(IsolationLevel.SERIALIZABLE))
{
- //returnValue =
+ returnValue = new SerializableIsolationImpl();
}
else
{
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/Car.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/Car.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/Car.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,9 @@
+package uk.ac.ncl.sdia.a8905943.model;
+
+
+public class Car {
+
+ private Long id;
+ private String make;
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/ICar.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/ICar.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/ICar.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,7 @@
+package uk.ac.ncl.sdia.a8905943.model;
+
+public interface ICar {
+
+ public Long id = 1l;;
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/TransactionStatus.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/TransactionStatus.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/model/TransactionStatus.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,6 @@
+package uk.ac.ncl.sdia.a8905943.model;
+
+public enum TransactionStatus {
+
+ INFLIGHT, ABORTED, COMMITTED, NOTSTARTED
+}
Modified: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ObjectStoreManager.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ObjectStoreManager.java 2009-05-26 15:57:45 UTC (rev 26738)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ObjectStoreManager.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -3,5 +3,5 @@
public interface ObjectStoreManager {
public Object find(Class type, Object identity);
-
+ public void put(Object object);
}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ResourceManager.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ResourceManager.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/ResourceManager.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,5 @@
+package uk.ac.ncl.sdia.a8905943.spec;
+
+public interface ResourceManager {
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Storable.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Storable.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Storable.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,6 @@
+package uk.ac.ncl.sdia.a8905943.spec;
+
+public interface Storable {
+
+ public Long getId();
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Transaction.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Transaction.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/Transaction.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,15 @@
+package uk.ac.ncl.sdia.a8905943.spec;
+
+/**
+ * The purpose of this object is to define the behaviour of a transaction.
+ * @author whitingjr
+ *
+ */
+public interface Transaction {
+
+ public void beginTransaction();
+ public void commit();
+ public void abort();
+
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/TransactionManager.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/TransactionManager.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/spec/TransactionManager.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,5 @@
+package uk.ac.ncl.sdia.a8905943.spec;
+
+public interface TransactionManager {
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/tracker/AbstractTracker.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/tracker/AbstractTracker.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/main/java/uk/ac/ncl/sdia/a8905943/tracker/AbstractTracker.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,11 @@
+package uk.ac.ncl.sdia.a8905943.tracker;
+
+import uk.ac.ncl.sdia.a8905943.isolation.Isolation;
+import uk.ac.ncl.sdia.a8905943.spec.Tracker;
+
+public abstract class AbstractTracker implements Tracker {
+
+ protected AbstractTracker(Isolation isolation) {
+ }
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/factory/JUTestTestFactory.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/factory/JUTestTestFactory.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/dstm2/factory/JUTestTestFactory.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,28 @@
+package dstm2.factory;
+
+import org.apache.log4j.BasicConfigurator;
+import org.apache.log4j.Logger;
+import org.junit.Before;
+import org.junit.Test;
+
+import uk.ac.ncl.sdia.a8905943.model.ICar;
+import dstm2.factory.ofree.Adapter;
+
+public class JUTestTestFactory {
+
+
+ private static final Logger logger = Logger.getLogger(JUTestTestFactory.class);
+ @Test
+ public void testCheckObjectCreated()
+ {
+ TestFactory<ICar> factory = new TestFactory<ICar>(ICar.class, Adapter.class);
+ ICar car = factory.create();
+ logger.info("Generated car object.");
+ }
+ @Before
+ public void setUp()
+ {
+ BasicConfigurator.configure();
+ }
+
+}
Added: labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/impl/JUTestMVCCStore.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/impl/JUTestMVCCStore.java (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/MVCCSampleSTM/src/test/java/uk/ac/ncl/sdia/a8905943/impl/JUTestMVCCStore.java 2009-05-26 16:28:18 UTC (rev 26739)
@@ -0,0 +1,21 @@
+package uk.ac.ncl.sdia.a8905943.impl;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class JUTestMVCCStore {
+
+ @Before
+ public void setUp()
+ {
+
+ }
+ @Test
+ public void testCheckObjectStored()
+ {
+ MVCCStore store = new MVCCStore();
+ store.put();
+
+
+ }
+}
More information about the jboss-svn-commits
mailing list