github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

queue test cleanup

Browse source 
Fixes #6297
This commit is contained in:
Joao Duarte 2016-11-24 12:41:04 +00:00 • committed by João Duarte
parent 2f6a472f52
commit 697f6c1edf
1 changed files with 2 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

28
logstash-core/src/test/java/org/logstash/ackedqueue/QueueTest.java
View file

@ -399,7 +399,7 @@ public class QueueTest {
TestQueue q = new TestQueue(settings);
q.open();
int ELEMENT_COUNT = 99; // should be able to write 100 events before getting full
int ELEMENT_COUNT = 99; // should be able to write 99 events before getting full
for (int i = 0; i < ELEMENT_COUNT; i++) {
long seqNum = q.write(element);
}
@ -416,32 +416,8 @@ public class QueueTest {
Thread.sleep(1);
assertThat(q.isFull(), is(true));
// spin wait until data is written and write blocks
//while (!q.isFull()) { Thread.sleep(1); }
/*
// read one element, which will unblock the last write
Batch b = q.nonBlockReadBatch(1);
assertThat(b, is(notNullValue()));
assertThat(b.getElements().size(), is(equalTo(1)));
b.close();
// future result is the blocked write seqNum for the second element
assertThat(future.get(), is(equalTo(2L + i)));
assertThat(q.isFull(), is(false));
executor.shutdown();
}
// all batches are acked, no tail pages should exist
assertThat(q.getTailPages().size(), is(equalTo(0)));
// the last read unblocked the last write so some elements (1 unread and maybe some acked) should be in the head page
assertThat(q.getHeadPage().getElementCount() > 0L, is(true));
assertThat(q.getHeadPage().unreadCount(), is(equalTo(1L)));
assertThat(q.unreadCount, is(equalTo(1L)));
*/
executor.shutdown();
}
}