1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
/*******************************************************************************
* Copyright (c) 2017 École Polytechnique de Montréal
*
* All rights reserved. This program and the accompanying materials are
* made available under the terms of the Eclipse Public License v1.0 which
* accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*******************************************************************************/
package org.eclipse.tracecompass.incubator.virtual.machine.analysis.core.tests.fused;
import java.util.HashSet;
import java.util.Set;
import org.eclipse.tracecompass.incubator.internal.virtual.machine.analysis.core.fused.FusedAttributes;
import org.eclipse.tracecompass.incubator.virtual.machine.analysis.core.tests.shared.vm.VmTestCase;
import org.eclipse.tracecompass.incubator.virtual.machine.analysis.core.tests.shared.vm.VmTestExperiment;
import org.eclipse.tracecompass.incubator.virtual.machine.analysis.core.tests.shared.vm.VmTraces;
import org.eclipse.tracecompass.statesystem.core.interval.ITmfStateInterval;
import org.eclipse.tracecompass.statesystem.core.statevalue.ITmfStateValue;
import org.eclipse.tracecompass.statesystem.core.statevalue.TmfStateValue;
import org.eclipse.tracecompass.statesystem.core.tests.shared.utils.StateIntervalStub;
import org.eclipse.tracecompass.statesystem.core.tests.shared.utils.StateSystemTestUtils;
import com.google.common.collect.ImmutableList;
/**
* Test case for the QemuKvm experiment and Fused VM analysis
*
* @author Geneviève Bastien
*/
public class OneQemuKvmFusedTestCase extends VmTestCase {
private static final ITmfStateValue HOST_SV_STRING = TmfStateValue.newValueString(VmTraces.HOST_ONE_QEMUKVM.getHostId());
private static final ITmfStateValue GUEST_SV_STRING = TmfStateValue.newValueString(VmTraces.GUEST_ONE_QEMUKVM.getHostId());
/**
* Constructor
*/
public OneQemuKvmFusedTestCase() {
super(VmTestExperiment.ONE_QEMUKVM);
}
@Override
public Set<IntervalInfo> getTestIntervals() {
Set<IntervalInfo> info = new HashSet<>();
/* Verify the 'CPUs/0' attributes: first the machine */
ImmutableList<ITmfStateInterval> intervals = ImmutableList.of(new StateIntervalStub(1, 49, TmfStateValue.nullValue()),
new StateIntervalStub(50, 154, HOST_SV_STRING),
new StateIntervalStub(155, 194, GUEST_SV_STRING),
new StateIntervalStub(195, 209, HOST_SV_STRING),
new StateIntervalStub(210, 244, GUEST_SV_STRING),
new StateIntervalStub(245, 259, HOST_SV_STRING),
new StateIntervalStub(260, 294, GUEST_SV_STRING),
new StateIntervalStub(295, 354, HOST_SV_STRING),
new StateIntervalStub(355, 375, GUEST_SV_STRING));
info.add(new IntervalInfo(intervals, FusedAttributes.CPUS, "0", FusedAttributes.MACHINE_NAME));
/* Verify the current thread */
intervals = ImmutableList.of(new StateIntervalStub(1, 99, TmfStateValue.nullValue()),
new StateIntervalStub(100, 149, TmfStateValue.newValueInt(30)),
new StateIntervalStub(150, 154, TmfStateValue.newValueInt(31)),
new StateIntervalStub(155, 174, TmfStateValue.newValueInt(131)),
new StateIntervalStub(175, 194, TmfStateValue.newValueInt(130)),
new StateIntervalStub(195, 209, TmfStateValue.newValueInt(31)),
new StateIntervalStub(210, 224, TmfStateValue.newValueInt(130)),
new StateIntervalStub(225, 244, TmfStateValue.newValueInt(131)),
new StateIntervalStub(245, 259, TmfStateValue.newValueInt(31)),
new StateIntervalStub(260, 274, TmfStateValue.newValueInt(131)),
new StateIntervalStub(275, 294, TmfStateValue.newValueInt(130)),
new StateIntervalStub(295, 299, TmfStateValue.newValueInt(31)),
new StateIntervalStub(300, 349, TmfStateValue.newValueInt(30)),
new StateIntervalStub(350, 354, TmfStateValue.newValueInt(31)),
new StateIntervalStub(355, 374, TmfStateValue.newValueInt(130)),
new StateIntervalStub(375, 375, TmfStateValue.newValueInt(131)));
info.add(new IntervalInfo(intervals, FusedAttributes.CPUS, "0", FusedAttributes.CURRENT_THREAD));
return info;
}
@Override
public Set<PunctualInfo> getPunctualTestData() {
Set<PunctualInfo> info = new HashSet<>();
// Check the 'Machines' sub-tree towards the end of the trace
PunctualInfo oneInfo = new PunctualInfo(300L);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.HOST_ONE_QEMUKVM.getHostId(), FusedAttributes.CPUS, "0"), null);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.HOST_ONE_QEMUKVM.getHostId(), FusedAttributes.PARENT), null);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.HOST_ONE_QEMUKVM.getHostId(), FusedAttributes.CONTAINERS), null);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.GUEST_ONE_QEMUKVM.getHostId(), FusedAttributes.CPUS, "0"), 31);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.GUEST_ONE_QEMUKVM.getHostId(), FusedAttributes.PARENT), VmTraces.HOST_ONE_QEMUKVM.getHostId());
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.GUEST_ONE_QEMUKVM.getHostId(), FusedAttributes.PCPUS, "0"), null);
oneInfo.addValue(StateSystemTestUtils.makeAttribute(FusedAttributes.HOSTS, VmTraces.GUEST_ONE_QEMUKVM.getHostId(), FusedAttributes.CONTAINERS), null);
info.add(oneInfo);
return info;
}
}
|
