[jboss-svn-commits] JBL Code SVN: r31421 - in labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance: configuration and 1 other directory.

[jboss-svn-commits at lists.jboss.org]

Author: whitingjr
Date: 2010-02-05 03:41:58 -0500 (Fri, 05 Feb 2010)
New Revision: 31421

Added:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/ConcurrentTaskConfiguration.java
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/TestConfiguration.java
Log:
Added objects for configuration.

Added: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/ConcurrentTaskConfiguration.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/ConcurrentTaskConfiguration.java	                        (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/ConcurrentTaskConfiguration.java	2010-02-05 08:41:58 UTC (rev 31421)
@@ -0,0 +1,63 @@
+package org.jboss.jbossts.performance.configuration;
+
+import java.util.Stack;
+import java.util.concurrent.CyclicBarrier;
+
+import javax.persistence.EntityManagerFactory;
+
+/**
+ * This object encapsulates the configuration for a test case task. 
+ * 
+ * @author whitingjr
+ *
+ */
+public class ConcurrentTaskConfiguration
+{ 
+   private final EntityManagerFactory emfactoryA;
+   private final EntityManagerFactory emfactoryB;
+   private final int iterationCount;
+   private final CyclicBarrier completionBarrier;
+   private final boolean isOptionalWriteEnabled;
+   private final Stack NDCstack;
+   private final Long threadIdentity; // this is not shared, each thread has it's own identity
+   public ConcurrentTaskConfiguration(final EntityManagerFactory emfA, final EntityManagerFactory emfB, final int iterations, 
+         final CyclicBarrier barrier, final boolean isOptionalWEnabled, final Stack stack, final Long identity)
+   {
+      this.emfactoryA = emfA;
+      this.emfactoryB = emfB;
+      this.iterationCount = iterations;
+      this.completionBarrier = barrier;
+      this.isOptionalWriteEnabled = isOptionalWEnabled;
+      this.NDCstack = stack;
+      this.threadIdentity = identity;
+      
+   }
+   public EntityManagerFactory getEmfactoryA()
+   {
+      return emfactoryA;
+   }
+   public EntityManagerFactory getEmfactoryB()
+   {
+      return emfactoryB;
+   }
+   public int getIterationCount()
+   {
+      return iterationCount;
+   }
+   public CyclicBarrier getCompletionBarrier()
+   {
+      return completionBarrier;
+   }
+   public boolean isOptionalWriteEnabled()
+   {
+      return isOptionalWriteEnabled;
+   }
+   public Stack getNDCstack()
+   {
+      return NDCstack;
+   }
+   public Long getThreadIdentity()
+   {
+      return threadIdentity;
+   }
+}

Added: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java	                        (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java	2010-02-05 08:41:58 UTC (rev 31421)
@@ -0,0 +1,39 @@
+package org.jboss.jbossts.performance.configuration;
+
+import java.util.concurrent.CyclicBarrier;
+
+/**
+ * This object holds the configuration for Task objects.
+ * 
+ * @author whitingjr
+ * 
+ */
+public class MultithreadedTestConfiguration
+{
+   private final Integer iterationCount;
+   private final CyclicBarrier completionBarrier;
+   private final Long threadIdentity;
+
+   public MultithreadedTestConfiguration(final Integer stable,
+         final CyclicBarrier barrier, final Long identity)
+   {
+      this.iterationCount = stable;
+      this.completionBarrier = barrier;
+      this.threadIdentity = identity;
+   }
+
+   public Integer getIterationCount()
+   {
+      return iterationCount;
+   }
+
+   public CyclicBarrier getCompletionBarrier()
+   {
+      return completionBarrier;
+   }
+
+   public Long getThreadIdentity()
+   {
+      return threadIdentity;
+   }
+}

Added: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/TestConfiguration.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/TestConfiguration.java	                        (rev 0)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/TestConfiguration.java	2010-02-05 08:41:58 UTC (rev 31421)
@@ -0,0 +1,31 @@
+package org.jboss.jbossts.performance.configuration;
+
+/**
+ * This is an immutable object to hold configuration for concurrent execution.
+ * @author Jeremy Whiting jwhiting at redhat.com
+ *
+ */
+public class TestConfiguration
+{
+   private final Integer iterationCount;
+   private final Integer threadCount;
+   private final Long profiledCount;
+   public TestConfiguration(final Integer iteration, final Integer thread, final Long profiled)
+   {
+      this.iterationCount = iteration;
+      this.threadCount = thread;
+      this.profiledCount = profiled;
+   }
+   public Integer getIterationCount()
+   {
+      return iterationCount;
+   }
+   public Integer getThreadCount()
+   {
+      return threadCount;
+   }
+   public Long getProfiledCount()
+   {
+      return profiledCount;
+   }
+}