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

make some Queue tests less aggressive on Thread.sleep usage

Browse source 
Fixes #6297
This commit is contained in:
Joao Duarte 2016-11-28 09:45:16 +00:00 • committed by João Duarte
parent fe4118288e
commit a4140dab6b
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -417,7 +417,7 @@ public class QueueTest {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<Long> future = executor.submit(write);
while (!q.isFull()) { Thread.sleep(1); }
while (!q.isFull()) { Thread.sleep(10); }
assertThat(q.isFull(), is(true));
@ -452,7 +452,7 @@ public class QueueTest {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<Long> future = executor.submit(write);
while (!q.isFull()) { Thread.sleep(1); }
while (!q.isFull()) { Thread.sleep(10); }
assertThat(q.isFull(), is(true));
@ -460,7 +460,7 @@ public class QueueTest {
b.close(); // purge 1 page
// spin wait until data is written and write blocks
while (q.isFull()) { Thread.sleep(1); }
while (q.isFull()) { Thread.sleep(10); }
assertThat(q.isFull(), is(false));
@ -495,7 +495,7 @@ public class QueueTest {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<Long> future = executor.submit(write);
while (!q.isFull()) { Thread.sleep(1); }
while (!q.isFull()) { Thread.sleep(10); }
assertThat(q.isFull(), is(true));