[jboss-svn-commits] JBL Code SVN: r31722 - labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration.

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

Author: whitingjr
Date: 2010-02-18 06:08:36 -0500 (Thu, 18 Feb 2010)
New Revision: 31722

Modified:
   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:
Updated to allow basic timing measuring.

Modified: 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	2010-02-18 08:49:46 UTC (rev 31721)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/ConcurrentTaskConfiguration.java	2010-02-18 11:08:36 UTC (rev 31722)
@@ -1,5 +1,6 @@
 package org.jboss.jbossts.performance.configuration;
 
+import java.util.List;
 import java.util.Stack;
 import java.util.concurrent.CyclicBarrier;
 
@@ -20,8 +21,9 @@
    private final boolean isOptionalWriteEnabled;
    private final Stack NDCstack;
    private final Long threadIdentity; // this is not shared, each thread has it's own identity
+   private final List<Long> threadResults ;// shared access to object, serialized behaviour baked in at construction time
    public ConcurrentTaskConfiguration(final EntityManagerFactory emfA, final EntityManagerFactory emfB, final int iterations, 
-         final CyclicBarrier barrier, final boolean isOptionalWEnabled, final Stack stack, final Long identity)
+         final CyclicBarrier barrier, final boolean isOptionalWEnabled, final Stack stack, final Long identity, final List<Long> results)
    {
       this.emfactoryA = emfA;
       this.emfactoryB = emfB;
@@ -30,7 +32,7 @@
       this.isOptionalWriteEnabled = isOptionalWEnabled;
       this.NDCstack = stack;
       this.threadIdentity = identity;
-      
+      this.threadResults = results;
    }
    public EntityManagerFactory getEmfactoryA()
    {
@@ -60,4 +62,8 @@
    {
       return threadIdentity;
    }
+   public List<Long> getThreadResults()
+   {
+      return threadResults;
+   }
 }

Modified: 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	2010-02-18 08:49:46 UTC (rev 31721)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java	2010-02-18 11:08:36 UTC (rev 31722)
@@ -1,5 +1,6 @@
 package org.jboss.jbossts.performance.configuration;
 
+import java.util.List;
 import java.util.concurrent.CyclicBarrier;
 
 /**
@@ -13,13 +14,14 @@
    private final Integer iterationCount;
    private final CyclicBarrier completionBarrier;
    private final Long threadIdentity;
-
+   private final List<Long> results;
    public MultithreadedTestConfiguration(final Integer stable,
-         final CyclicBarrier barrier, final Long identity)
+         final CyclicBarrier barrier, final Long identity, final List<Long> threadResults)
    {
       this.iterationCount = stable;
       this.completionBarrier = barrier;
       this.threadIdentity = identity;
+      this.results = threadResults;
    }
 
    public Integer getIterationCount()
@@ -36,4 +38,9 @@
    {
       return threadIdentity;
    }
+   
+   public List<Long> getResults()
+   {
+      return results;
+   }
 }

Modified: 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	2010-02-18 08:49:46 UTC (rev 31721)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/TestConfiguration.java	2010-02-18 11:08:36 UTC (rev 31722)
@@ -1,5 +1,7 @@
 package org.jboss.jbossts.performance.configuration;
 
+import java.util.List;
+
 /**
  * This is an immutable object to hold configuration for concurrent execution.
  * @author Jeremy Whiting jwhiting at redhat.com
@@ -9,12 +11,12 @@
 {
    private final Integer iterationCount;
    private final Integer threadCount;
-   //private final Long profiledCount;
-   public TestConfiguration(final Integer iteration, final Integer thread)
+   private final List<Long> threadResults;
+   public TestConfiguration(final Integer iteration, final Integer thread, final List<Long> results)
    {
       this.iterationCount = iteration;
       this.threadCount = thread;
-      //this.profiledCount = profiled;
+      this.threadResults = results;
    }
    public Integer getIterationCount()
    {
@@ -24,9 +26,8 @@
    {
       return threadCount;
    }
-   /*
-   public Long getProfiledCount()
+   public List<Long> getThreadResults()
    {
-      return profiledCount;
-   }*/
+      return threadResults;
+   }
 }