Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix for: https://issues.apache.org/jira/browse/AMQ-3995 

Remove the long and not so useful serial add test.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1377779 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2012-08-27 18:26:22 +00:00
parent 6ce59ed1b0
commit 53f07b0a75
1 changed files with 0 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
View File

@ -48,7 +48,6 @@ public class PListTest {
final Vector<Throwable> exceptions = new Vector<Throwable>(); final Vector<Throwable> exceptions = new Vector<Throwable>();
ExecutorService executor; ExecutorService executor;
@Test @Test
public void testAddLast() throws Exception { public void testAddLast() throws Exception {
final int COUNT = 1000; final int COUNT = 1000;
@ -147,7 +146,6 @@ public class PListTest {
assertFalse(plist.remove("doesNotExist")); assertFalse(plist.remove("doesNotExist"));
} }
@Test @Test
public void testRemoveSingleEntry() throws Exception { public void testRemoveSingleEntry() throws Exception {
plist.addLast("First", new ByteSequence("A".getBytes())); plist.addLast("First", new ByteSequence("A".getBytes()));
@ -169,7 +167,6 @@ public class PListTest {
assertFalse(plist.remove(0)); assertFalse(plist.remove(0));
} }
@Test @Test
public void testConcurrentAddRemove() throws Exception { public void testConcurrentAddRemove() throws Exception {
File directory = store.getDirectory(); File directory = store.getDirectory();
@ -260,7 +257,6 @@ public class PListTest {
assertTrue("finished ok", finishedInTime); assertTrue("finished ok", finishedInTime);
} }
@Test @Test
public void testConcurrentAddLast() throws Exception { public void testConcurrentAddLast() throws Exception {
File directory = store.getDirectory(); File directory = store.getDirectory();
@ -310,7 +306,6 @@ public class PListTest {
LOG.info("After remove index file: " + store.pageFile.getFile().length()); LOG.info("After remove index file: " + store.pageFile.getFile().length());
} }
@Test @Test
public void testConcurrentAddRemoveWithPreload() throws Exception { public void testConcurrentAddRemoveWithPreload() throws Exception {
File directory = store.getDirectory(); File directory = store.getDirectory();
@ -442,40 +437,6 @@ public class PListTest {
assertTrue("test did not timeout ", shutdown); assertTrue("test did not timeout ", shutdown);
} }
@Test
public void testSerialAddIterate() throws Exception {
File directory = store.getDirectory();
store.stop();
IOHelper.mkdirs(directory);
IOHelper.deleteChildren(directory);
store = new PListStore();
store.setIndexPageSize(512);
store.setJournalMaxFileLength(100*1024);
store.setDirectory(directory);
store.setCleanupInterval(-1);
store.setIndexEnablePageCaching(false);
store.setIndexWriteBatchSize(2000);
store.setEnableIndexWriteAsync(false);
store.start();
final int iterations = 1000;
final int numLists = 1;
LOG.info("create");
for (int i=0; i<numLists;i++) {
new Job(i, PListTest.TaskType.CREATE, iterations).run();
}
LOG.info("serial add and iterate");
for (int i=0; i<iterations; i++) {
new Job(0, TaskType.ADD, i).run();
new Job(0, TaskType.ITERATE, 0).run();
}
assertTrue("no exceptions: " + exceptions, exceptions.isEmpty());
LOG.info("Num dataFiles:" + store.getJournal().getFiles().size());
}
@Test @Test
public void testConcurrentAddIterate() throws Exception { public void testConcurrentAddIterate() throws Exception {
File directory = store.getDirectory(); File directory = store.getDirectory();