package org.eclipse.linuxtools.tmf.core.trace;
import java.io.File;
-import java.io.FileNotFoundException;
import org.eclipse.core.resources.IResource;
import org.eclipse.core.runtime.Path;
* TmfCheckpointIndexer (default). In this case, the trace cache size will be
* used as checkpoint interval.
*
- * @since 1.0
* @version 1.0
* @author Francois Chouinard
*
*/
public abstract class TmfTrace<T extends ITmfEvent> extends TmfEventProvider<T> implements ITmfTrace<T> {
- // ------------------------------------------------------------------------
- // Constants
- // ------------------------------------------------------------------------
-
- /**
- * The default trace cache size
- */
- public static final int DEFAULT_TRACE_CACHE_SIZE = 10000;
-
// ------------------------------------------------------------------------
// Attributes
// ------------------------------------------------------------------------
// The trace path
private String fPath;
- /**
- * The trace cache page size
- */
- protected int fCacheSize = DEFAULT_TRACE_CACHE_SIZE;
+ // The trace cache page size
+ private int fCacheSize = ITmfTrace.DEFAULT_TRACE_CACHE_SIZE;
- /**
- * The number of events collected (so far)
- */
- protected long fNbEvents = 0;
+ // The number of events collected (so far)
+ private long fNbEvents = 0;
// The time span of the event stream
private ITmfTimestamp fStartTime = TmfTimestamp.BIG_CRUNCH;
private ITmfTimestamp fEndTime = TmfTimestamp.BIG_BANG;
- /**
- * The trace streaming interval (0 = no streaming)
- */
- protected long fStreamingInterval = 0;
+ // The trace streaming interval (0 = no streaming)
+ private long fStreamingInterval = 0;
- /**
- * The trace indexer
- */
- protected ITmfTraceIndexer<ITmfTrace<ITmfEvent>> fIndexer;
+ // The trace indexer
+ private ITmfTraceIndexer<ITmfTrace<ITmfEvent>> fIndexer;
- /**
- * The trace parser
- */
- protected ITmfEventParser<T> fParser;
+ // The trace parser
+ private ITmfEventParser<T> fParser;
// ------------------------------------------------------------------------
// Construction
*/
protected TmfTrace(final IResource resource, final Class<T> type, final String path, final int cacheSize,
final long interval, final ITmfTraceIndexer<?> indexer) throws TmfTraceException {
- this(resource, type, path, cacheSize, interval, null, null);
+ this(resource, type, path, cacheSize, interval, indexer, null);
}
/**
protected TmfTrace(final IResource resource, final Class<T> type, final String path, final int cacheSize,
final long interval, final ITmfTraceIndexer<?> indexer, final ITmfEventParser<T> parser) throws TmfTraceException {
super();
- fCacheSize = (cacheSize > 0) ? cacheSize : DEFAULT_TRACE_CACHE_SIZE;
+ fCacheSize = (cacheSize > 0) ? cacheSize : ITmfTrace.DEFAULT_TRACE_CACHE_SIZE;
fStreamingInterval = interval;
fIndexer = (indexer != null) ? indexer : new TmfCheckpointIndexer(this, fCacheSize);
fParser = parser;
@SuppressWarnings({ "unchecked", "rawtypes" })
public TmfTrace(final TmfTrace<T> trace) throws TmfTraceException {
super();
- if (trace == null)
+ if (trace == null) {
throw new IllegalArgumentException();
+ }
fCacheSize = trace.getCacheSize();
fStreamingInterval = trace.getStreamingInterval();
fIndexer = new TmfCheckpointIndexer(this);
* @param path the trace path
* @param type the trace event type
*
- * @throws FileNotFoundException
+ * @throws TmfTraceException
*/
@SuppressWarnings("unchecked")
protected void initialize(final IResource resource, final String path, final Class<T> type) throws TmfTraceException {
- if (path == null)
+ if (path == null) {
throw new TmfTraceException("Invalid trace path"); //$NON-NLS-1$
+ }
fPath = path;
fResource = resource;
String traceName = (resource != null) ? resource.getName() : null;
return fStreamingInterval;
}
+ /**
+ * @return the trace indexer
+ */
+ protected ITmfTraceIndexer<ITmfTrace<ITmfEvent>> getIndexer() {
+ return fIndexer;
+ }
+
+ /**
+ * @return the trace parser
+ */
+ protected ITmfEventParser<T> getParser() {
+ return fParser;
+ }
+
// ------------------------------------------------------------------------
// ITmfTrace - Trace characteristics getters
// ------------------------------------------------------------------------
}
// ------------------------------------------------------------------------
- // Convenience setters
+ // Convenience setters/getters
// ------------------------------------------------------------------------
+ /**
+ * Set the trace cache size. Must be done at initialization time.
+ *
+ * @param cacheSize The trace cache size
+ */
+ protected void setCacheSize(final int cacheSize) {
+ fCacheSize = cacheSize;
+ }
+
+ /**
+ * Set the trace known number of events. This can be quite dynamic
+ * during indexing or for live traces.
+ *
+ * @param nbEvents The number of events
+ */
+ protected synchronized void setNbEvents(final long nbEvents) {
+ fNbEvents = (nbEvents > 0) ? nbEvents : 0;
+ }
+
/**
* Update the trace events time range
*
}
/**
- * Update the trace streaming interval
+ * Set the polling interval for live traces (default = 0 = no streaming).
*
* @param interval the new trace streaming interval
*/
fStreamingInterval = (interval > 0) ? interval : 0;
}
+ /**
+ * Set the trace indexer. Must be done at initialization time.
+ *
+ * @param indexer the trace indexer
+ */
+ protected void setIndexer(final ITmfTraceIndexer<ITmfTrace<ITmfEvent>> indexer) {
+ fIndexer = indexer;
+ }
+
+ /**
+ * Set the trace parser. Must be done at initialization time.
+ *
+ * @param parser the new trace parser
+ */
+ protected void setParser(final ITmfEventParser<T> parser) {
+ fParser = parser;
+ }
+
// ------------------------------------------------------------------------
// ITmfTrace - SeekEvent operations (returning a trace context)
// ------------------------------------------------------------------------
context.increaseRank();
event = readNextEvent(nextEventContext);
}
+ if (event == null) {
+ context.setLocation(null);
+ context.setRank(ITmfContext.UNKNOWN_RANK);
+ }
return context;
}
@Override
public ITmfContext armRequest(final ITmfDataRequest<T> request) {
if (request instanceof ITmfEventRequest<?>
- && !TmfTimestamp.BIG_BANG.equals(((ITmfEventRequest<T>) request).getRange().getStartTime())
- && request.getIndex() == 0) {
+ && !TmfTimestamp.BIG_BANG.equals(((ITmfEventRequest<T>) request).getRange().getStartTime())
+ && request.getIndex() == 0)
+ {
final ITmfContext context = seekEvent(((ITmfEventRequest<T>) request).getRange().getStartTime());
((ITmfEventRequest<T>) request).setStartIndex((int) context.getRank());
return context;
@Override
@SuppressWarnings("unchecked")
public T getNext(final ITmfContext context) {
- if (context instanceof TmfContext)
+ if (context instanceof TmfContext) {
return (T) readNextEvent(context);
+ }
return null;
}
projects / deliverable / tracecompass.git / blobdiff