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")