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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
/*******************************************************************************
* Copyright (c) 2010 Ericsson
*
* 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
*
* Contributors:
* Francois Chouinard - Initial API and implementation
*******************************************************************************/
package org.eclipse.linuxtools.lttng.trace;
import org.eclipse.linuxtools.tmf.event.TmfEvent;
import org.eclipse.linuxtools.tmf.event.TmfTimestamp;
import org.eclipse.linuxtools.tmf.experiment.TmfExperiment;
import org.eclipse.linuxtools.tmf.experiment.TmfExperimentContext;
import org.eclipse.linuxtools.tmf.experiment.TmfExperimentLocation;
import org.eclipse.linuxtools.tmf.signal.TmfSignalManager;
import org.eclipse.linuxtools.tmf.trace.ITmfTrace;
import org.eclipse.linuxtools.tmf.trace.TmfContext;
/**
* <b><u>LTTngExperiment</u></b>
* <p>
* Temporary class to resolve a basic incompatibility between TMF and LTTng.
* <p>
*/
public class LTTngExperiment<T extends TmfEvent> extends TmfExperiment<T> implements ITmfTrace {
private static final int DEFAULT_INDEX_PAGE_SIZE = 5000;
// ------------------------------------------------------------------------
// Constructors
// ------------------------------------------------------------------------
/**
* @param type
* @param id
* @param traces
* @param epoch
* @param indexPageSize
*/
public LTTngExperiment(Class<T> type, String id, ITmfTrace[] traces, TmfTimestamp epoch, int indexPageSize) {
this(type, id, traces, TmfTimestamp.Zero, indexPageSize, false);
}
public LTTngExperiment(Class<T> type, String id, ITmfTrace[] traces, TmfTimestamp epoch, int indexPageSize, boolean preIndexExperiment) {
super(type, id, traces, epoch, indexPageSize, preIndexExperiment);
}
/**
* @param type
* @param id
* @param traces
*/
public LTTngExperiment(Class<T> type, String id, ITmfTrace[] traces) {
this(type, id, traces, TmfTimestamp.Zero, DEFAULT_INDEX_PAGE_SIZE);
}
/**
* @param type
* @param id
* @param traces
* @param indexPageSize
*/
public LTTngExperiment(Class<T> type, String id, ITmfTrace[] traces, int indexPageSize) {
this(type, id, traces, TmfTimestamp.Zero, indexPageSize);
}
public LTTngExperiment(LTTngExperiment<T> other) {
super(other.getName() + "(clone)", other.fType);
fEpoch = other.fEpoch;
fIndexPageSize = other.fIndexPageSize;
fTraces = new ITmfTrace[other.fTraces.length];
for (int trace = 0; trace < other.fTraces.length; trace++) {
fTraces[trace] = other.fTraces[trace].createTraceCopy();
}
fNbEvents = other.fNbEvents;
fTimeRange = other.fTimeRange;
}
@Override
public LTTngExperiment<T> createTraceCopy() {
LTTngExperiment<T> experiment = new LTTngExperiment<T>(this);
TmfSignalManager.deregister(experiment);
return experiment;
}
// ------------------------------------------------------------------------
// ITmfTrace trace positioning
// ------------------------------------------------------------------------
@Override
public synchronized TmfEvent getNextEvent(TmfContext context) {
// Validate the context
if (!(context instanceof TmfExperimentContext)) {
return null; // Throw an exception?
}
if (!context.equals(fExperimentContext)) {
// Tracer.trace("Ctx: Restoring context");
seekLocation(context.getLocation());
}
TmfExperimentContext expContext = (TmfExperimentContext) context;
// dumpContext(expContext, true);
// If an event was consumed previously, get the next one from that trace
int lastTrace = expContext.getLastTrace();
if (lastTrace != TmfExperimentContext.NO_TRACE) {
TmfContext traceContext = expContext.getContexts()[lastTrace];
expContext.getEvents()[lastTrace] = expContext.getTraces()[lastTrace].getNextEvent(traceContext);
expContext.setLastTrace(TmfExperimentContext.NO_TRACE);
}
// Scan the candidate events and identify the "next" trace to read from
int trace = TmfExperimentContext.NO_TRACE;
TmfTimestamp timestamp = TmfTimestamp.BigCrunch;
for (int i = 0; i < expContext.getTraces().length; i++) {
TmfEvent event = expContext.getEvents()[i];
if (event != null && event.getTimestamp() != null) {
TmfTimestamp otherTS = event.getTimestamp();
if (otherTS.compareTo(timestamp, true) < 0) {
trace = i;
timestamp = otherTS;
}
}
}
// Update the experiment context and set the "next" event
TmfEvent event = null;
if (trace != TmfExperimentContext.NO_TRACE) {
// updateIndex(expContext, timestamp);
TmfContext traceContext = expContext.getContexts()[trace];
TmfExperimentLocation expLocation = (TmfExperimentLocation) expContext.getLocation();
expLocation.getLocation()[trace] = traceContext.getLocation().clone();
updateIndex(expContext, timestamp);
expLocation.getRanks()[trace] = traceContext.getRank();
expContext.setLastTrace(trace);
expContext.updateRank(1);
event = expContext.getEvents()[trace];
}
// if (event != null) {
// Tracer.trace("Exp: " + (expContext.getRank() - 1) + ": " + event.getTimestamp().toString());
// dumpContext(expContext, false);
// Tracer.trace("Ctx: Event returned= " + event.getTimestamp().toString());
// }
return event;
}
/* (non-Javadoc)
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
return "[LTTngExperiment (" + getName() + ")]";
}
}
|
