Commit | Line | Data |
---|---|---|
af7f72ce FG |
1 | /******************************************************************************* |
2 | * Copyright (c) 2015 École Polytechnique de Montréal | |
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 | ||
10 | package org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.handlers; | |
11 | ||
12 | import org.eclipse.tracecompass.analysis.os.linux.core.model.HostThread; | |
5aa7fe19 | 13 | import org.eclipse.tracecompass.analysis.os.linux.core.trace.IKernelAnalysisEventLayout; |
af7f72ce FG |
14 | import org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.building.LttngKernelExecGraphProvider; |
15 | import org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.building.LttngKernelExecGraphProvider.ProcessStatus; | |
16 | import org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.model.EventField; | |
17 | import org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.model.LttngSystemModel; | |
18 | import org.eclipse.tracecompass.internal.lttng2.kernel.core.analysis.graph.model.LttngWorker; | |
af7f72ce FG |
19 | import org.eclipse.tracecompass.tmf.core.event.ITmfEvent; |
20 | ||
21 | /** | |
22 | * Handles the LTTng statedump events necessary for the initialization of the | |
23 | * system model | |
24 | * | |
25 | * @author Francis Giraldeau | |
26 | */ | |
27 | public class TraceEventHandlerStatedump extends BaseHandler { | |
28 | ||
29 | /** | |
30 | * Constructor | |
31 | * | |
32 | * @param provider | |
33 | * The parent graph provider | |
34 | */ | |
35 | public TraceEventHandlerStatedump(LttngKernelExecGraphProvider provider) { | |
36 | super(provider); | |
37 | } | |
38 | ||
39 | @Override | |
40 | public void handleEvent(ITmfEvent event) { | |
5aa7fe19 | 41 | IKernelAnalysisEventLayout eventLayout = getProvider().getEventLayout(event.getTrace()); |
af7f72ce FG |
42 | LttngSystemModel system = getProvider().getSystem(); |
43 | String eventName = event.getName(); | |
44 | if (!eventName.equals(eventLayout.eventStatedumpProcessState())) { | |
45 | return; | |
46 | } | |
47 | ||
48 | Integer tid = EventField.getInt(event, eventLayout.fieldTid()); | |
49 | String name = EventField.getOrDefault(event, eventLayout.fieldName(), Messages.TraceEventHandlerSched_UnknownThreadName); | |
50 | Integer status = EventField.getInt(event, eventLayout.fieldStatus()); | |
51 | ||
52 | String host = event.getTrace().getHostId(); | |
53 | long ts = event.getTimestamp().getValue(); | |
54 | ||
55 | HostThread ht = new HostThread(host, tid); | |
56 | LttngWorker task = system.findWorker(ht); | |
57 | if (task == null) { | |
58 | task = new LttngWorker(ht, name, ts); | |
59 | system.addWorker(task); | |
60 | } else { | |
61 | task.setName(name); | |
62 | } | |
63 | ||
64 | task.setStatus(ProcessStatus.getStatus(status)); | |
65 | } | |
66 | ||
67 | } |