import org.eclipse.core.runtime.Status;
import org.eclipse.core.runtime.jobs.Job;
import org.eclipse.linuxtools.tmf.core.component.TmfEventProvider;
+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.event.TmfTimestamp;
import org.eclipse.linuxtools.tmf.core.request.ITmfDataRequest;
* TmfExperiment presents a time-ordered, unified view of a set of TmfTraces that are part of a tracing experiment.
* <p>
*/
-public class TmfExperiment<T extends TmfEvent> extends TmfEventProvider<T> implements ITmfTrace<T> {
+public class TmfExperiment<T extends ITmfEvent> extends TmfEventProvider<T> implements ITmfTrace<T> {
// ------------------------------------------------------------------------
// Attributes
*/
public ITmfTimestamp getTimestamp(int index) {
TmfExperimentContext context = seekEvent(index);
- TmfEvent event = getNextEvent(context);
+ ITmfEvent event = getNextEvent(context);
return (event != null) ? event.getTimestamp() : null;
}
context.setRank((long) index * fIndexPageSize);
// And locate the event
- TmfEvent event = parseEvent(context);
+ ITmfEvent event = parseEvent(context);
while (event != null && event.getTimestamp().compareTo(timestamp, false) < 0) {
getNextEvent(context);
event = parseEvent(context);
context.setRank((long) index * fIndexPageSize);
// And locate the event
- TmfEvent event = parseEvent(context);
+ ITmfEvent event = parseEvent(context);
long pos = context.getRank();
while (event != null && pos++ < rank) {
getNextEvent(context);
// }
@Override
- public synchronized TmfEvent getNextEvent(TmfContext context) {
+ public synchronized ITmfEvent getNextEvent(TmfContext context) {
// Validate the context
if (!(context instanceof TmfExperimentContext)) {
}
// Scan the candidate events and identify the "next" trace to read from
- TmfEvent eventArray[] = expContext.getEvents();
+ ITmfEvent eventArray[] = expContext.getEvents();
if (eventArray == null) {
return null;
}
}
} else {
for (int i = 0; i < eventArray.length; i++) {
- TmfEvent event = eventArray[i];
+ ITmfEvent event = eventArray[i];
if (event != null && event.getTimestamp() != null) {
ITmfTimestamp otherTS = event.getTimestamp();
if (otherTS.compareTo(timestamp, true) < 0) {
}
}
// Update the experiment context and set the "next" event
- TmfEvent event = null;
+ ITmfEvent event = null;
if (trace != TmfExperimentContext.NO_TRACE) {
updateIndex(expContext, timestamp);
* @see org.eclipse.linuxtools.tmf.trace.ITmfTrace#parseEvent(org.eclipse.linuxtools .tmf.trace.TmfContext)
*/
@Override
- public TmfEvent parseEvent(TmfContext context) {
+ public ITmfEvent parseEvent(TmfContext context) {
// Validate the context
if (!(context instanceof TmfExperimentContext)) {
int trace = TmfExperimentContext.NO_TRACE;
ITmfTimestamp timestamp = TmfTimestamp.BigCrunch;
for (int i = 0; i < expContext.getTraces().length; i++) {
- TmfEvent event = expContext.getEvents()[i];
+ ITmfEvent event = expContext.getEvents()[i];
if (event != null && event.getTimestamp() != null) {
ITmfTimestamp otherTS = event.getTimestamp();
if (otherTS.compareTo(timestamp, true) < 0) {
}
}
- TmfEvent event = null;
+ ITmfEvent event = null;
if (trace != TmfExperimentContext.NO_TRACE) {
event = expContext.getEvents()[trace];
}
if (getStreamingInterval() == 0) {
TmfContext context = seekLocation(null);
- TmfEvent event = getNext(context);
+ ITmfEvent event = getNext(context);
if (event == null) {
return;
}
// fEventLog = openLogFile("TraceEvent.log");
// System.out.println(System.currentTimeMillis() + ": Experiment indexing started");
- ITmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, timeRange, index, TmfDataRequest.ALL_DATA,
+ ITmfEventRequest<ITmfEvent> request = new TmfEventRequest<ITmfEvent>(ITmfEvent.class, timeRange, index, TmfDataRequest.ALL_DATA,
fIndexPageSize, ITmfDataRequest.ExecutionType.BACKGROUND) { // PATA FOREGROUND
// long indexingStart = System.nanoTime();
}
@Override
- public void handleData(TmfEvent event) {
+ public void handleData(ITmfEvent event) {
super.handleData(event);
if (event != null) {
ITmfTimestamp ts = event.getTimestamp();