Fix bug when tracefile is not aligned. Now supports exotic architectures.

[deliverable/tracecompass.git] / org.eclipse.linuxtools.ctf.core.tests / src / org / eclipse / linuxtools / ctf / core / tests / headless / ReadTrace.java

diff --git a/org.eclipse.linuxtools.ctf.core.tests/src/org/eclipse/linuxtools/ctf/core/tests/headless/ReadTrace.java b/org.eclipse.linuxtools.ctf.core.tests/src/org/eclipse/linuxtools/ctf/core/tests/headless/ReadTrace.java
index 07cdfbfe2596a4cabb72e08e0ebc3758cc6a9c28..9f09b810fbe79f6bf7d50beae826877d9b842f18 100644 (file)
--- a/org.eclipse.linuxtools.ctf.core.tests/src/org/eclipse/linuxtools/ctf/core/tests/headless/ReadTrace.java
+++ b/org.eclipse.linuxtools.ctf.core.tests/src/org/eclipse/linuxtools/ctf/core/tests/headless/ReadTrace.java
@@ -15,6 +15,7 @@ package org.eclipse.linuxtools.ctf.core.tests.headless;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
 import java.util.Date;
+import java.util.Vector;
 
 import org.eclipse.linuxtools.ctf.core.event.EventDefinition;
 import org.eclipse.linuxtools.ctf.core.trace.CTFReaderException;
@@ -28,46 +29,129 @@ public class ReadTrace {
      */
     @SuppressWarnings("nls")
     public static void main(String[] args) {
-        final String TRACE_PATH = "Tests/traces/trace20m1";
+        final String TRACE_PATH = "/home/ematkho/lttng-traces/lt-hello-4175-20120405-092230";
 
         // Change this to enable text output
         final boolean USE_TEXT = true;
 
+        final int LOOP_COUNT = 1;
+
         // Work variables
         Long nbEvent = 0L;
+        Vector<Double> benchs = new Vector<Double>();
         CTFTrace trace = null;
-        try {
-            trace = new CTFTrace(TRACE_PATH);
-        } catch (CTFReaderException e) {
-
-            nbEvent = (long) -1;
-        }
         long start, stop;
-        start = System.nanoTime();
-        if (nbEvent != -1) {
-            CTFTraceReader traceReader = new CTFTraceReader(trace);
-
+        for (int loops = 0; loops < LOOP_COUNT; loops++) {
+            try {
+                nbEvent = 0L;
+                trace = new CTFTrace(TRACE_PATH);
+            } catch (CTFReaderException e) {
+                // do nothing
+            }
+            long prev = -1;
             start = System.nanoTime();
-            while (traceReader.hasMoreEvents()) {
-                EventDefinition ed = traceReader.getCurrentEventDef();
-                nbEvent++;
-                if (USE_TEXT) {
-                    String output = formatDate(ed.timestamp + trace.getOffset());
-                    System.out.println("Event " + nbEvent + " Time " + output
-                            + " type " + ed.getDeclaration().getName()
-                            + " on CPU " + ed.getCPU());
+            if (USE_TEXT) {
+                System.out.println("Event, " + " Time, " + " type, " + " CPU ");
+            }
+            if (trace != null) {
+                CTFTraceReader traceReader = new CTFTraceReader(trace);
+
+                start = System.nanoTime();
+
+                while (traceReader.hasMoreEvents()) {
+                    EventDefinition ed = traceReader.getCurrentEventDef();
+                    nbEvent++;
+                    if (prev == traceReader.getIndex()) {
+                        System.out.println("Error on events " + prev);
+                    }
+                    prev = traceReader.getIndex();
+                    if (USE_TEXT) {
+                        String output = formatDate(ed.timestamp
+                                + trace.getOffset());
+                        System.out.println(traceReader.getIndex() + ", "
+                                + output + ", " + ed.getDeclaration().getName()
+                                + ", " + ed.getCPU() + ed.getFields().toString()) ;
+                    }
+
+                    traceReader.advance();
                 }
-                traceReader.advance();
             }
+            stop = System.nanoTime();
+            System.out.print('.');
+            double time = (stop - start) / (double) nbEvent;
+            benchs.add(time);
+        }
+        System.out.println("");
+        double avg = 0;
+        for (Double val : benchs) {
+            avg += val;
+        }
+        avg /= benchs.size();
+        System.out.println("Time to read " + nbEvent + " events = " + avg
+                + " events/ns");
+        for (Double val : benchs) {
+            System.out.print(val);
+            System.out.print(", ");
         }
-        stop = System.nanoTime();
-        System.out.println("Time taken for " + nbEvent + " events " + (stop - start)
-                + "ns ");
-        System.out.println(((stop - start) / nbEvent) + "ns/event ");
+        testSeekIndex(trace);
+        testSeekIndex(trace);
+    }
+
+    /**
+     * @return
+     */
+    private static long getTimestamp(CTFTraceReader fixture) {
+        if (fixture.getCurrentEventDef() != null) {
+            return fixture.getCurrentEventDef().timestamp;
+        }
+        return Long.MIN_VALUE;
+    }
+
+    public static void testSeekIndex(CTFTrace trace) {
+        CTFTraceReader fixture = new CTFTraceReader(trace);
+        long rank = 300000L;
+        long timeRank = 4281275394331L;
+        long nearEnd = 4287422858132L;
+        long seekTime_0;
+        long seekIndex_0 = 0;
+        long seekNext_300000 = 0;
+        long seekIndex_300000 = 0;
+        long seekTime_300000 = 0;
+        String cr = "\n"; //$NON-NLS-1$
+        fixture.seek(0);
+        for (int i = 0; i < 100; i++) {
+            fixture.advance();
+        }
+
+        fixture.seek(nearEnd);
+        /*
+         * we need to read the trace before seeking
+         */
+        fixture.seek(0);
+        seekTime_0 = getTimestamp(fixture);
+        for (int i = 0; i < rank; i++) {
+            fixture.advance();
+        }
+        seekNext_300000 = getTimestamp(fixture);
+        fixture.seek(timeRank);
+        seekTime_300000 = getTimestamp(fixture);
+        fixture.seekIndex(0);
+        seekIndex_0 = getTimestamp(fixture);
+
+        fixture.seekIndex(rank);
+        seekIndex_300000 = getTimestamp(fixture);
+        System.out.print(cr);
+        System.out.println("seek(0) " + seekTime_0 + cr + //$NON-NLS-1$
+                "seekIndex(0) " + seekIndex_0 + cr + //$NON-NLS-1$
+                "Next(300000) " + seekNext_300000 + cr + //$NON-NLS-1$
+                "seek(time(300000)) " + seekTime_300000 + cr + //$NON-NLS-1$
+                "seekIndex(300000) " + seekIndex_300000 //$NON-NLS-1$
+        );
     }
 
     /**
-     * @param timestamp the timestamp in UTC to convert to nanoseconds.
+     * @param timestamp
+     *            the timestamp in UTC to convert to nanoseconds.
      * @return formatted string.
      */
     private static String formatDate(long timestamp) {