github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

replace decreasing timeout with fixed timeout

Browse source
This commit is contained in:
Colin Surprenant 2017-11-13 14:18:51 -05:00
parent 9525a806d7
commit 75b360f2ff
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
logstash-core/src/main/java/org/logstash/common/LsQueueUtils.java
View file

@ -77,13 +77,12 @@ public final class LsQueueUtils {
private static int drain(final BlockingQueue<JrubyEventExtLibrary.RubyEvent> queue, private static int drain(final BlockingQueue<JrubyEventExtLibrary.RubyEvent> queue,
final Collection<JrubyEventExtLibrary.RubyEvent> collection, final int count, final Collection<JrubyEventExtLibrary.RubyEvent> collection, final int count,
final long nanos) throws InterruptedException { final long nanos) throws InterruptedException {
final long deadline = System.nanoTime() + nanos;
int added = 0; int added = 0;
do { do {
added += queue.drainTo(collection, count - added); added += queue.drainTo(collection, count - added);
if (added < count) { if (added < count) {
final JrubyEventExtLibrary.RubyEvent event = final JrubyEventExtLibrary.RubyEvent event =
queue.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS); queue.poll(nanos, TimeUnit.NANOSECONDS);
if (event == null) { if (event == null) {
break; break;
} }