import java.util.Collections;
import java.util.Iterator;
import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.tracecompass.analysis.timing.core.segmentstore.IAnalysisProgressListener;
import org.eclipse.tracecompass.analysis.timing.core.segmentstore.ISegmentStoreProvider;
import org.eclipse.tracecompass.analysis.timing.ui.views.segmentstore.SubSecondTimeWithUnitFormat;
-import org.eclipse.tracecompass.common.core.NonNullUtils;
import org.eclipse.tracecompass.internal.analysis.timing.ui.Activator;
import org.eclipse.tracecompass.internal.analysis.timing.ui.views.segmentstore.scatter.Messages;
import org.eclipse.tracecompass.internal.analysis.timing.ui.views.segmentstore.scatter.SegmentStoreScatterGraphTooltipProvider;
import org.eclipse.tracecompass.tmf.core.signal.TmfTraceClosedSignal;
import org.eclipse.tracecompass.tmf.core.signal.TmfTraceOpenedSignal;
import org.eclipse.tracecompass.tmf.core.signal.TmfTraceSelectedSignal;
-import org.eclipse.tracecompass.tmf.core.signal.TmfWindowRangeUpdatedSignal;
import org.eclipse.tracecompass.tmf.core.timestamp.TmfTimeRange;
import org.eclipse.tracecompass.tmf.core.trace.ITmfTrace;
import org.eclipse.tracecompass.tmf.core.trace.TmfTraceManager;
private static final Format FORMAT = new SubSecondTimeWithUnitFormat();
+ private final AtomicInteger fDirty = new AtomicInteger();
+
private final class CompactingSegmentStoreQuery extends Job {
private static final long MAX_POINTS = 1000;
- private final TmfTimeRange fCurrentRange;
+ private final long fStart;
+ private final long fEnd;
- private CompactingSegmentStoreQuery(TmfTimeRange currentRange) {
+ private CompactingSegmentStoreQuery(long start, long end) {
super(Messages.SegmentStoreScatterGraphViewer_compactTitle);
- fCurrentRange = currentRange;
+ fStart = start;
+ fEnd = end;
}
@Override
protected IStatus run(@Nullable IProgressMonitor monitor) {
final IProgressMonitor statusMonitor = monitor;
- if (statusMonitor == null) {
- return new Status(IStatus.ERROR, Activator.PLUGIN_ID, "Monitor is null"); //$NON-NLS-1$
- }
-
- ISegmentStoreProvider segmentProvider = getSegmentProvider();
- final long startTimeInNanos = fCurrentRange.getStartTime().toNanos();
- final long endTimeInNanos = fCurrentRange.getEndTime().toNanos();
- if (segmentProvider == null) {
- setWindowRange(startTimeInNanos, endTimeInNanos);
- redraw(statusMonitor, startTimeInNanos, startTimeInNanos, Collections.EMPTY_LIST);
- return new Status(IStatus.WARNING, Activator.PLUGIN_ID, "segment provider not available"); //$NON-NLS-1$
- }
+ try {
+ if (statusMonitor == null) {
+ return new Status(IStatus.ERROR, Activator.PLUGIN_ID, "Monitor is null"); //$NON-NLS-1$
+ }
- final ISegmentStore<ISegment> segStore = segmentProvider.getSegmentStore();
- if (segStore == null) {
- setWindowRange(startTimeInNanos, endTimeInNanos);
- redraw(statusMonitor, startTimeInNanos, startTimeInNanos, Collections.EMPTY_LIST);
- return new Status(IStatus.INFO, Activator.PLUGIN_ID, "Segment provider does not have segments"); //$NON-NLS-1$
- }
+ ISegmentStoreProvider segmentProvider = getSegmentProvider();
+ final long startTime = fStart;
+ final long endTime = fEnd;
+ if (segmentProvider == null) {
+ redraw(statusMonitor, startTime, startTime, Collections.EMPTY_LIST);
+ return new Status(IStatus.WARNING, Activator.PLUGIN_ID, "segment provider not available"); //$NON-NLS-1$
+ }
- final long startTime = fCurrentRange.getStartTime().getValue();
- final long endTime = fCurrentRange.getEndTime().getValue();
- fPixelStart = startTime;
- fPixelSize = Math.max(1, (endTime - startTime) / MAX_POINTS);
- final Iterable<ISegment> intersectingElements = segStore.getIntersectingElements(startTime, endTime);
+ final ISegmentStore<ISegment> segStore = segmentProvider.getSegmentStore();
+ if (segStore == null) {
+ redraw(statusMonitor, startTime, startTime, Collections.EMPTY_LIST);
+ return new Status(IStatus.INFO, Activator.PLUGIN_ID, "Segment provider does not have segments"); //$NON-NLS-1$
+ }
- final List<ISegment> list = convertIterableToList(intersectingElements, statusMonitor);
- final List<ISegment> displayData = (!list.isEmpty()) ? compactList(startTime, list, statusMonitor) : list;
+ fPixelStart = startTime;
+ fPixelSize = Math.max(1, (endTime - startTime) / MAX_POINTS);
+ final Iterable<ISegment> intersectingElements = segStore.getIntersectingElements(startTime, endTime);
+ final List<ISegment> list = convertIterableToList(intersectingElements, statusMonitor);
+ final List<ISegment> displayData = (!list.isEmpty()) ? compactList(startTime, list, statusMonitor) : list;
- setWindowRange(startTimeInNanos, endTimeInNanos);
- redraw(statusMonitor, startTime, endTime, displayData);
+ redraw(statusMonitor, startTime, endTime, displayData);
- if (statusMonitor.isCanceled()) {
- return Status.CANCEL_STATUS;
+ if (statusMonitor.isCanceled()) {
+ return Status.CANCEL_STATUS;
+ }
+ return Status.OK_STATUS;
+ } finally {
+ /*
+ * fDirty should have been incremented before creating a job, so
+ * we decrement it once the job is done
+ */
+ fDirty.decrementAndGet();
}
- return Status.OK_STATUS;
}
private void redraw(final IProgressMonitor statusMonitor, final long startTime, final long endTime, final List<ISegment> displayData) {
fDisplayData = displayData;
+ /*
+ * Increment at every redraw, since the content of the view is not
+ * current
+ */
+ fDirty.incrementAndGet();
Display.getDefault().asyncExec(new Runnable() {
@Override
public void run() {
- updateData(startTime, endTime, displayData.size(), statusMonitor);
+ try {
+ updateData(startTime, endTime, displayData.size(), statusMonitor);
+ } finally {
+ /* Decrement once the redraw is done */
+ fDirty.decrementAndGet();
+ }
}
});
}
// Only update the model if trace that was analyzed is active trace
if (segmentProvider.equals(getSegmentProvider())) {
updateModel(segmentStore);
- updateRange(TmfTraceManager.getInstance().getCurrentTraceContext().getWindowRange());
}
}
}
if (segmentStoreProvider != null) {
segmentStoreProvider.addListener(fListener);
setData(segmentStoreProvider);
- updateRange(TmfTraceManager.getInstance().getCurrentTraceContext().getWindowRange());
}
}
}
fDisplayData = list;
}
setWindowRange(currentStart, currentEnd);
- updateRange(currentRange);
+ updateContent();
}
@Override
Collection<ISegment> data = fDisplayData;
final int dataSize = (nb == 0) ? data.size() : nb;
- if (dataSize == 0 || end == start) {
+ if (end == start) {
return;
}
ySeries.add((double) segment.getLength());
}
setXAxis(Doubles.toArray(xSeries));
- setSeries(Messages.SegmentStoreScatterGraphViewer_legend, Doubles.toArray(ySeries)); // $NON-NLS-1$
+ setSeries(Messages.SegmentStoreScatterGraphViewer_legend, Doubles.toArray(ySeries));
updateDisplay();
}
timeRange.getStartTime().toNanos(),
timeRange.getEndTime().toNanos());
setData(getSegmentStoreProvider(trace));
- updateRange(timeRange);
+ updateContent();
}
}
}
- private void updateRange(final @Nullable TmfTimeRange timeRange) {
+ @Override
+ protected void updateContent() {
+ /*
+ * Update is requested, content is not up to date, fDirty will be
+ * decremented in the compacting job
+ */
+ fDirty.incrementAndGet();
Job compactingJob = fCompactingJob;
if (compactingJob != null && compactingJob.getState() == Job.RUNNING) {
compactingJob.cancel();
}
- compactingJob = new CompactingSegmentStoreQuery(NonNullUtils.checkNotNull(timeRange));
+ compactingJob = new CompactingSegmentStoreQuery(getWindowStartTime(), getWindowEndTime());
fCompactingJob = compactingJob;
compactingJob.schedule();
}
refresh();
}
- /**
- * @param signal
- * Signal received when window range is updated
- */
- @Override
- @TmfSignalHandler
- public void windowRangeUpdated(@Nullable TmfWindowRangeUpdatedSignal signal) {
- super.windowRangeUpdated(signal);
- if (signal == null) {
- return;
- }
- if (getTrace() != null) {
- final TmfTimeRange currentRange = signal.getCurrentRange();
- updateRange(currentRange);
- } else {
- Activator.getDefault().logInfo("No Trace to update"); //$NON-NLS-1$
- }
- }
-
private @Nullable ISegmentStoreProvider getSegmentProvider() {
return fSegmentProvider;
}
private void setSegmentProvider(ISegmentStoreProvider provider) {
fSegmentProvider = provider;
}
+
+ @Override
+ public boolean isDirty() {
+ /* Check the parent's or this view's own dirtiness */
+ return super.isDirty() || (fDirty.get() != 0);
+ }
}
\ No newline at end of file
projects / deliverable / tracecompass.git / blobdiff