tmf: Drop generics from ITmfTrace and TmfExperiment
[deliverable/tracecompass.git] / org.eclipse.linuxtools.lttng2.kernel.ui / src / org / eclipse / linuxtools / internal / lttng2 / kernel / ui / views / resources / ResourcesView.java
CommitLineData
04835162
PT
1/*******************************************************************************\r
2 * Copyright (c) 2012 Ericsson\r
27f3a03d 3 *\r
04835162
PT
4 * All rights reserved. This program and the accompanying materials are\r
5 * made available under the terms of the Eclipse Public License v1.0 which\r
6 * accompanies this distribution, and is available at\r
7 * http://www.eclipse.org/legal/epl-v10.html\r
27f3a03d 8 *\r
04835162
PT
9 * Contributors:\r
10 * Patrick Tasse - Initial API and implementation\r
11 *******************************************************************************/\r
12\r
13package org.eclipse.linuxtools.internal.lttng2.kernel.ui.views.resources;\r
14\r
15import java.util.ArrayList;\r
49ffadb7 16import java.util.Arrays;\r
2c33fc31 17import java.util.Comparator;\r
04835162
PT
18import java.util.Iterator;\r
19import java.util.List;\r
04835162 20\r
0137b624
PT
21import org.eclipse.core.runtime.IProgressMonitor;\r
22import org.eclipse.core.runtime.NullProgressMonitor;\r
49ffadb7
PT
23import org.eclipse.jface.action.Action;\r
24import org.eclipse.jface.action.IToolBarManager;\r
25import org.eclipse.jface.action.Separator;\r
3e97fbfa 26import org.eclipse.linuxtools.internal.lttng2.kernel.core.Attributes;\r
49ffadb7
PT
27import org.eclipse.linuxtools.internal.lttng2.kernel.ui.Messages;\r
28import org.eclipse.linuxtools.internal.lttng2.kernel.ui.views.resources.ResourcesEntry.Type;\r
04835162 29import org.eclipse.linuxtools.lttng2.kernel.core.trace.CtfKernelTrace;\r
49ffadb7 30import org.eclipse.linuxtools.tmf.core.ctfadaptor.CtfTmfTimestamp;\r
49ffadb7
PT
31import org.eclipse.linuxtools.tmf.core.event.TmfTimeRange;\r
32import org.eclipse.linuxtools.tmf.core.event.TmfTimestamp;\r
04835162
PT
33import org.eclipse.linuxtools.tmf.core.exceptions.AttributeNotFoundException;\r
34import org.eclipse.linuxtools.tmf.core.exceptions.StateValueTypeException;\r
35import org.eclipse.linuxtools.tmf.core.exceptions.TimeRangeException;\r
04835162
PT
36import org.eclipse.linuxtools.tmf.core.interval.ITmfStateInterval;\r
37import org.eclipse.linuxtools.tmf.core.signal.TmfExperimentSelectedSignal;\r
49ffadb7 38import org.eclipse.linuxtools.tmf.core.signal.TmfRangeSynchSignal;\r
04835162 39import org.eclipse.linuxtools.tmf.core.signal.TmfSignalHandler;\r
b987050f 40import org.eclipse.linuxtools.tmf.core.signal.TmfStateSystemBuildCompleted;\r
49ffadb7 41import org.eclipse.linuxtools.tmf.core.signal.TmfTimeSynchSignal;\r
04835162 42import org.eclipse.linuxtools.tmf.core.statesystem.IStateSystemQuerier;\r
5793c495 43import org.eclipse.linuxtools.tmf.core.statesystem.IStateSystemQuerier2;\r
04835162 44import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;\r
9e0640dc 45import org.eclipse.linuxtools.tmf.core.trace.TmfExperiment;\r
04835162 46import org.eclipse.linuxtools.tmf.ui.views.TmfView;\r
49ffadb7
PT
47import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.ITimeGraphRangeListener;\r
48import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.ITimeGraphTimeListener;\r
49ffadb7
PT
49import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.TimeGraphRangeUpdateEvent;\r
50import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.TimeGraphTimeEvent;\r
04835162
PT
51import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.TimeGraphViewer;\r
52import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.model.ITimeEvent;\r
53import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.model.ITimeGraphEntry;\r
54import org.eclipse.linuxtools.tmf.ui.widgets.timegraph.model.TimeEvent;\r
55import org.eclipse.swt.SWT;\r
56import org.eclipse.swt.widgets.Composite;\r
57import org.eclipse.swt.widgets.Display;\r
49ffadb7 58import org.eclipse.ui.IActionBars;\r
04835162 59\r
27f3a03d
AM
60/**\r
61 * Main implementation for the LTTng 2.0 kernel Resource view\r
62 *\r
63 * @author Patrick Tasse\r
64 */\r
04835162
PT
65public class ResourcesView extends TmfView {\r
66\r
67 // ------------------------------------------------------------------------\r
68 // Constants\r
69 // ------------------------------------------------------------------------\r
70\r
27f3a03d 71 /** View ID. */\r
04835162
PT
72 public static final String ID = "org.eclipse.linuxtools.lttng2.kernel.ui.views.resources"; //$NON-NLS-1$\r
73\r
27f3a03d 74 /** Initial time range */\r
3ac6ad1a 75 private static final long INITIAL_WINDOW_OFFSET = (1L * 100 * 1000 * 1000); // .1sec\r
0137b624 76\r
03bcc394
PT
77 /**\r
78 * Redraw state enum\r
79 */\r
ea21cd65 80 private enum State { IDLE, BUSY, PENDING }\r
03bcc394 81\r
04835162
PT
82 // ------------------------------------------------------------------------\r
83 // Fields\r
84 // ------------------------------------------------------------------------\r
85\r
86 // The time graph viewer\r
87 TimeGraphViewer fTimeGraphViewer;\r
88\r
89 // The selected experiment\r
6256d8ad 90 private TmfExperiment fSelectedExperiment;\r
04835162
PT
91\r
92 // The time graph entry list\r
49ffadb7 93 private ArrayList<TraceEntry> fEntryList;\r
04835162 94\r
c19a8781
PT
95 // The time graph entry list synchronization object\r
96 final private Object fEntryListSyncObj = new Object();\r
97\r
04835162
PT
98 // The start time\r
99 private long fStartTime;\r
100\r
101 // The end time\r
102 private long fEndTime;\r
103\r
104 // The display width\r
27f3a03d 105 private final int fDisplayWidth;\r
0137b624 106\r
49ffadb7
PT
107 // The next resource action\r
108 private Action fNextResourceAction;\r
0137b624 109\r
49ffadb7
PT
110 // The previous resource action\r
111 private Action fPreviousResourceAction;\r
112\r
49ffadb7
PT
113 // The zoom thread\r
114 private ZoomThread fZoomThread;\r
04835162 115\r
03bcc394
PT
116 // The redraw state used to prevent unnecessary queuing of display runnables\r
117 private State fRedrawState = State.IDLE;\r
118\r
119 // The redraw synchronization object\r
120 final private Object fSyncObj = new Object();\r
121\r
04835162
PT
122 // ------------------------------------------------------------------------\r
123 // Classes\r
124 // ------------------------------------------------------------------------\r
125\r
49ffadb7 126 private class TraceEntry implements ITimeGraphEntry {\r
2c33fc31 127 // The Trace\r
27f3a03d 128 private final CtfKernelTrace fTrace;\r
2c33fc31 129 // The start time\r
27f3a03d 130 private final long fTraceStartTime;\r
2c33fc31 131 // The end time\r
27f3a03d 132 private final long fTraceEndTime;\r
2c33fc31 133 // The children of the entry\r
27f3a03d 134 private final ArrayList<ResourcesEntry> fChildren;\r
2c33fc31 135 // The name of entry\r
27f3a03d 136 private final String fName;\r
2c33fc31
BH
137\r
138 public TraceEntry(CtfKernelTrace trace, String name, long startTime, long endTime) {\r
49ffadb7
PT
139 fTrace = trace;\r
140 fChildren = new ArrayList<ResourcesEntry>();\r
04835162 141 fName = name;\r
2c33fc31
BH
142 fTraceStartTime = startTime;\r
143 fTraceEndTime = endTime;\r
04835162
PT
144 }\r
145\r
146 @Override\r
147 public ITimeGraphEntry getParent() {\r
49ffadb7 148 return null;\r
04835162
PT
149 }\r
150\r
151 @Override\r
152 public boolean hasChildren() {\r
153 return fChildren != null && fChildren.size() > 0;\r
154 }\r
155\r
156 @Override\r
49ffadb7
PT
157 public ResourcesEntry[] getChildren() {\r
158 return fChildren.toArray(new ResourcesEntry[0]);\r
04835162
PT
159 }\r
160\r
161 @Override\r
162 public String getName() {\r
163 return fName;\r
164 }\r
165\r
166 @Override\r
167 public long getStartTime() {\r
2c33fc31 168 return fTraceStartTime;\r
04835162
PT
169 }\r
170\r
171 @Override\r
49ffadb7 172 public long getEndTime() {\r
2c33fc31 173 return fTraceEndTime;\r
04835162
PT
174 }\r
175\r
8d8cb868
PT
176 @Override\r
177 public boolean hasTimeEvents() {\r
178 return false;\r
179 }\r
180\r
04835162
PT
181 @Override\r
182 public Iterator<ITimeEvent> getTimeEventsIterator() {\r
183 return null;\r
184 }\r
185\r
186 @Override\r
187 public <T extends ITimeEvent> Iterator<T> getTimeEventsIterator(long startTime, long stopTime, long visibleDuration) {\r
188 return null;\r
189 }\r
190\r
49ffadb7
PT
191 public CtfKernelTrace getTrace() {\r
192 return fTrace;\r
193 }\r
194\r
195 public void addChild(ResourcesEntry entry) {\r
196 int index;\r
197 for (index = 0; index < fChildren.size(); index++) {\r
198 ResourcesEntry other = fChildren.get(index);\r
199 if (entry.getType().compareTo(other.getType()) < 0) {\r
200 break;\r
201 } else if (entry.getType().equals(other.getType())) {\r
202 if (entry.getId() < other.getId()) {\r
203 break;\r
204 }\r
205 }\r
206 }\r
207 entry.setParent(this);\r
208 fChildren.add(index, entry);\r
209 }\r
210 }\r
27f3a03d 211\r
2c33fc31
BH
212 private static class TraceEntryComparator implements Comparator<ITimeGraphEntry> {\r
213 @Override\r
214 public int compare(ITimeGraphEntry o1, ITimeGraphEntry o2) {\r
215 int result = o1.getStartTime() < o2.getStartTime() ? -1 : o1.getStartTime() > o2.getStartTime() ? 1 : 0;\r
216 if (result == 0) {\r
217 result = o1.getName().compareTo(o2.getName());\r
218 }\r
219 return result;\r
220 }\r
221 }\r
49ffadb7
PT
222\r
223 private class ZoomThread extends Thread {\r
27f3a03d
AM
224 private final long fZoomStartTime;\r
225 private final long fZoomEndTime;\r
226 private final IProgressMonitor fMonitor;\r
49ffadb7
PT
227\r
228 public ZoomThread(long startTime, long endTime) {\r
229 super("ResourcesView zoom"); //$NON-NLS-1$\r
3ac6ad1a
BH
230 fZoomStartTime = startTime;\r
231 fZoomEndTime = endTime;\r
0137b624 232 fMonitor = new NullProgressMonitor();\r
49ffadb7
PT
233 }\r
234\r
235 @Override\r
236 public void run() {\r
c19a8781
PT
237 ArrayList<TraceEntry> entryList = null;\r
238 synchronized (fEntryListSyncObj) {\r
239 entryList = fEntryList;\r
240 }\r
8d8cb868 241 if (entryList == null) {\r
49ffadb7
PT
242 return;\r
243 }\r
3ac6ad1a 244 long resolution = Math.max(1, (fZoomEndTime - fZoomStartTime) / fDisplayWidth);\r
8d8cb868 245 for (TraceEntry traceEntry : entryList) {\r
49ffadb7 246 for (ITimeGraphEntry child : traceEntry.getChildren()) {\r
0137b624
PT
247 if (fMonitor.isCanceled()) {\r
248 break;\r
249 }\r
5929fada
PT
250 ResourcesEntry entry = (ResourcesEntry) child;\r
251 if (fZoomStartTime <= fStartTime && fZoomEndTime >= fEndTime) {\r
252 entry.setZoomedEventList(null);\r
253 } else {\r
254 List<ITimeEvent> zoomedEventList = getEventList(entry, fZoomStartTime, fZoomEndTime, resolution, true, fMonitor);\r
27f3a03d 255 if (zoomedEventList != null) {\r
5929fada
PT
256 entry.setZoomedEventList(zoomedEventList);\r
257 }\r
49ffadb7 258 }\r
03bcc394 259 redraw();\r
49ffadb7
PT
260 }\r
261 }\r
262 }\r
263\r
264 public void cancel() {\r
0137b624 265 fMonitor.setCanceled(true);\r
04835162
PT
266 }\r
267 }\r
268\r
269 // ------------------------------------------------------------------------\r
270 // Constructors\r
271 // ------------------------------------------------------------------------\r
272\r
27f3a03d
AM
273 /**\r
274 * Default constructor\r
275 */\r
04835162
PT
276 public ResourcesView() {\r
277 super(ID);\r
278 fDisplayWidth = Display.getDefault().getBounds().width;\r
279 }\r
280\r
281 // ------------------------------------------------------------------------\r
282 // ViewPart\r
283 // ------------------------------------------------------------------------\r
284\r
285 /* (non-Javadoc)\r
286 * @see org.eclipse.linuxtools.tmf.ui.views.TmfView#createPartControl(org.eclipse.swt.widgets.Composite)\r
287 */\r
288 @Override\r
289 public void createPartControl(Composite parent) {\r
290 fTimeGraphViewer = new TimeGraphViewer(parent, SWT.NONE);\r
291\r
72b5abb1 292 fTimeGraphViewer.setTimeGraphProvider(new ResourcesPresentationProvider());\r
49ffadb7
PT
293\r
294 fTimeGraphViewer.setTimeCalendarFormat(true);\r
295\r
296 fTimeGraphViewer.addRangeListener(new ITimeGraphRangeListener() {\r
297 @Override\r
298 public void timeRangeUpdated(TimeGraphRangeUpdateEvent event) {\r
299 long startTime = event.getStartTime();\r
300 long endTime = event.getEndTime();\r
301 TmfTimeRange range = new TmfTimeRange(new CtfTmfTimestamp(startTime), new CtfTmfTimestamp(endTime));\r
302 TmfTimestamp time = new CtfTmfTimestamp(fTimeGraphViewer.getSelectedTime());\r
303 broadcast(new TmfRangeSynchSignal(ResourcesView.this, range, time));\r
3ac6ad1a 304 startZoomThread(startTime, endTime);\r
04835162
PT
305 }\r
306 });\r
307\r
49ffadb7
PT
308 fTimeGraphViewer.addTimeListener(new ITimeGraphTimeListener() {\r
309 @Override\r
310 public void timeSelected(TimeGraphTimeEvent event) {\r
311 long time = event.getTime();\r
312 broadcast(new TmfTimeSynchSignal(ResourcesView.this, new CtfTmfTimestamp(time)));\r
313 }\r
314 });\r
315\r
316 final Thread thread = new Thread("ResourcesView build") { //$NON-NLS-1$\r
04835162
PT
317 @Override\r
318 public void run() {\r
319 if (TmfExperiment.getCurrentExperiment() != null) {\r
320 selectExperiment(TmfExperiment.getCurrentExperiment());\r
321 }\r
322 }\r
323 };\r
324 thread.start();\r
0137b624 325\r
49ffadb7
PT
326 // View Action Handling\r
327 makeActions();\r
328 contributeToActionBars();\r
04835162
PT
329 }\r
330\r
331 /* (non-Javadoc)\r
332 * @see org.eclipse.ui.part.WorkbenchPart#setFocus()\r
333 */\r
334 @Override\r
335 public void setFocus() {\r
336 fTimeGraphViewer.setFocus();\r
337 }\r
338\r
339 // ------------------------------------------------------------------------\r
340 // Signal handlers\r
341 // ------------------------------------------------------------------------\r
342\r
27f3a03d
AM
343 /**\r
344 * Handler for the ExperimentSelected signal\r
345 *\r
346 * @param signal\r
347 * The incoming signal\r
348 */\r
04835162 349 @TmfSignalHandler\r
6256d8ad 350 public void experimentSelected(final TmfExperimentSelectedSignal signal) {\r
04835162
PT
351 if (signal.getExperiment().equals(fSelectedExperiment)) {\r
352 return;\r
353 }\r
354\r
49ffadb7 355 final Thread thread = new Thread("ResourcesView build") { //$NON-NLS-1$\r
04835162
PT
356 @Override\r
357 public void run() {\r
358 selectExperiment(signal.getExperiment());\r
0137b624
PT
359 }\r
360 };\r
04835162
PT
361 thread.start();\r
362 }\r
363\r
27f3a03d
AM
364 /**\r
365 * Handler for the TimeSynch signal\r
366 *\r
367 * @param signal\r
368 * The incoming signal\r
369 */\r
49ffadb7
PT
370 @TmfSignalHandler\r
371 public void synchToTime(final TmfTimeSynchSignal signal) {\r
8a74a597 372 if (signal.getSource() == this || fSelectedExperiment == null) {\r
49ffadb7
PT
373 return;\r
374 }\r
375 final long time = signal.getCurrentTime().normalize(0, -9).getValue();\r
376 Display.getDefault().asyncExec(new Runnable() {\r
377 @Override\r
378 public void run() {\r
379 if (fTimeGraphViewer.getControl().isDisposed()) {\r
380 return;\r
381 }\r
3ac6ad1a 382 fTimeGraphViewer.setSelectedTime(time, true);\r
7264b6f2 383 startZoomThread(fTimeGraphViewer.getTime0(), fTimeGraphViewer.getTime1());\r
49ffadb7
PT
384 }\r
385 });\r
386 }\r
387\r
27f3a03d
AM
388 /**\r
389 * Handler for the RangeSynch signal\r
390 *\r
391 * @param signal\r
392 * The incoming signal\r
393 */\r
49ffadb7
PT
394 @TmfSignalHandler\r
395 public void synchToRange(final TmfRangeSynchSignal signal) {\r
8a74a597 396 if (signal.getSource() == this || fSelectedExperiment == null) {\r
49ffadb7
PT
397 return;\r
398 }\r
399 final long startTime = signal.getCurrentRange().getStartTime().normalize(0, -9).getValue();\r
400 final long endTime = signal.getCurrentRange().getEndTime().normalize(0, -9).getValue();\r
401 final long time = signal.getCurrentTime().normalize(0, -9).getValue();\r
402 Display.getDefault().asyncExec(new Runnable() {\r
403 @Override\r
404 public void run() {\r
405 if (fTimeGraphViewer.getControl().isDisposed()) {\r
406 return;\r
407 }\r
408 fTimeGraphViewer.setStartFinishTime(startTime, endTime);\r
8d8cb868 409 fTimeGraphViewer.setSelectedTime(time, false);\r
3ac6ad1a 410 startZoomThread(startTime, endTime);\r
49ffadb7
PT
411 }\r
412 });\r
413 }\r
414\r
27f3a03d
AM
415 /**\r
416 * Handler for the StatesystemBuildCompleted signal\r
417 *\r
418 * @param signal\r
419 * The incoming signal\r
420 */\r
b987050f
PT
421 @TmfSignalHandler\r
422 public void stateSystemBuildCompleted (final TmfStateSystemBuildCompleted signal) {\r
6256d8ad 423 final TmfExperiment selectedExperiment = fSelectedExperiment;\r
04aafb31 424 if (selectedExperiment == null || selectedExperiment.getTraces() == null) {\r
b987050f
PT
425 return;\r
426 }\r
6256d8ad 427 for (ITmfTrace trace : selectedExperiment.getTraces()) {\r
b987050f
PT
428 if (trace == signal.getTrace() && trace instanceof CtfKernelTrace) {\r
429 final Thread thread = new Thread("ResourcesView build") { //$NON-NLS-1$\r
430 @Override\r
431 public void run() {\r
432 // rebuild the model\r
433 selectExperiment(selectedExperiment);\r
434 }\r
435 };\r
436 thread.start();\r
437 }\r
438 }\r
439 }\r
440\r
49ffadb7
PT
441 // ------------------------------------------------------------------------\r
442 // Internal\r
443 // ------------------------------------------------------------------------\r
444\r
6256d8ad 445 private void selectExperiment(TmfExperiment experiment) {\r
04835162
PT
446 fStartTime = Long.MAX_VALUE;\r
447 fEndTime = Long.MIN_VALUE;\r
6256d8ad 448 fSelectedExperiment = experiment;\r
8d8cb868 449 ArrayList<TraceEntry> entryList = new ArrayList<TraceEntry>();\r
6256d8ad 450 for (ITmfTrace trace : experiment.getTraces()) {\r
04835162
PT
451 if (trace instanceof CtfKernelTrace) {\r
452 CtfKernelTrace ctfKernelTrace = (CtfKernelTrace) trace;\r
453 IStateSystemQuerier ssq = ctfKernelTrace.getStateSystem();\r
49ffadb7
PT
454 long startTime = ssq.getStartTime();\r
455 long endTime = ssq.getCurrentEndTime() + 1;\r
2c33fc31
BH
456 TraceEntry groupEntry = new TraceEntry(ctfKernelTrace, trace.getName(), startTime, endTime);\r
457 entryList.add(groupEntry);\r
49ffadb7
PT
458 fStartTime = Math.min(fStartTime, startTime);\r
459 fEndTime = Math.max(fEndTime, endTime);\r
04835162 460 List<Integer> cpuQuarks = ssq.getQuarks(Attributes.CPUS, "*"); //$NON-NLS-1$\r
49ffadb7
PT
461 ResourcesEntry[] cpuEntries = new ResourcesEntry[cpuQuarks.size()];\r
462 for (int i = 0; i < cpuQuarks.size(); i++) {\r
463 int cpuQuark = cpuQuarks.get(i);\r
464 int cpu = Integer.parseInt(ssq.getAttributeName(cpuQuark));\r
465 ResourcesEntry entry = new ResourcesEntry(cpuQuark, ctfKernelTrace, Type.CPU, cpu);\r
466 groupEntry.addChild(entry);\r
467 cpuEntries[i] = entry;\r
468 }\r
469 List<Integer> irqQuarks = ssq.getQuarks(Attributes.RESOURCES, Attributes.IRQS, "*"); //$NON-NLS-1$\r
470 ResourcesEntry[] irqEntries = new ResourcesEntry[irqQuarks.size()];\r
471 for (int i = 0; i < irqQuarks.size(); i++) {\r
472 int irqQuark = irqQuarks.get(i);\r
473 int irq = Integer.parseInt(ssq.getAttributeName(irqQuark));\r
474 ResourcesEntry entry = new ResourcesEntry(irqQuark, ctfKernelTrace, Type.IRQ, irq);\r
475 groupEntry.addChild(entry);\r
476 irqEntries[i] = entry;\r
477 }\r
478 List<Integer> softIrqQuarks = ssq.getQuarks(Attributes.RESOURCES, Attributes.SOFT_IRQS, "*"); //$NON-NLS-1$\r
479 ResourcesEntry[] softIrqEntries = new ResourcesEntry[softIrqQuarks.size()];\r
480 for (int i = 0; i < softIrqQuarks.size(); i++) {\r
481 int softIrqQuark = softIrqQuarks.get(i);\r
482 int softIrq = Integer.parseInt(ssq.getAttributeName(softIrqQuark));\r
483 ResourcesEntry entry = new ResourcesEntry(softIrqQuark, ctfKernelTrace, Type.SOFT_IRQ, softIrq);\r
484 groupEntry.addChild(entry);\r
485 softIrqEntries[i] = entry;\r
486 }\r
487 }\r
488 }\r
c19a8781
PT
489 synchronized (fEntryListSyncObj) {\r
490 fEntryList = (ArrayList<TraceEntry>) entryList.clone();\r
491 }\r
3ac6ad1a 492 refresh(INITIAL_WINDOW_OFFSET);\r
c19a8781 493 for (TraceEntry traceEntry : entryList) {\r
0a78d11a 494 CtfKernelTrace ctfKernelTrace = traceEntry.getTrace();\r
49ffadb7
PT
495 IStateSystemQuerier ssq = ctfKernelTrace.getStateSystem();\r
496 long startTime = ssq.getStartTime();\r
497 long endTime = ssq.getCurrentEndTime() + 1;\r
498 long resolution = (endTime - startTime) / fDisplayWidth;\r
499 for (ResourcesEntry entry : traceEntry.getChildren()) {\r
0137b624 500 List<ITimeEvent> eventList = getEventList(entry, startTime, endTime, resolution, false, new NullProgressMonitor());\r
49ffadb7
PT
501 entry.setEventList(eventList);\r
502 redraw();\r
503 }\r
504 }\r
505 }\r
506\r
0a78d11a
AM
507 private static List<ITimeEvent> getEventList(ResourcesEntry entry,\r
508 long startTime, long endTime, long resolution, boolean includeNull,\r
509 IProgressMonitor monitor) {\r
5793c495 510 IStateSystemQuerier2 ssq = (IStateSystemQuerier2) entry.getTrace().getStateSystem();\r
7264b6f2
PT
511 startTime = Math.max(startTime, ssq.getStartTime());\r
512 endTime = Math.min(endTime, ssq.getCurrentEndTime() + 1);\r
0137b624
PT
513 if (endTime <= startTime) {\r
514 return null;\r
515 }\r
49ffadb7
PT
516 List<ITimeEvent> eventList = null;\r
517 int quark = entry.getQuark();\r
518 try {\r
519 if (entry.getType().equals(Type.CPU)) {\r
72b5abb1 520 int statusQuark = ssq.getQuarkRelative(quark, Attributes.STATUS);\r
03bcc394 521 List<ITmfStateInterval> statusIntervals = ssq.queryHistoryRange(statusQuark, startTime, endTime - 1, resolution, monitor);\r
72b5abb1 522 eventList = new ArrayList<ITimeEvent>(statusIntervals.size());\r
49ffadb7 523 long lastEndTime = -1;\r
72b5abb1 524 for (ITmfStateInterval statusInterval : statusIntervals) {\r
0137b624
PT
525 if (monitor.isCanceled()) {\r
526 return null;\r
527 }\r
72b5abb1
PT
528 int status = statusInterval.getStateValue().unboxInt();\r
529 long time = statusInterval.getStartTime();\r
530 long duration = statusInterval.getEndTime() - time + 1;\r
531 if (!statusInterval.getStateValue().isNull()) {\r
49ffadb7
PT
532 if (lastEndTime != time && lastEndTime != -1) {\r
533 eventList.add(new TimeEvent(entry, lastEndTime, time - lastEndTime));\r
cf7d106f 534 }\r
72b5abb1 535 eventList.add(new ResourcesEvent(entry, time, duration, status));\r
49ffadb7 536 lastEndTime = time + duration;\r
72b5abb1
PT
537 } else {\r
538 if (includeNull) {\r
539 eventList.add(new ResourcesEvent(entry, time, duration));\r
540 }\r
cf7d106f 541 }\r
49ffadb7
PT
542 }\r
543 } else if (entry.getType().equals(Type.IRQ)) {\r
03bcc394 544 List<ITmfStateInterval> irqIntervals = ssq.queryHistoryRange(quark, startTime, endTime - 1, resolution, monitor);\r
49ffadb7
PT
545 eventList = new ArrayList<ITimeEvent>(irqIntervals.size());\r
546 long lastEndTime = -1;\r
547 boolean lastIsNull = true;\r
548 for (ITmfStateInterval irqInterval : irqIntervals) {\r
0137b624
PT
549 if (monitor.isCanceled()) {\r
550 return null;\r
551 }\r
49ffadb7
PT
552 long time = irqInterval.getStartTime();\r
553 long duration = irqInterval.getEndTime() - time + 1;\r
554 if (!irqInterval.getStateValue().isNull()) {\r
555 int cpu = irqInterval.getStateValue().unboxInt();\r
556 eventList.add(new ResourcesEvent(entry, time, duration, cpu));\r
557 lastIsNull = false;\r
558 } else {\r
559 if (lastEndTime != time && lastEndTime != -1 && lastIsNull) {\r
560 eventList.add(new ResourcesEvent(entry, lastEndTime, time - lastEndTime, -1));\r
561 }\r
562 if (includeNull) {\r
563 eventList.add(new ResourcesEvent(entry, time, duration));\r
564 }\r
565 lastIsNull = true;\r
566 }\r
567 lastEndTime = time + duration;\r
568 }\r
569 } else if (entry.getType().equals(Type.SOFT_IRQ)) {\r
03bcc394 570 List<ITmfStateInterval> softIrqIntervals = ssq.queryHistoryRange(quark, startTime, endTime - 1, resolution, monitor);\r
49ffadb7
PT
571 eventList = new ArrayList<ITimeEvent>(softIrqIntervals.size());\r
572 long lastEndTime = -1;\r
573 boolean lastIsNull = true;\r
574 for (ITmfStateInterval softIrqInterval : softIrqIntervals) {\r
0137b624
PT
575 if (monitor.isCanceled()) {\r
576 return null;\r
577 }\r
49ffadb7
PT
578 long time = softIrqInterval.getStartTime();\r
579 long duration = softIrqInterval.getEndTime() - time + 1;\r
580 if (!softIrqInterval.getStateValue().isNull()) {\r
581 int cpu = softIrqInterval.getStateValue().unboxInt();\r
582 eventList.add(new ResourcesEvent(entry, time, duration, cpu));\r
583 } else {\r
584 if (lastEndTime != time && lastEndTime != -1 && lastIsNull) {\r
585 eventList.add(new ResourcesEvent(entry, lastEndTime, time - lastEndTime, -1));\r
586 }\r
587 if (includeNull) {\r
588 eventList.add(new ResourcesEvent(entry, time, duration));\r
589 }\r
590 lastIsNull = true;\r
591 }\r
592 lastEndTime = time + duration;\r
04835162
PT
593 }\r
594 }\r
49ffadb7
PT
595 } catch (AttributeNotFoundException e) {\r
596 e.printStackTrace();\r
597 } catch (TimeRangeException e) {\r
598 e.printStackTrace();\r
599 } catch (StateValueTypeException e) {\r
600 e.printStackTrace();\r
04835162 601 }\r
49ffadb7 602 return eventList;\r
04835162
PT
603 }\r
604\r
3ac6ad1a 605 private void refresh(final long windowRange) {\r
04835162
PT
606 Display.getDefault().asyncExec(new Runnable() {\r
607 @Override\r
608 public void run() {\r
609 if (fTimeGraphViewer.getControl().isDisposed()) {\r
610 return;\r
611 }\r
c19a8781
PT
612 ITimeGraphEntry[] entries = null;\r
613 synchronized (fEntryListSyncObj) {\r
614 entries = fEntryList.toArray(new ITimeGraphEntry[0]);\r
615 }\r
2c33fc31 616 Arrays.sort(entries, new TraceEntryComparator());\r
49ffadb7 617 fTimeGraphViewer.setInput(entries);\r
04835162 618 fTimeGraphViewer.setTimeBounds(fStartTime, fEndTime);\r
0137b624 619\r
3ac6ad1a
BH
620 long endTime = fStartTime + windowRange;\r
621\r
622 if (fEndTime < endTime) {\r
623 endTime = fEndTime;\r
624 }\r
625 fTimeGraphViewer.setStartFinishTime(fStartTime, endTime);\r
0137b624 626\r
3ac6ad1a 627 startZoomThread(fStartTime, endTime);\r
04835162
PT
628 }\r
629 });\r
630 }\r
631\r
49ffadb7
PT
632\r
633 private void redraw() {\r
03bcc394
PT
634 synchronized (fSyncObj) {\r
635 if (fRedrawState == State.IDLE) {\r
636 fRedrawState = State.BUSY;\r
637 } else {\r
638 fRedrawState = State.PENDING;\r
639 return;\r
640 }\r
641 }\r
49ffadb7
PT
642 Display.getDefault().asyncExec(new Runnable() {\r
643 @Override\r
644 public void run() {\r
645 if (fTimeGraphViewer.getControl().isDisposed()) {\r
646 return;\r
647 }\r
648 fTimeGraphViewer.getControl().redraw();\r
649 fTimeGraphViewer.getControl().update();\r
03bcc394
PT
650 synchronized (fSyncObj) {\r
651 if (fRedrawState == State.PENDING) {\r
652 fRedrawState = State.IDLE;\r
653 redraw();\r
654 } else {\r
655 fRedrawState = State.IDLE;\r
656 }\r
657 }\r
49ffadb7
PT
658 }\r
659 });\r
660 }\r
661\r
3ac6ad1a
BH
662 private void startZoomThread(long startTime, long endTime) {\r
663 if (fZoomThread != null) {\r
664 fZoomThread.cancel();\r
665 }\r
666 fZoomThread = new ZoomThread(startTime, endTime);\r
667 fZoomThread.start();\r
668 }\r
0137b624 669\r
49ffadb7
PT
670 private void makeActions() {\r
671 fPreviousResourceAction = fTimeGraphViewer.getPreviousItemAction();\r
672 fPreviousResourceAction.setText(Messages.ResourcesView_previousResourceActionNameText);\r
673 fPreviousResourceAction.setToolTipText(Messages.ResourcesView_previousResourceActionToolTipText);\r
674 fNextResourceAction = fTimeGraphViewer.getNextItemAction();\r
675 fNextResourceAction.setText(Messages.ResourcesView_nextResourceActionNameText);\r
676 fNextResourceAction.setToolTipText(Messages.ResourcesView_previousResourceActionToolTipText);\r
677 }\r
0137b624 678\r
49ffadb7
PT
679 private void contributeToActionBars() {\r
680 IActionBars bars = getViewSite().getActionBars();\r
681 fillLocalToolBar(bars.getToolBarManager());\r
682 }\r
0137b624 683\r
49ffadb7
PT
684 private void fillLocalToolBar(IToolBarManager manager) {\r
685 manager.add(fTimeGraphViewer.getShowLegendAction());\r
686 manager.add(new Separator());\r
687 manager.add(fTimeGraphViewer.getResetScaleAction());\r
688 manager.add(fTimeGraphViewer.getPreviousEventAction());\r
689 manager.add(fTimeGraphViewer.getNextEventAction());\r
690 manager.add(fPreviousResourceAction);\r
691 manager.add(fNextResourceAction);\r
692 manager.add(fTimeGraphViewer.getZoomInAction());\r
693 manager.add(fTimeGraphViewer.getZoomOutAction());\r
694 manager.add(new Separator());\r
695 }\r
04835162 696}\r
This page took 0.063965 seconds and 5 git commands to generate.