diff --git a/src/main/java/org/torproject/collector/sync/SyncManager.java b/src/main/java/org/torproject/collector/sync/SyncManager.java index 1390d50..ab7d4b6 100644 --- a/src/main/java/org/torproject/collector/sync/SyncManager.java +++ b/src/main/java/org/torproject/collector/sync/SyncManager.java @@ -78,15 +78,16 @@ public class SyncManager { DescriptorReader descriptorReader = DescriptorSourceFactory.createDescriptorReader(); descriptorReader.addDirectory(new File(base, entry.getKey())); + String histFileEnding = entry.getValue().getSimpleName() + + (entry.getKey().contains("consensus-microdesc") + ? "-micro" : ""); descriptorReader.setExcludeFiles(new File(basePath.toFile(), "sync-history-" + source.getHost() + "-" + marker + "-" - + entry.getValue().getSimpleName())); - log.info("Reading {} of type {} ... ", marker, - entry.getValue().getSimpleName()); + + histFileEnding)); + log.info("Reading {} of type {} ... ", marker, histFileEnding); Iterator descriptorFiles = descriptorReader.readDescriptors(); - log.info("Done reading {} of type {}.", - marker, entry.getValue().getSimpleName()); + log.info("Done reading {} of type {}.", marker, histFileEnding); Criterium crit = new ProcessCriterium(entry.getValue()); while (descriptorFiles.hasNext()) { DescriptorFile descFile = descriptorFiles.next();