minor unimportant changes

pdb-plotting/src/main/java/org/lucares/recommind/logs/TcpIngestor.java

@@ -155,7 +155,7 @@ public class TcpIngestor implements AutoCloseable {
 
 	public void start() throws Exception {
 
-		final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(100);
+		final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(1);
 
 		serverThreadPool.submit(() -> {
 			Thread.currentThread().setName("db-ingestion");

performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java

@@ -57,7 +57,7 @@ public class PerformanceDb implements AutoCloseable {
 
 	public void put(final BlockingIterator<Entry> entries) throws WriteException {
 
-		final int blocksize = 10000;
+		final int blocksize = 100000;
 		long count = 0;
 
 		try {
@@ -83,7 +83,8 @@ public class PerformanceDb implements AutoCloseable {
 					final long end = System.nanoTime();
 					final double duration = (end - start) / 1_000_000.0;
 					LOGGER.info("inserting the last " + blocksize + " took " + duration + " ms; " + Stats.duration
-							+ "ms of " + Stats.count + " operations. total entries: " + count);
+							+ "ms of " + Stats.count + " operations. total entries: " + count / 1_000_000.0
+							+ " million");
 
 					// System.out.println(entry);
 
@@ -91,6 +92,10 @@ public class PerformanceDb implements AutoCloseable {
 					Stats.duration = 0.0;
 					Stats.count = 0;
 				}
+
+				if (count % blocksize == 0) {
+					tagsToFile.flush();
+				}
 			}
 
 		} catch (final RuntimeException e) {

performanceDb/src/main/java/org/lucares/performance/db/Stats.java

@@ -9,5 +9,6 @@ public class Stats {
 		final long s = System.nanoTime();
 		final long e = System.nanoTime();
 		Stats.duration += (e - s) / 1_000_000.0;
+		Stats.count++;
 	}
 }

performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java

@@ -161,15 +161,11 @@ public class TagsToFile implements CollectionUtils, AutoCloseable {
 		final PdbWriter result;
 		final WriterCache writersForTags = getOrInit(tags);
 
-		final long s = System.nanoTime();
 		final Optional<PdbWriter> optionalWriter = chooseBestMatchingWriter(writersForTags.getWriters(), date);
-		final long e = System.nanoTime();
-		Stats.duration += (e - s) / 1_000_000.0;
 
 		if (optionalWriter.isPresent()) {
 			result = optionalWriter.get();
 		} else {
-			Stats.count++;
 			final List<PdbFile> pdbFiles = getFilesMatchingTagsExactly(tags);
 
 			assertAllFilesHaveSameFolder(pdbFiles);