tmf: make CallstackProvider entry and exit return TmfStates
[deliverable/tracecompass.git] / tmf / org.eclipse.tracecompass.tmf.core / src / org / eclipse / tracecompass / tmf / core / callstack / CallStackStateProvider.java
1 /*******************************************************************************
2 * Copyright (c) 2013, 2015 Ericsson
3 *
4 * All rights reserved. This program and the accompanying materials are
5 * made available under the terms of the Eclipse Public License v1.0 which
6 * accompanies this distribution, and is available at
7 * http://www.eclipse.org/legal/epl-v10.html
8 *
9 * Contributors:
10 * Patrick Tasse - Initial API and implementation
11 *******************************************************************************/
12
13 package org.eclipse.tracecompass.tmf.core.callstack;
14
15 import static org.eclipse.tracecompass.common.core.NonNullUtils.checkNotNull;
16
17 import org.eclipse.jdt.annotation.NonNullByDefault;
18 import org.eclipse.jdt.annotation.Nullable;
19 import org.eclipse.osgi.util.NLS;
20 import org.eclipse.tracecompass.internal.tmf.core.Activator;
21 import org.eclipse.tracecompass.statesystem.core.ITmfStateSystemBuilder;
22 import org.eclipse.tracecompass.statesystem.core.exceptions.AttributeNotFoundException;
23 import org.eclipse.tracecompass.statesystem.core.statevalue.ITmfStateValue;
24 import org.eclipse.tracecompass.statesystem.core.statevalue.TmfStateValue;
25 import org.eclipse.tracecompass.tmf.core.event.ITmfEvent;
26 import org.eclipse.tracecompass.tmf.core.statesystem.AbstractTmfStateProvider;
27 import org.eclipse.tracecompass.tmf.core.statesystem.ITmfStateProvider;
28 import org.eclipse.tracecompass.tmf.core.trace.ITmfTrace;
29
30 /**
31 * The state provider for traces that support the Call Stack view.
32 *
33 * The attribute tree should have the following structure:
34 *
35 * <pre>
36 * (root)
37 * +-- Processes
38 * +-- (PID 1000)
39 * | +-- (TID 1000)
40 * | | +-- CallStack (stack-attribute)
41 * | | +-- 1
42 * | | +-- 2
43 * | | ...
44 * | | +-- n
45 * | +-- (TID 1001)
46 * | +-- CallStack (stack-attribute)
47 * | +-- 1
48 * | +-- 2
49 * | ...
50 * | +-- n
51 * |
52 * +-- (PID 2000)
53 * +-- (TID 2000)
54 * +-- CallStack (stack-attribute)
55 * +-- 1
56 * +-- 2
57 * ...
58 * +-- n
59 * </pre>
60 *
61 * where:
62 * <ul>
63 * <li>(PID n) is an attribute name representing a unique process identifier.
64 * </li>
65 * <li>(TID n) is an attribute whose name is the display name of the thread.
66 * Optionally, its value is a long representing the thread id, used for sorting.
67 * </li>
68 * <li>"CallStack" is a stack-attribute whose pushed values are either a string,
69 * int or long representing the function name or address in the call stack. The
70 * type of value used must be constant for a particular CallStack.</li>
71 * </ul>
72 *
73 * @author Patrick Tasse
74 */
75 @NonNullByDefault
76 public abstract class CallStackStateProvider extends AbstractTmfStateProvider {
77
78 /**
79 * Thread attribute
80 *
81 * @since 2.0
82 */
83 public static final String PROCESSES = "Processes"; //$NON-NLS-1$
84
85 /** CallStack stack-attribute */
86 public static final String CALL_STACK = "CallStack"; //$NON-NLS-1$
87
88 /**
89 * Undefined process ID
90 *
91 * @since 2.0
92 */
93 protected static final int UNDEFINED_PID = -1;
94
95 /** Undefined function exit name */
96 protected static final String UNDEFINED = "UNDEFINED"; //$NON-NLS-1$
97
98 /** CallStack state system ID */
99 private static final String ID = "org.eclipse.linuxtools.tmf.callstack"; //$NON-NLS-1$
100
101 /**
102 * Default constructor
103 *
104 * @param trace
105 * The trace for which we build this state system
106 */
107 public CallStackStateProvider(ITmfTrace trace) {
108 super(trace, ID);
109 }
110
111 @Override
112 protected void eventHandle(ITmfEvent event) {
113 if (!considerEvent(event)) {
114 return;
115 }
116
117 ITmfStateSystemBuilder ss = checkNotNull(getStateSystemBuilder());
118
119 try {
120 /* Check if the event is a function entry */
121 ITmfStateValue functionEntryName = functionEntry(event);
122 if (functionEntryName != null) {
123 long timestamp = event.getTimestamp().toNanos();
124 int pid = getProcessId(event);
125 String threadName = getThreadName(event);
126 int threadQuark = ss.getQuarkAbsoluteAndAdd(PROCESSES, Integer.toString(pid), threadName);
127
128 long threadId = getThreadId(event);
129 ss.updateOngoingState(TmfStateValue.newValueLong(threadId), threadQuark);
130
131 int callStackQuark = ss.getQuarkRelativeAndAdd(threadQuark, CALL_STACK);
132 ITmfStateValue value = functionEntryName;
133 ss.pushAttribute(timestamp, value, callStackQuark);
134 return;
135 }
136
137 /* Check if the event is a function exit */
138 ITmfStateValue functionExitState = functionExit(event);
139 if (functionExitState != null) {
140 long timestamp = event.getTimestamp().toNanos();
141 int pid = getProcessId(event);
142 String thread = getThreadName(event);
143 int quark = ss.getQuarkAbsoluteAndAdd(PROCESSES, Integer.toString(pid), thread, CALL_STACK);
144 ITmfStateValue poppedValue = ss.popAttribute(timestamp, quark);
145 /*
146 * Verify that the value we are popping matches the one in the
147 * event field, unless the latter is undefined.
148 */
149 if (!functionExitState.isNull() && !functionExitState.equals(poppedValue)) {
150 Activator.logWarning(NLS.bind(
151 Messages.CallStackStateProvider_UnmatchedPoppedValue,
152 functionExitState,
153 poppedValue));
154 }
155 }
156
157 } catch (AttributeNotFoundException e) {
158 e.printStackTrace();
159 }
160 }
161
162 /**
163 * Restrict the return type for {@link ITmfStateProvider#getNewInstance}.
164 *
165 * @since 2.0
166 */
167 @Override
168 public abstract CallStackStateProvider getNewInstance();
169
170 /**
171 * Check if this event should be considered at all for function entry/exit
172 * analysis. This check is only run once per event, before
173 * {@link #functionEntry} and {@link #functionExit} (to avoid repeating
174 * checks in those methods).
175 *
176 * @param event
177 * The event to check
178 * @return If false, the event will be ignored by the state provider. If
179 * true processing will continue.
180 */
181 protected abstract boolean considerEvent(ITmfEvent event);
182
183 /**
184 * Check an event if it indicates a function entry.
185 *
186 * @param event
187 * An event to check for function entry
188 * @return The state value representing the function being entered, or null
189 * if not a function entry
190 * @since 2.0
191 */
192 protected abstract @Nullable ITmfStateValue functionEntry(ITmfEvent event);
193
194 /**
195 * Check an event if it indicates a function exit.
196 *
197 * @param event
198 * An event to check for function exit
199 * @return The state value representing the function being exited, or
200 * TmfStateValue#nullValue() if the exited function is undefined,
201 * or null if not a function exit.
202 * @since 2.0
203 */
204 protected abstract @Nullable ITmfStateValue functionExit(ITmfEvent event);
205
206 /**
207 * Return the process ID of a function entry event.
208 *
209 * Use {@link #UNDEFINED_PID} if it is not known.
210 *
211 * @param event
212 * The event
213 * @return The process ID
214 * @since 2.0
215 */
216 protected abstract int getProcessId(ITmfEvent event);
217
218 /**
219 * Return the thread id of a function entry event.
220 *
221 * @param event
222 * The event
223 * @return The thread id
224 * @since 2.0
225 */
226 protected abstract long getThreadId(ITmfEvent event);
227
228 /**
229 * Return the thread name of a function entry or exit event.
230 *
231 * @param event
232 * The event
233 * @return The thread name (as will be shown in the view)
234 */
235 protected abstract String getThreadName(ITmfEvent event);
236 }
This page took 0.039895 seconds and 5 git commands to generate.