}
}
- if (range != TmfTimeRange.Null) {
+ @TmfSignalHandler
+ public void experimentUpdated(TmfExperimentUpdatedSignal signal) {
+ if (signal.getExperiment().equals(TmfExperiment.getCurrentExperiment())) {
+ final TmfTimeRange range = signal.getExperiment().getTimeRange();
++ if (range != TmfTimeRange.NULL_RANGE) {
+ Display.getDefault().asyncExec(new Runnable() {
+ @Override
+ public void run() {
+ tsfviewer.setTimeBounds(range.getStartTime().getValue(), range.getEndTime().getValue());
+ }});
+ }
+ }
+ }
+
/**
* @param source
* @param experimentTRange
protected int getProviderId() {
return LttngCoreProviderFactory.CONTROL_FLOW_LTTNG_SYTH_EVENT_PROVIDER;
}
--}
++}
}
}
- if (range != TmfTimeRange.Null) {
+ @TmfSignalHandler
+ public void experimentUpdated(TmfExperimentUpdatedSignal signal) {
+ if (signal.getExperiment().equals(TmfExperiment.getCurrentExperiment())) {
+ final TmfTimeRange range = signal.getExperiment().getTimeRange();
++ if (range != TmfTimeRange.NULL_RANGE) {
+ Display.getDefault().asyncExec(new Runnable() {
+ @Override
+ public void run() {
+ tsfviewer.setTimeBounds(range.getStartTime().getValue(), range.getEndTime().getValue());
+ }});
+ }
+ }
+ }
+
/**
* @param source
* @param experimentTRange
protected int getProviderId() {
return LttngCoreProviderFactory.RESOURCE_LTTNG_SYTH_EVENT_PROVIDER;
}
--}
++}
public void handleSuccess() {
// long indexingEnd = System.nanoTime();
- if (getRange() != TmfTimeRange.ETERNITY) {
+ // if the end time is a real value then it is the streaming safe time stamp
+ // set the last time to the safe time stamp to prevent unnecessary indexing requests
- if (getRange().getEndTime() != TmfTimestamp.BigCrunch) {
++ if (getRange().getEndTime() != TmfTimestamp.BIG_CRUNCH) {
lastTime = getRange().getEndTime();
}
updateExperiment();