diff --git a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java index e1c2c09..64bf11d 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java @@ -9,8 +9,6 @@ import java.util.Iterator; import java.util.List; import java.util.Optional; import java.util.SortedSet; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; import java.util.stream.Stream; import org.lucares.collections.LongList; @@ -64,7 +62,7 @@ public class PerformanceDb implements AutoCloseable { long nextSync = lastSync + timeBetweenSyncs.toMillis(); while (true) { - final Optional entryOptional = nextEntry(entries); + final Optional entryOptional = entries.next(); if (!entryOptional.isPresent()) { break; } @@ -112,16 +110,6 @@ public class PerformanceDb implements AutoCloseable { } } - private Optional nextEntry(final BlockingIterator entries) throws InterruptedException { - - try { - return entries.next(10, TimeUnit.SECONDS); - } catch (final TimeoutException e) { - tagsToFile.clearWriterCache(); - } - return entries.next(); - } - /** * * @param query