You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/07/28 21:27:09 UTC
[02/11] activemq-artemis git commit: Fix journal compact test slow
appender loop counters
Fix journal compact test slow appender loop counters
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a6a03d49
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a6a03d49
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a6a03d49
Branch: refs/heads/master
Commit: a6a03d498505adf226fea49b0266a33e74488fb9
Parents: fa191ba
Author: Ville Skytt� <vi...@iki.fi>
Authored: Thu Jul 28 23:20:07 2016 +0300
Committer: Ville Skytt� <vi...@iki.fi>
Committed: Thu Jul 28 23:30:02 2016 +0300
----------------------------------------------------------------------
.../tests/stress/journal/JournalCleanupCompactStressTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a6a03d49/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/journal/JournalCleanupCompactStressTest.java
----------------------------------------------------------------------
diff --git a/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/journal/JournalCleanupCompactStressTest.java b/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/journal/JournalCleanupCompactStressTest.java
index ae2b2f1..849e285 100644
--- a/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/journal/JournalCleanupCompactStressTest.java
+++ b/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/journal/JournalCleanupCompactStressTest.java
@@ -486,7 +486,7 @@ public class JournalCleanupCompactStressTest extends ActiveMQTestBase {
while (running) {
long[] ids = new long[5];
// Append
- for (int i = 0; running & i < ids.length; i++) {
+ for (int i = 0; running && i < ids.length; i++) {
System.out.println("append slow");
ids[i] = JournalCleanupCompactStressTest.idGen.generateID();
maxRecords.acquire();
@@ -500,7 +500,7 @@ public class JournalCleanupCompactStressTest extends ActiveMQTestBase {
rwLock.readLock().lock();
}
// Delete
- for (int i = 0; running & i < ids.length; i++) {
+ for (int i = 0; running && i < ids.length; i++) {
System.out.println("Deleting");
maxRecords.release();
journal.appendDeleteRecord(ids[i], false);