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

replace decreasing timeout with fixed timeout

Browse source
This commit is contained in:
Colin Surprenant 2017-11-13 14:18:51 -05:00
parent 0371abad1d
commit c0d5c4e868
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,
final Collection<JrubyEventExtLibrary.RubyEvent> collection, final int count,
final long nanos) throws InterruptedException {
final long deadline = System.nanoTime() + nanos;
int added = 0;
do {
added += queue.drainTo(collection, count - added);
if (added < count) {
final JrubyEventExtLibrary.RubyEvent event =
queue.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
queue.poll(nanos, TimeUnit.NANOSECONDS);
if (event == null) {
break;
}