Remove the generic location (replace by Comparable)

[deliverable/tracecompass.git] / org.eclipse.linuxtools.tmf.core.tests / stubs / org / eclipse / linuxtools / tmf / tests / stubs / trace / TmfTraceStub.java

diff --git a/org.eclipse.linuxtools.tmf.core.tests/stubs/org/eclipse/linuxtools/tmf/tests/stubs/trace/TmfTraceStub.java b/org.eclipse.linuxtools.tmf.core.tests/stubs/org/eclipse/linuxtools/tmf/tests/stubs/trace/TmfTraceStub.java
index 69d3a87424e81ad84504ace5d4e28437677af46d..fed0590eb3105e8f4fe7d50cbf20aa23c49fb5a9 100644 (file)
--- a/org.eclipse.linuxtools.tmf.core.tests/stubs/org/eclipse/linuxtools/tmf/tests/stubs/trace/TmfTraceStub.java
+++ b/org.eclipse.linuxtools.tmf.core.tests/stubs/org/eclipse/linuxtools/tmf/tests/stubs/trace/TmfTraceStub.java
@@ -1,11 +1,11 @@
 /*******************************************************************************
  * Copyright (c) 2009, 2010 Ericsson
- * 
+ *
  * All rights reserved. This program and the accompanying materials are
  * made available under the terms of the Eclipse Public License v1.0 which
  * accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v10.html
- * 
+ *
  * Contributors:
  *   Francois Chouinard - Initial API and implementation
  *******************************************************************************/
@@ -17,17 +17,20 @@ import java.io.IOException;
 import java.io.RandomAccessFile;
 import java.util.concurrent.locks.ReentrantLock;
 
+import org.eclipse.core.resources.IProject;
 import org.eclipse.core.resources.IResource;
 import org.eclipse.linuxtools.tmf.core.event.ITmfEvent;
 import org.eclipse.linuxtools.tmf.core.event.ITmfTimestamp;
 import org.eclipse.linuxtools.tmf.core.event.TmfEvent;
 import org.eclipse.linuxtools.tmf.core.event.TmfTimeRange;
+import org.eclipse.linuxtools.tmf.core.exceptions.TmfTraceException;
 import org.eclipse.linuxtools.tmf.core.trace.ITmfContext;
 import org.eclipse.linuxtools.tmf.core.trace.ITmfEventParser;
 import org.eclipse.linuxtools.tmf.core.trace.ITmfLocation;
+import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;
 import org.eclipse.linuxtools.tmf.core.trace.ITmfTraceIndexer;
 import org.eclipse.linuxtools.tmf.core.trace.TmfContext;
-import org.eclipse.linuxtools.tmf.core.trace.TmfLocation;
+import org.eclipse.linuxtools.tmf.core.trace.TmfLongLocation;
 import org.eclipse.linuxtools.tmf.core.trace.TmfTrace;
 
 /**
@@ -35,8 +38,8 @@ import org.eclipse.linuxtools.tmf.core.trace.TmfTrace;
  * <p>
  * Dummy test trace. Use in conjunction with TmfEventParserStub.
  */
-@SuppressWarnings("nls")
-public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<TmfEvent> {
+@SuppressWarnings({"nls","javadoc"})
+public class TmfTraceStub extends TmfTrace implements ITmfEventParser {
 
     // ------------------------------------------------------------------------
     // Attributes
@@ -55,21 +58,17 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
     // Constructors
     // ------------------------------------------------------------------------
 
-    /**
-     * @param path
-     * @throws FileNotFoundException
-     */
     public TmfTraceStub() {
         super();
-        fParser = new TmfEventParserStub(this);
+        setParser(new TmfEventParserStub(this));
     }
 
     /**
      * @param path
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path) throws FileNotFoundException {
-        this(path, DEFAULT_TRACE_CACHE_SIZE, false);
+    public TmfTraceStub(final String path) throws TmfTraceException {
+        this(path, ITmfTrace.DEFAULT_TRACE_CACHE_SIZE, false);
     }
 
     /**
@@ -77,7 +76,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param cacheSize
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path, final int cacheSize) throws FileNotFoundException {
+    public TmfTraceStub(final String path, final int cacheSize) throws TmfTraceException {
         this(path, cacheSize, false);
     }
 
@@ -86,10 +85,14 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param cacheSize
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path, final int cacheSize, final long interval) throws FileNotFoundException {
+    public TmfTraceStub(final String path, final int cacheSize, final long interval) throws TmfTraceException {
         super(null, TmfEvent.class, path, cacheSize, interval);
-        fTrace = new RandomAccessFile(path, "r");
-        fParser = new TmfEventParserStub(this);
+        try {
+            fTrace = new RandomAccessFile(path, "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser(new TmfEventParserStub(this));
     }
 
     /**
@@ -97,7 +100,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param cacheSize
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path, final int cacheSize, final ITmfTraceIndexer<?> indexer) throws FileNotFoundException {
+    public TmfTraceStub(final String path, final int cacheSize, final ITmfTraceIndexer indexer) throws TmfTraceException {
         this(path, cacheSize, false, null, indexer);
     }
 
@@ -106,8 +109,8 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param waitForCompletion
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path, final boolean waitForCompletion) throws FileNotFoundException {
-        this(path, DEFAULT_TRACE_CACHE_SIZE, waitForCompletion);
+    public TmfTraceStub(final String path, final boolean waitForCompletion) throws TmfTraceException {
+        this(path, ITmfTrace.DEFAULT_TRACE_CACHE_SIZE, waitForCompletion);
     }
 
     /**
@@ -116,10 +119,17 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param waitForCompletion
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final String path, final int cacheSize, final boolean waitForCompletion) throws FileNotFoundException {
+    public TmfTraceStub(final String path, final int cacheSize, final boolean waitForCompletion) throws TmfTraceException {
         super(null, TmfEvent.class, path, cacheSize);
-        fTrace = new RandomAccessFile(path, "r");
-        fParser = new TmfEventParserStub(this);
+        try {
+            fTrace = new RandomAccessFile(path, "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser(new TmfEventParserStub(this));
+        if (waitForCompletion) {
+            indexTrace();
+        }
     }
 
     /**
@@ -128,10 +138,14 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param waitForCompletion
      * @throws FileNotFoundException
      */
-    public TmfTraceStub(final IResource resource,  final String path, final int cacheSize, final boolean waitForCompletion) throws FileNotFoundException {
+    public TmfTraceStub(final IResource resource,  final String path, final int cacheSize, final boolean waitForCompletion) throws TmfTraceException {
         super(resource, TmfEvent.class, path, cacheSize);
-        fTrace = new RandomAccessFile(path, "r");
-        fParser = new TmfEventParserStub(this);
+        try {
+            fTrace = new RandomAccessFile(path, "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser(new TmfEventParserStub(this));
     }
 
     /**
@@ -141,36 +155,47 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
      * @param parser
      * @throws FileNotFoundException
      */
-    @SuppressWarnings("unchecked")
     public TmfTraceStub(final String path, final int cacheSize, final boolean waitForCompletion,
-            final ITmfEventParser<TmfEvent> parser, final ITmfTraceIndexer<?> indexer) throws FileNotFoundException {
+            final ITmfEventParser parser, final ITmfTraceIndexer indexer) throws TmfTraceException {
         super(null, TmfEvent.class, path, cacheSize, 0, indexer);
-        fTrace = new RandomAccessFile(path, "r");
-        fParser = (ITmfEventParser<ITmfEvent>) ((parser != null) ? parser : new TmfEventParserStub(this));
+        try {
+            fTrace = new RandomAccessFile(path, "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser((parser != null) ? parser : new TmfEventParserStub(this));
     }
 
     /**
      * Copy constructor
      */
-    public TmfTraceStub(final TmfTraceStub trace) throws FileNotFoundException {
+    public TmfTraceStub(final TmfTraceStub trace) throws TmfTraceException {
         super(trace);
-        fTrace = new RandomAccessFile(getPath(), "r");
-        fParser = new TmfEventParserStub(this);
+        try {
+            fTrace = new RandomAccessFile(getPath(), "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser(new TmfEventParserStub(this));
     }
 
     public void indexTrace() {
-        fIndexer.buildIndex(true);
+        indexTrace(true);
     }
 
     @Override
-    public void initTrace(final IResource resource, final String path, final Class<TmfEvent> type) throws FileNotFoundException {
-        fTrace = new RandomAccessFile(path, "r");
-        fParser = new TmfEventParserStub(this);
+    public void initTrace(final IResource resource, final String path, final Class<? extends ITmfEvent> type) throws TmfTraceException {
+        try {
+            fTrace = new RandomAccessFile(path, "r");
+        } catch (FileNotFoundException e) {
+            throw new TmfTraceException(e.getMessage());
+        }
+        setParser(new TmfEventParserStub(this));
         super.initTrace(resource, path, type);
     }
 
     @Override
-    public void initialize(final IResource resource, final String path, final Class<TmfEvent> type) throws FileNotFoundException {
+    public void initialize(final IResource resource, final String path, final Class<? extends ITmfEvent> type) throws TmfTraceException {
         super.initialize(resource, path, type);
     }
 
@@ -187,8 +212,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
     // ------------------------------------------------------------------------
 
     @Override
-    @SuppressWarnings("unchecked")
-    public TmfContext seekEvent(final ITmfLocation<?> location) {
+    public TmfContext seekEvent(final ITmfLocation location) {
         try {
             fLock.lock();
             try {
@@ -198,7 +222,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
                     long loc  = 0;
                     long rank = 0;
                     if (location != null) {
-                        loc = ((TmfLocation<Long>) location).getLocation();
+                        loc = (Long) location.getLocationData();
                         rank = ITmfContext.UNKNOWN_RANK;
                     }
                     if (loc != fTrace.getFilePointer()) {
@@ -212,12 +236,12 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
             } catch (final NullPointerException e) {
                 e.printStackTrace();
             }
+            finally{
+                fLock.unlock();
+            }
         } catch (final NullPointerException e) {
             e.printStackTrace();
         }
-        finally{
-            fLock.unlock();
-        }
         return null;
     }
 
@@ -227,7 +251,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
         fLock.lock();
         try {
             if (fTrace != null) {
-                final ITmfLocation<?> location = new TmfLocation<Long>(Long.valueOf((long) (ratio * fTrace.length())));
+                final ITmfLocation location = new TmfLongLocation(Long.valueOf((long) (ratio * fTrace.length())));
                 final TmfContext context = seekEvent(location);
                 context.setRank(ITmfContext.UNKNOWN_RANK);
                 return context;
@@ -242,13 +266,14 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
     }
 
     @Override
-    @SuppressWarnings("rawtypes")
-    public double getLocationRatio(final ITmfLocation location) {
+    public double getLocationRatio(ITmfLocation location) {
         fLock.lock();
         try {
-            if (fTrace != null)
-                if (location.getLocation() instanceof Long)
-                    return (double) ((Long) location.getLocation()) / fTrace.length();
+            if (fTrace != null) {
+                if (location.getLocationData() instanceof Long) {
+                    return (double) ((Long) location.getLocationData()) / fTrace.length();
+                }
+            }
         } catch (final IOException e) {
             e.printStackTrace();
         } finally {
@@ -258,11 +283,12 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
     }
 
     @Override
-    public TmfLocation<Long> getCurrentLocation() {
+    public ITmfLocation getCurrentLocation() {
         fLock.lock();
         try {
-            if (fTrace != null)
-                return new TmfLocation<Long>(fTrace.getFilePointer());
+            if (fTrace != null) {
+                return new TmfLongLocation(fTrace.getFilePointer());
+            }
         } catch (final IOException e) {
             e.printStackTrace();
         } finally {
@@ -276,19 +302,21 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
         fLock.lock();
         try {
             // parseNextEvent will update the context
-            if (fTrace != null) {
-                final ITmfEvent event = fParser.parseEvent(context.clone());
+            if (fTrace != null && getParser() != null && context != null) {
+                final ITmfEvent event = getParser().parseEvent(context.clone());
                 return event;
             }
-//        }
-//        catch (final IOException e) {
-//            e.printStackTrace();
         } finally {
             fLock.unlock();
         }
         return null;
     }
 
+    @Override
+    public synchronized void setNbEvents(final long nbEvents) {
+        super.setNbEvents(nbEvents);
+    }
+
     @Override
     public void setTimeRange(final TmfTimeRange range) {
         super.setTimeRange(range);
@@ -310,7 +338,7 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
     }
 
     @Override
-    public void dispose() {
+    public synchronized void dispose() {
         fLock.lock();
         try {
             if (fTrace != null) {
@@ -325,4 +353,12 @@ public class TmfTraceStub extends TmfTrace<TmfEvent> implements ITmfEventParser<
         super.dispose();
     }
 
-}
\ No newline at end of file
+    /* (non-Javadoc)
+     * @see org.eclipse.linuxtools.tmf.core.trace.ITmfTrace#validate(org.eclipse.core.resources.IProject, java.lang.String)
+     */
+    @Override
+    public boolean validate(IProject project, String path) {
+        return fileExists(path);
+    }
+
+}