tmf.ctf: Re-initialize start and endtime after transform is applied

With this the start and endtime is correct when opening the experiment
that has automatically applied timestamp transformation applied.

fixes #323

Signed-off-by: Bernd Hufmann <[email protected]>

Author: bhufmann

ctf/org.eclipse.tracecompass.tmf.ctf.core/src/org/eclipse/tracecompass/tmf/ctf/core/trace/CtfTmfTrace.java

@@ -65,6 +65,7 @@
 import org.eclipse.tracecompass.tmf.core.event.aspect.TmfBaseAspects;
 import org.eclipse.tracecompass.tmf.core.exceptions.TmfTraceException;
 import org.eclipse.tracecompass.tmf.core.project.model.ITmfPropertiesProvider;
+import org.eclipse.tracecompass.tmf.core.synchronization.ITmfTimestampTransform;
 import org.eclipse.tracecompass.tmf.core.timestamp.ITmfTimestamp;
 import org.eclipse.tracecompass.tmf.core.timestamp.TmfTimeRange;
 import org.eclipse.tracecompass.tmf.core.timestamp.TmfTimestamp;
@@ -218,18 +219,11 @@ public void initTrace(final IResource resource, final String path, final Class<?
 
         try {
             this.fTrace = new CTFTrace(path);
-            CtfTmfContext ctx;
             /* Set the start and (current) end times for this trace */
-            ctx = (CtfTmfContext) seekEvent(0L);
-            CtfTmfEvent event = getNext(ctx);
-            if ((ctx.getLocation().equals(CtfIterator.NULL_LOCATION)) || (ctx.getCurrentEvent() == null)) {
-                /* Handle the case where the trace is empty */
-                this.setStartTime(TmfTimestamp.BIG_BANG);
-            } else {
-                final ITmfTimestamp curTime = event.getTimestamp();
-                this.setStartTime(curTime);
-                long endTime = Math.max(curTime.getValue(), fTrace.getCurrentEndTime());
-                this.setEndTime(TmfTimestamp.fromNanos(endTime));
+            CtfTmfContext ctx = resetTimes();
+
+            if (ctx == null) {
+                return;
             }
             /*
              * Register every event type. When you call getType, it will register a trace to
@@ -913,4 +907,32 @@ public Path trim(@NonNull TmfTimeRange range, @NonNull Path destinationPath, @No
         return null;
     }
 
+    @Override
+    public void setTimestampTransform(final ITmfTimestampTransform tt) {
+        super.setTimestampTransform(tt);
+        // Reset indexer so that transformed times are applied
+        resetIndexer();
+        resetTimes();
+    }
+
+    private @Nullable CtfTmfContext resetTimes() {
+        /* Set the start and (current) end times for this trace */
+        CtfTmfContext ctx = (CtfTmfContext) seekEvent(0L);
+        CtfTmfEvent event = getNext(ctx);
+        /* Verify context is valid. It's only invalid trace if trace.init() hasn't been called) */
+        if ((ctx != null) && (ctx.getLocation() != null)) {
+            if ((ctx.getLocation().equals(CtfIterator.NULL_LOCATION)) || (ctx.getCurrentEvent() == null)) {
+                /* Handle the case where the trace is empty */
+                this.setStartTime(TmfTimestamp.BIG_BANG);
+            } else {
+                final ITmfTimestamp curTime = event.getTimestamp();
+                this.setStartTime(curTime);
+                long endTime = createTimestamp(fTrace.getCurrentEndTime()).getValue();
+                endTime = Math.max(curTime.getValue(), endTime);
+                this.setEndTime(TmfTimestamp.fromNanos(endTime));
+            }
+            return ctx;
+        }
+        return null;
+    }
 }

tmf/org.eclipse.tracecompass.tmf.core/src/org/eclipse/tracecompass/tmf/core/trace/TmfTrace.java

@@ -222,6 +222,22 @@ protected ITmfTraceIndexer createIndexer(int interval) {
         return new TmfCheckpointIndexer(this, interval);
     }
 
+    /**
+     * Reset indexer. It dispose the old indexer and creates a new one,
+     *
+     * Note:
+     * Only call this when there is no trace reading is ongoing. Caller
+     * needs to ensure that trace indexing is restarted.
+     *
+     * @since 10.1
+     */
+    protected synchronized void resetIndexer() {
+        if (fIndexer != null) {
+            fIndexer.dispose();
+        }
+        fIndexer = createIndexer(fCacheSize);
+    }
+
     // ------------------------------------------------------------------------
     // ITmfTrace - Initializers
     // ------------------------------------------------------------------------
@@ -379,6 +395,7 @@ public synchronized void dispose() {
         ByteBufferTracker.setMarked();
     }
 
+
     // ------------------------------------------------------------------------
     // ITmfTrace - Basic getters
     // ------------------------------------------------------------------------