You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by ti...@apache.org on 2016/05/20 09:04:44 UTC
svn commit: r1744675 -
/aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/CoordinatorOptimisationTest.java
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")