summaryrefslogtreecommitdiff
path: root/dslog/Main.java
diff options
context:
space:
mode:
Diffstat (limited to 'dslog/Main.java')
-rw-r--r--dslog/Main.java37
1 files changed, 29 insertions, 8 deletions
diff --git a/dslog/Main.java b/dslog/Main.java
index 40851bc..f8a2196 100644
--- a/dslog/Main.java
+++ b/dslog/Main.java
@@ -4,9 +4,10 @@ import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.ArrayList;
-import java.util.HashMap;
import java.util.List;
+import java.util.SortedMap;
import java.util.Map;
+import java.util.TreeMap;
class Main {
public static void dslog2csv(String[] args) throws IOException {
@@ -20,9 +21,17 @@ class Main {
}
public static class LogSet {
+ public String name;
public DslogReader dslog;
public DseventsReader dsevents;
public PdplogReader pdplog;
+
+ public String toString() {
+ return name
+ +" "+(dslog == null ? "␕" : dslog.version)
+ +"/"+(dsevents == null ? "␕" : dsevents.version)
+ +"/"+(pdplog == null ? "␕" : pdplog.version);
+ }
}
private static LogSet getSet(Map<String, LogSet> sets, String name) {
@@ -31,6 +40,7 @@ class Main {
set = sets.get(name);
if (set == null) {
set = new LogSet();
+ set.name = name;
sets.put(name, set);
}
}
@@ -39,27 +49,38 @@ class Main {
public static void main(String[] args) throws IOException {
for (String dirname : args) {
- Map<String, LogSet> logsets = new HashMap<String, LogSet>();
+ SortedMap<String, LogSet> logsets = new TreeMap<String, LogSet>();
List<Exception> errs = new ArrayList<Exception>();
Files.list(Paths.get(dirname)).parallel().forEach(filepath->{
try {
String filename = filepath.getFileName().toString();
if (filename.endsWith(".dslog")) {
- String setname = filename.substring(0, filename.lastIndexOf('.'));
- getSet(logsets, setname).dslog = new DslogReader(Files.newInputStream(filepath));
+ try (DslogReader dslog = new DslogReader(Files.newInputStream(filepath))) {
+ String setname = filename.substring(0, filename.lastIndexOf('.'));
+ getSet(logsets, setname).dslog = dslog;
+ }
} else if (filename.endsWith(".dsevents")) {
+ try (DseventsReader dsevents = new DseventsReader(Files.newInputStream(filepath))) {
String setname = filename.substring(0, filename.lastIndexOf('.'));
- getSet(logsets, setname).dsevents = new DseventsReader(Files.newInputStream(filepath));
+ getSet(logsets, setname).dsevents = dsevents;
+ }
} else if (filename.endsWith(".pdplog")) {
- String setname = filename.substring(0, filename.lastIndexOf('.'));
- getSet(logsets, setname).pdplog = new PdplogReader(Files.newInputStream(filepath));
+ try (PdplogReader pdplog = new PdplogReader(Files.newInputStream(filepath))) {
+ String setname = filename.substring(0, filename.lastIndexOf('.'));
+ getSet(logsets, setname).pdplog = pdplog;
+ }
}
} catch (Exception e) {
synchronized (errs) {
- errs.add(new IOException("Could not read file: "+filepath.toString(), e));
+ e = new IOException("Could not read file: "+filepath.toString(), e);
+ errs.add(e);
+ e.printStackTrace();
}
}
});
+ logsets.forEach((k,v)->{
+ System.out.println(v);
+ });
}
}
}