activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [02/11] activemq-artemis git commit: Fix journal compact test slow appender loop counters
Date Thu, 28 Jul 2016 21:27:09 GMT
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ä <ville.skytta@iki.fi>
Authored: Thu Jul 28 23:20:07 2016 +0300
Committer: Ville Skyttä <ville.skytta@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);


Mime
View raw message