Author: timothyjward
Date: Fri May 20 09:04:44 2016
New Revision: 1744675

URL: http://svn.apache.org/viewvc?rev=1744675&view=rev
Log:
[tx-control] Enhance the Coordinator Optimisation test to show one transaction 
isn't necessarily better

Modified:
    
aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java

Modified: 
aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
URL: 
http://svn.apache.org/viewvc/aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java?rev=1744675&r1=1744674&r2=1744675&view=diff
==============================================================================
--- 
aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
 (original)
+++ 
aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
 Fri May 20 09:04:44 2016
@@ -63,6 +63,7 @@ public class CoordinatorOptimisationTest
                                .collect(toList());
        
        long noCoord;
+       long oneTran;
        long withCoord;
        
        long start = System.currentTimeMillis();
@@ -75,17 +76,27 @@ public class CoordinatorOptimisationTest
        
        txControl.required(() -> 
connection.createStatement().executeUpdate("DELETE FROM TEST_TABLE"));
        
+       txControl.required(() -> {
+                       messages.stream()
+                               .forEach(this::persistMessage);
+                       return null;
+               });
+       oneTran = System.currentTimeMillis() - start;
+
+       txControl.required(() -> 
connection.createStatement().executeUpdate("DELETE FROM TEST_TABLE"));
+       
        coordinator.begin("foo", MINUTES.toMillis(5));
        start = System.currentTimeMillis();
        try {
                messages.stream()
-                       .forEach(this::persistMessage);
+               .forEach(this::persistMessage);
        } finally {
                coordinator.peek().end();
                withCoord = System.currentTimeMillis() - start;
        }
        
-       System.out.println("\n\n\n\nWithout Coord: " + noCoord + "  With Coord: 
" + withCoord);
+       System.out.println("\n\n\n\nWithout Coord: " + noCoord + "  One Tran: " 
+ oneTran+  
+                       "  With Coord: " + withCoord);
     }
     
     @SuppressWarnings("unchecked")


Reply via email to