andi/perfdb
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Activity

PdbWriters are now closed by the cache TagsToFile

Browse Source 
we do not have to close the files when the input streams are idle.
This commit is contained in:
Andreas Huber
2018-10-03 16:47:29 +02:00
parent ad630fc6b2
commit 60578b45ec
1 changed files with 1 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java
View File

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