Commit | Line | Data |
---|---|---|
d18dd09b | 1 | /******************************************************************************* |
0316808c | 2 | * Copyright (c) 2009, 2010, 2012 Ericsson |
d18dd09b ASL |
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 | * Francois Chouinard - Initial API and implementation | |
0316808c | 11 | * Francois Chouinard - Adjusted for new Trace Model |
d18dd09b ASL |
12 | *******************************************************************************/ |
13 | ||
9e0640dc | 14 | package org.eclipse.linuxtools.tmf.core.tests.trace; |
d18dd09b ASL |
15 | |
16 | import java.io.File; | |
17 | import java.io.IOException; | |
18 | import java.net.URISyntaxException; | |
19 | import java.net.URL; | |
20 | import java.util.Vector; | |
21 | ||
22 | import junit.framework.TestCase; | |
23 | ||
9e0640dc | 24 | import org.eclipse.core.resources.IFile; |
d18dd09b ASL |
25 | import org.eclipse.core.runtime.FileLocator; |
26 | import org.eclipse.core.runtime.Path; | |
9e0640dc | 27 | import org.eclipse.linuxtools.internal.tmf.core.trace.TmfExperimentLocation; |
72f1e62a | 28 | import org.eclipse.linuxtools.tmf.core.event.ITmfEvent; |
6c13869b FC |
29 | import org.eclipse.linuxtools.tmf.core.event.TmfEvent; |
30 | import org.eclipse.linuxtools.tmf.core.event.TmfTimeRange; | |
31 | import org.eclipse.linuxtools.tmf.core.event.TmfTimestamp; | |
b4f71e4a | 32 | import org.eclipse.linuxtools.tmf.core.exceptions.TmfTraceException; |
6c13869b FC |
33 | import org.eclipse.linuxtools.tmf.core.request.TmfEventRequest; |
34 | import org.eclipse.linuxtools.tmf.core.tests.TmfCoreTestPlugin; | |
35 | import org.eclipse.linuxtools.tmf.core.trace.ITmfContext; | |
0316808c | 36 | import org.eclipse.linuxtools.tmf.core.trace.ITmfLocation; |
6c13869b | 37 | import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace; |
9e0640dc FC |
38 | import org.eclipse.linuxtools.tmf.core.trace.TmfExperiment; |
39 | import org.eclipse.linuxtools.tmf.core.trace.TmfLocation; | |
40 | import org.eclipse.linuxtools.tmf.tests.stubs.trace.TmfExperimentStub; | |
4918b8f2 | 41 | import org.eclipse.linuxtools.tmf.tests.stubs.trace.TmfTraceStub; |
d18dd09b ASL |
42 | |
43 | /** | |
0316808c | 44 | * Test suite for the TmfExperiment class (single trace). |
d18dd09b | 45 | */ |
2d223a34 | 46 | @SuppressWarnings({ "nls" }) |
d18dd09b ASL |
47 | public class TmfExperimentTest extends TestCase { |
48 | ||
0316808c FC |
49 | // ------------------------------------------------------------------------ |
50 | // Attributes | |
51 | // ------------------------------------------------------------------------ | |
52 | ||
d18dd09b ASL |
53 | private static final String DIRECTORY = "testfiles"; |
54 | private static final String TEST_STREAM = "A-Test-10K"; | |
55 | private static final String EXPERIMENT = "MyExperiment"; | |
56 | private static int NB_EVENTS = 10000; | |
0316808c | 57 | private static int BLOCK_SIZE = 1000; |
d18dd09b | 58 | |
9e0640dc | 59 | private ITmfTrace<TmfEvent>[] fTestTraces; |
0879b6b9 | 60 | private TmfExperimentStub<ITmfEvent> fExperiment; |
d18dd09b ASL |
61 | |
62 | private static byte SCALE = (byte) -3; | |
63 | ||
64 | // ------------------------------------------------------------------------ | |
65 | // Housekeeping | |
66 | // ------------------------------------------------------------------------ | |
67 | ||
9e0640dc FC |
68 | @SuppressWarnings("unchecked") |
69 | private synchronized ITmfTrace<?>[] setupTrace(final String path) { | |
70 | if (fTestTraces == null) { | |
71 | fTestTraces = new ITmfTrace[1]; | |
25e48683 FC |
72 | try { |
73 | final URL location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(path), null); | |
74 | final File test = new File(FileLocator.toFileURL(location).toURI()); | |
20658947 | 75 | final TmfTraceStub trace = new TmfTraceStub(test.getPath(), 0, true); |
9e0640dc | 76 | fTestTraces[0] = trace; |
b4f71e4a FC |
77 | } catch (final TmfTraceException e) { |
78 | e.printStackTrace(); | |
25e48683 FC |
79 | } catch (final URISyntaxException e) { |
80 | e.printStackTrace(); | |
81 | } catch (final IOException e) { | |
82 | e.printStackTrace(); | |
83 | } | |
84 | } | |
9e0640dc | 85 | return fTestTraces; |
d18dd09b ASL |
86 | } |
87 | ||
9e0640dc | 88 | private synchronized void setupExperiment() { |
20658947 | 89 | if (fExperiment == null) { |
9e0640dc FC |
90 | fExperiment = new TmfExperimentStub<ITmfEvent>(EXPERIMENT, fTestTraces, BLOCK_SIZE); |
91 | fExperiment.getIndexer().buildIndex(0, TmfTimeRange.ETERNITY, true); | |
20658947 | 92 | } |
d18dd09b ASL |
93 | } |
94 | ||
25e48683 FC |
95 | public TmfExperimentTest(final String name) throws Exception { |
96 | super(name); | |
97 | } | |
d18dd09b | 98 | |
25e48683 FC |
99 | @Override |
100 | protected void setUp() throws Exception { | |
101 | super.setUp(); | |
102 | setupTrace(DIRECTORY + File.separator + TEST_STREAM); | |
103 | setupExperiment(); | |
104 | } | |
d18dd09b | 105 | |
25e48683 FC |
106 | @Override |
107 | protected void tearDown() throws Exception { | |
108 | super.tearDown(); | |
109 | } | |
d18dd09b ASL |
110 | |
111 | // ------------------------------------------------------------------------ | |
112 | // Constructor | |
113 | // ------------------------------------------------------------------------ | |
114 | ||
9e0640dc FC |
115 | public void testSimpleTmfExperimentConstructor() { |
116 | ||
117 | TmfExperiment<TmfEvent> experiment = new TmfExperiment<TmfEvent>(TmfEvent.class, EXPERIMENT, fTestTraces); | |
118 | assertEquals("GetId", EXPERIMENT, experiment.getName()); | |
119 | assertEquals("GetCacheSize", TmfExperiment.DEFAULT_INDEX_PAGE_SIZE, experiment.getCacheSize()); | |
120 | experiment.dispose(); | |
121 | ||
122 | experiment = new TmfExperiment<TmfEvent>(TmfEvent.class, EXPERIMENT, null); | |
123 | experiment.dispose(); | |
124 | } | |
125 | ||
126 | public void testNormalTmfExperimentConstructor() { | |
cb866e08 | 127 | |
25e48683 | 128 | assertEquals("GetId", EXPERIMENT, fExperiment.getName()); |
d18dd09b ASL |
129 | assertEquals("GetNbEvents", NB_EVENTS, fExperiment.getNbEvents()); |
130 | ||
07671572 FC |
131 | final long nbExperimentEvents = fExperiment.getNbEvents(); |
132 | assertEquals("GetNbEvents", NB_EVENTS, nbExperimentEvents); | |
133 | ||
25e48683 | 134 | final long nbTraceEvents = fExperiment.getTraces()[0].getNbEvents(); |
82e04272 FC |
135 | assertEquals("GetNbEvents", NB_EVENTS, nbTraceEvents); |
136 | ||
25e48683 | 137 | final TmfTimeRange timeRange = fExperiment.getTimeRange(); |
d18dd09b ASL |
138 | assertEquals("getStartTime", 1, timeRange.getStartTime().getValue()); |
139 | assertEquals("getEndTime", NB_EVENTS, timeRange.getEndTime().getValue()); | |
25e48683 | 140 | } |
d18dd09b | 141 | |
9e0640dc FC |
142 | @SuppressWarnings("static-access") |
143 | public void testSetCurrentExperiment() { | |
144 | ||
145 | TmfExperiment<TmfEvent> experiment = new TmfExperiment<TmfEvent>(TmfEvent.class, EXPERIMENT, fTestTraces); | |
146 | experiment.setCurrentExperiment(experiment); | |
147 | assertEquals("getCurrentExperiment", experiment, experiment.getCurrentExperiment()); | |
148 | ||
149 | TmfExperiment<TmfEvent> experiment2 = new TmfExperiment<TmfEvent>(TmfEvent.class, EXPERIMENT, null); | |
150 | experiment.setCurrentExperiment(experiment2); | |
151 | assertEquals("getCurrentExperiment", experiment2, experiment.getCurrentExperiment()); | |
152 | ||
153 | experiment.dispose(); | |
154 | experiment2.dispose(); | |
155 | } | |
156 | ||
157 | // ------------------------------------------------------------------------ | |
158 | // getTimestamp | |
159 | // ------------------------------------------------------------------------ | |
160 | ||
161 | public void testGetTimestamp() throws Exception { | |
162 | assertTrue("getTimestamp", fExperiment.getTimestamp( 0).equals(new TmfTimestamp( 1, (byte) -3))); | |
163 | assertTrue("getTimestamp", fExperiment.getTimestamp( 10).equals(new TmfTimestamp( 11, (byte) -3))); | |
164 | assertTrue("getTimestamp", fExperiment.getTimestamp( 100).equals(new TmfTimestamp( 101, (byte) -3))); | |
165 | assertTrue("getTimestamp", fExperiment.getTimestamp( 1000).equals(new TmfTimestamp(1001, (byte) -3))); | |
166 | assertTrue("getTimestamp", fExperiment.getTimestamp( 2000).equals(new TmfTimestamp(2001, (byte) -3))); | |
167 | assertTrue("getTimestamp", fExperiment.getTimestamp( 2500).equals(new TmfTimestamp(2501, (byte) -3))); | |
168 | assertNull("getTimestamp", fExperiment.getTimestamp(10000)); | |
169 | } | |
170 | ||
171 | // ------------------------------------------------------------------------ | |
172 | // Bookmarks file handling | |
173 | // ------------------------------------------------------------------------ | |
174 | ||
175 | public void testBookmarks() throws Exception { | |
176 | assertNull("GetBookmarksFile", fExperiment.getBookmarksFile()); | |
9e0640dc FC |
177 | IFile bookmarks = (IFile) fTestTraces[0].getResource(); |
178 | fExperiment.setBookmarksFile(bookmarks); | |
179 | assertEquals("GetBookmarksFile", bookmarks, fExperiment.getBookmarksFile()); | |
180 | } | |
181 | ||
182 | // ------------------------------------------------------------------------ | |
183 | // seekEvent by location | |
184 | // ------------------------------------------------------------------------ | |
185 | ||
9e0640dc FC |
186 | public void testSeekBadLocation() throws Exception { |
187 | ITmfContext context = fExperiment.seekEvent((ITmfLocation<?>) new TmfLocation<Long>(0L)); | |
188 | assertNull("seekEvent", context); | |
189 | } | |
190 | ||
191 | public void testSeekNoTrace() throws Exception { | |
192 | TmfExperiment<TmfEvent> experiment = new TmfExperiment<TmfEvent>(TmfEvent.class, EXPERIMENT, null); | |
9e0640dc FC |
193 | ITmfContext context = experiment.seekEvent((TmfExperimentLocation) null); |
194 | assertNull("seekEvent", context); | |
195 | experiment.dispose(); | |
196 | } | |
197 | ||
198 | // ------------------------------------------------------------------------ | |
199 | // seekEvent on ratio | |
200 | // ------------------------------------------------------------------------ | |
201 | ||
202 | public void testSeekEventOnRatio() throws Exception { | |
203 | ||
204 | // First event | |
205 | ITmfContext context = fExperiment.seekEvent(0.0); | |
206 | assertEquals("Context rank", 0, context.getRank()); | |
207 | ITmfEvent event = fExperiment.parseEvent(context); | |
208 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); | |
209 | assertEquals("Context rank", 0, context.getRank()); | |
210 | ||
211 | // Middle event | |
212 | int midTrace = NB_EVENTS / 2; | |
213 | context = fExperiment.seekEvent(0.5); | |
214 | assertEquals("Context rank", midTrace, context.getRank()); | |
215 | event = fExperiment.parseEvent(context); | |
216 | assertEquals("Event timestamp", midTrace + 1, event.getTimestamp().getValue()); | |
217 | assertEquals("Context rank", midTrace, context.getRank()); | |
218 | ||
219 | // Last event | |
220 | context = fExperiment.seekEvent(1.0); | |
221 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
222 | event = fExperiment.parseEvent(context); | |
223 | assertNull("Event timestamp", event); | |
224 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
225 | ||
226 | // Beyond last event | |
227 | context = fExperiment.seekEvent(1.1); | |
228 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
229 | event = fExperiment.parseEvent(context); | |
230 | assertNull("Event timestamp", event); | |
231 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
232 | ||
233 | // Negative ratio | |
234 | context = fExperiment.seekEvent(-0.5); | |
235 | assertEquals("Context rank", 0, context.getRank()); | |
236 | event = fExperiment.parseEvent(context); | |
237 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); | |
238 | assertEquals("Context rank", 0, context.getRank()); | |
239 | } | |
240 | ||
0879b6b9 | 241 | @SuppressWarnings("rawtypes") |
9e0640dc FC |
242 | public void testGetLocationRatio() throws Exception { |
243 | ||
244 | // First event | |
245 | ITmfContext context = fExperiment.seekEvent((ITmfLocation) null); | |
246 | double ratio = fExperiment.getLocationRatio(context.getLocation()); | |
9a7f542f | 247 | assertEquals("getLocationRatio", 0.0, ratio); |
9e0640dc FC |
248 | |
249 | // Middle event | |
250 | context = fExperiment.seekEvent(NB_EVENTS / 2); | |
251 | ratio = fExperiment.getLocationRatio(context.getLocation()); | |
9a7f542f | 252 | assertEquals("getLocationRatio", (double) (NB_EVENTS / 2) / NB_EVENTS, ratio); |
9e0640dc FC |
253 | |
254 | // Last event | |
255 | context = fExperiment.seekEvent(NB_EVENTS - 1); | |
256 | ratio = fExperiment.getLocationRatio(context.getLocation()); | |
9a7f542f | 257 | assertEquals("getLocationRatio", (double) (NB_EVENTS - 1) / NB_EVENTS, ratio); |
9e0640dc FC |
258 | } |
259 | ||
260 | // @SuppressWarnings({ "unchecked", "rawtypes" }) | |
261 | // public void testGetCurrentLocation() throws Exception { | |
262 | // ITmfContext context = fExperiment.seekEvent((ITmfLocation) null); | |
263 | // ITmfLocation location = fExperiment.getCurrentLocation(); | |
264 | // assertEquals("getCurrentLocation", location, context.getLocation()); | |
265 | // } | |
266 | ||
d18dd09b | 267 | // ------------------------------------------------------------------------ |
0316808c | 268 | // seekEvent on rank |
d18dd09b ASL |
269 | // ------------------------------------------------------------------------ |
270 | ||
0316808c | 271 | public void testSeekRankOnCacheBoundary() throws Exception { |
d18dd09b | 272 | |
0316808c | 273 | long cacheSize = fExperiment.getCacheSize(); |
9b635e61 | 274 | |
0316808c FC |
275 | // On lower bound, returns the first event (TS = 1) |
276 | ITmfContext context = fExperiment.seekEvent(0); | |
277 | assertEquals("Context rank", 0, context.getRank()); | |
25e48683 | 278 | |
c32744d6 | 279 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 280 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
0316808c | 281 | assertEquals("Context rank", 1, context.getRank()); |
25e48683 | 282 | |
0316808c FC |
283 | // Position trace at event rank [cacheSize] |
284 | context = fExperiment.seekEvent(cacheSize); | |
285 | assertEquals("Context rank", cacheSize, context.getRank()); | |
25e48683 | 286 | |
c32744d6 | 287 | event = fExperiment.getNext(context); |
0316808c FC |
288 | assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue()); |
289 | assertEquals("Context rank", cacheSize + 1, context.getRank()); | |
d18dd09b | 290 | |
0316808c FC |
291 | // Position trace at event rank [4 * cacheSize] |
292 | context = fExperiment.seekEvent(4 * cacheSize); | |
293 | assertEquals("Context rank", 4 * cacheSize, context.getRank()); | |
25e48683 | 294 | |
c32744d6 | 295 | event = fExperiment.getNext(context); |
0316808c FC |
296 | assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue()); |
297 | assertEquals("Context rank", 4 * cacheSize + 1, context.getRank()); | |
d18dd09b ASL |
298 | } |
299 | ||
0316808c | 300 | public void testSeekRankNotOnCacheBoundary() throws Exception { |
d18dd09b | 301 | |
0316808c | 302 | long cacheSize = fExperiment.getCacheSize(); |
25e48683 | 303 | |
0316808c FC |
304 | // Position trace at event rank 9 |
305 | ITmfContext context = fExperiment.seekEvent(9); | |
306 | assertEquals("Context rank", 9, context.getRank()); | |
25e48683 | 307 | |
c32744d6 | 308 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 309 | assertEquals("Event timestamp", 10, event.getTimestamp().getValue()); |
0316808c | 310 | assertEquals("Context rank", 10, context.getRank()); |
d18dd09b | 311 | |
0316808c FC |
312 | // Position trace at event rank [cacheSize - 1] |
313 | context = fExperiment.seekEvent(cacheSize - 1); | |
314 | assertEquals("Context rank", cacheSize - 1, context.getRank()); | |
25e48683 | 315 | |
c32744d6 | 316 | event = fExperiment.getNext(context); |
0316808c FC |
317 | assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue()); |
318 | assertEquals("Context rank", cacheSize, context.getRank()); | |
d18dd09b | 319 | |
0316808c FC |
320 | // Position trace at event rank [cacheSize + 1] |
321 | context = fExperiment.seekEvent(cacheSize + 1); | |
322 | assertEquals("Context rank", cacheSize + 1, context.getRank()); | |
25e48683 | 323 | |
c32744d6 | 324 | event = fExperiment.getNext(context); |
0316808c FC |
325 | assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue()); |
326 | assertEquals("Context rank", cacheSize + 2, context.getRank()); | |
d18dd09b | 327 | |
25e48683 | 328 | // Position trace at event rank 4500 |
0316808c FC |
329 | context = fExperiment.seekEvent(4500); |
330 | assertEquals("Context rank", 4500, context.getRank()); | |
25e48683 | 331 | |
c32744d6 | 332 | event = fExperiment.getNext(context); |
d18dd09b | 333 | assertEquals("Event timestamp", 4501, event.getTimestamp().getValue()); |
0316808c | 334 | assertEquals("Context rank", 4501, context.getRank()); |
d18dd09b ASL |
335 | } |
336 | ||
0316808c | 337 | public void testSeekRankOutOfScope() throws Exception { |
d18dd09b | 338 | |
25e48683 | 339 | // Position trace at beginning |
0316808c | 340 | ITmfContext context = fExperiment.seekEvent(-1); |
9b635e61 | 341 | assertEquals("Event rank", 0, context.getRank()); |
25e48683 | 342 | |
c32744d6 | 343 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 344 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
0316808c | 345 | assertEquals("Context rank", 1, context.getRank()); |
d18dd09b | 346 | |
25e48683 | 347 | // Position trace at event passed the end |
0316808c FC |
348 | context = fExperiment.seekEvent(NB_EVENTS); |
349 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
350 | ||
c32744d6 | 351 | event = fExperiment.getNext(context); |
0316808c FC |
352 | assertNull("Event", event); |
353 | assertEquals("Context rank", NB_EVENTS, context.getRank()); | |
d18dd09b ASL |
354 | } |
355 | ||
356 | // ------------------------------------------------------------------------ | |
357 | // seekEvent on timestamp | |
358 | // ------------------------------------------------------------------------ | |
359 | ||
0316808c | 360 | public void testSeekTimestampOnCacheBoundary() throws Exception { |
d18dd09b | 361 | |
0316808c | 362 | long cacheSize = fExperiment.getCacheSize(); |
25e48683 | 363 | |
0316808c FC |
364 | // Position trace at event rank 0 |
365 | ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(1, SCALE, 0)); | |
366 | assertEquals("Context rank", 0, context.getRank()); | |
25e48683 | 367 | |
c32744d6 | 368 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 369 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
0316808c | 370 | assertEquals("Context rank", 1, context.getRank()); |
25e48683 | 371 | |
0316808c FC |
372 | // Position trace at event rank [cacheSize] |
373 | context = fExperiment.seekEvent(new TmfTimestamp(cacheSize + 1, SCALE, 0)); | |
374 | assertEquals("Event rank", cacheSize, context.getRank()); | |
25e48683 | 375 | |
c32744d6 | 376 | event = fExperiment.getNext(context); |
0316808c FC |
377 | assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue()); |
378 | assertEquals("Context rank", cacheSize + 1, context.getRank()); | |
d18dd09b | 379 | |
0316808c FC |
380 | // Position trace at event rank [4 * cacheSize] |
381 | context = fExperiment.seekEvent(new TmfTimestamp(4 * cacheSize + 1, SCALE, 0)); | |
382 | assertEquals("Context rank", 4 * cacheSize, context.getRank()); | |
25e48683 | 383 | |
c32744d6 | 384 | event = fExperiment.getNext(context); |
0316808c FC |
385 | assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue()); |
386 | assertEquals("Context rank", 4 * cacheSize + 1, context.getRank()); | |
d18dd09b ASL |
387 | } |
388 | ||
0316808c | 389 | public void testSeekTimestampNotOnCacheBoundary() throws Exception { |
d18dd09b | 390 | |
0316808c FC |
391 | // Position trace at event rank 1 (TS = 2) |
392 | ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(2, SCALE, 0)); | |
393 | assertEquals("Context rank", 1, context.getRank()); | |
25e48683 | 394 | |
c32744d6 | 395 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 396 | assertEquals("Event timestamp", 2, event.getTimestamp().getValue()); |
0316808c | 397 | assertEquals("Context rank", 2, context.getRank()); |
d18dd09b | 398 | |
0316808c | 399 | // Position trace at event rank 9 (TS = 10) |
25e48683 | 400 | context = fExperiment.seekEvent(new TmfTimestamp(10, SCALE, 0)); |
0316808c | 401 | assertEquals("Context rank", 9, context.getRank()); |
25e48683 | 402 | |
c32744d6 | 403 | event = fExperiment.getNext(context); |
d18dd09b | 404 | assertEquals("Event timestamp", 10, event.getTimestamp().getValue()); |
0316808c | 405 | assertEquals("Context rank", 10, context.getRank()); |
d18dd09b | 406 | |
0316808c | 407 | // Position trace at event rank 999 (TS = 1000) |
d18dd09b | 408 | context = fExperiment.seekEvent(new TmfTimestamp(1000, SCALE, 0)); |
0316808c | 409 | assertEquals("Context rank", 999, context.getRank()); |
25e48683 | 410 | |
c32744d6 | 411 | event = fExperiment.getNext(context); |
d18dd09b | 412 | assertEquals("Event timestamp", 1000, event.getTimestamp().getValue()); |
0316808c | 413 | assertEquals("Context rank", 1000, context.getRank()); |
d18dd09b | 414 | |
0316808c | 415 | // Position trace at event rank 1001 (TS = 1002) |
d18dd09b | 416 | context = fExperiment.seekEvent(new TmfTimestamp(1002, SCALE, 0)); |
0316808c | 417 | assertEquals("Context rank", 1001, context.getRank()); |
25e48683 | 418 | |
c32744d6 | 419 | event = fExperiment.getNext(context); |
d18dd09b | 420 | assertEquals("Event timestamp", 1002, event.getTimestamp().getValue()); |
0316808c | 421 | assertEquals("Context rank", 1002, context.getRank()); |
d18dd09b | 422 | |
0316808c | 423 | // Position trace at event rank 4500 (TS = 4501) |
d18dd09b | 424 | context = fExperiment.seekEvent(new TmfTimestamp(4501, SCALE, 0)); |
0316808c | 425 | assertEquals("Context rank", 4500, context.getRank()); |
25e48683 | 426 | |
c32744d6 | 427 | event = fExperiment.getNext(context); |
d18dd09b | 428 | assertEquals("Event timestamp", 4501, event.getTimestamp().getValue()); |
0316808c | 429 | assertEquals("Context rank", 4501, context.getRank()); |
d18dd09b ASL |
430 | } |
431 | ||
0316808c | 432 | public void testSeekTimestampOutOfScope() throws Exception { |
d18dd09b | 433 | |
25e48683 | 434 | // Position trace at beginning |
0316808c | 435 | ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(-1, SCALE, 0)); |
d18dd09b | 436 | assertEquals("Event rank", 0, context.getRank()); |
25e48683 | 437 | |
c32744d6 | 438 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b ASL |
439 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
440 | assertEquals("Event rank", 1, context.getRank()); | |
441 | ||
25e48683 | 442 | // Position trace at event passed the end |
d18dd09b | 443 | context = fExperiment.seekEvent(new TmfTimestamp(NB_EVENTS + 1, SCALE, 0)); |
c32744d6 | 444 | event = fExperiment.getNext(context); |
0316808c | 445 | assertNull("Event location", event); |
9b635e61 | 446 | assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank()); |
d18dd09b ASL |
447 | } |
448 | ||
449 | // ------------------------------------------------------------------------ | |
0316808c | 450 | // seekEvent by location (context rank is undefined) |
d18dd09b ASL |
451 | // ------------------------------------------------------------------------ |
452 | ||
0316808c FC |
453 | public void testSeekLocationOnCacheBoundary() throws Exception { |
454 | ||
455 | long cacheSize = fExperiment.getCacheSize(); | |
d18dd09b | 456 | |
0316808c FC |
457 | // Position trace at event rank 0 |
458 | ITmfContext tmpContext = fExperiment.seekEvent(0); | |
459 | ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation()); | |
25e48683 | 460 | |
c32744d6 | 461 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 462 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
25e48683 | 463 | |
c32744d6 | 464 | event = fExperiment.getNext(context); |
0316808c | 465 | assertEquals("Event timestamp", 2, event.getTimestamp().getValue()); |
d18dd09b | 466 | |
0316808c FC |
467 | // Position trace at event rank 'cacheSize' |
468 | tmpContext = fExperiment.seekEvent(cacheSize); | |
469 | context = fExperiment.seekEvent(tmpContext.getLocation()); | |
25e48683 | 470 | |
c32744d6 | 471 | event = fExperiment.getNext(context); |
0316808c | 472 | assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue()); |
25e48683 | 473 | |
c32744d6 | 474 | event = fExperiment.getNext(context); |
0316808c | 475 | assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue()); |
d18dd09b | 476 | |
0316808c FC |
477 | // Position trace at event rank 4 * 'cacheSize' |
478 | tmpContext = fExperiment.seekEvent(4 * cacheSize); | |
479 | context = fExperiment.seekEvent(tmpContext.getLocation()); | |
25e48683 | 480 | |
c32744d6 | 481 | event = fExperiment.getNext(context); |
0316808c | 482 | assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue()); |
25e48683 | 483 | |
c32744d6 | 484 | event = fExperiment.getNext(context); |
0316808c | 485 | assertEquals("Event timestamp", 4 * cacheSize + 2, event.getTimestamp().getValue()); |
d18dd09b ASL |
486 | } |
487 | ||
0316808c | 488 | public void testSeekLocationNotOnCacheBoundary() throws Exception { |
25e48683 | 489 | |
0316808c | 490 | long cacheSize = fExperiment.getCacheSize(); |
25e48683 | 491 | |
0316808c FC |
492 | // Position trace at event 'cacheSize' - 1 |
493 | ITmfContext tmpContext = fExperiment.seekEvent(cacheSize - 1); | |
494 | ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation()); | |
d18dd09b | 495 | |
c32744d6 | 496 | ITmfEvent event = fExperiment.getNext(context); |
0316808c | 497 | assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue()); |
25e48683 | 498 | |
c32744d6 | 499 | event = fExperiment.getNext(context); |
0316808c | 500 | assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue()); |
d18dd09b | 501 | |
0316808c FC |
502 | // Position trace at event rank 2 * 'cacheSize' - 1 |
503 | tmpContext = fExperiment.seekEvent(2 * cacheSize - 1); | |
504 | context = fExperiment.seekEvent(tmpContext.getLocation()); | |
505 | context = fExperiment.seekEvent(2 * cacheSize - 1); | |
25e48683 | 506 | |
c32744d6 | 507 | event = fExperiment.getNext(context); |
0316808c | 508 | assertEquals("Event timestamp", 2 * cacheSize, event.getTimestamp().getValue()); |
25e48683 | 509 | |
c32744d6 | 510 | event = fExperiment.getNext(context); |
0316808c | 511 | assertEquals("Event timestamp", 2 * cacheSize + 1, event.getTimestamp().getValue()); |
d18dd09b | 512 | |
25e48683 | 513 | // Position trace at event rank 4500 |
0316808c FC |
514 | tmpContext = fExperiment.seekEvent(4500); |
515 | context = fExperiment.seekEvent(tmpContext.getLocation()); | |
25e48683 | 516 | |
c32744d6 | 517 | event = fExperiment.getNext(context); |
d18dd09b | 518 | assertEquals("Event timestamp", 4501, event.getTimestamp().getValue()); |
25e48683 | 519 | |
c32744d6 | 520 | event = fExperiment.getNext(context); |
0316808c | 521 | assertEquals("Event timestamp", 4502, event.getTimestamp().getValue()); |
d18dd09b ASL |
522 | } |
523 | ||
0316808c | 524 | public void testSeekLocationOutOfScope() throws Exception { |
d18dd09b | 525 | |
25e48683 | 526 | // Position trace at beginning |
0316808c | 527 | ITmfContext context = fExperiment.seekEvent((ITmfLocation<?>) null); |
25e48683 | 528 | |
c32744d6 | 529 | ITmfEvent event = fExperiment.getNext(context); |
d18dd09b | 530 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
d18dd09b | 531 | } |
25e48683 | 532 | |
9b635e61 | 533 | // ------------------------------------------------------------------------ |
1744ff0e | 534 | // getNext - updates the context |
9b635e61 FC |
535 | // ------------------------------------------------------------------------ |
536 | ||
1744ff0e | 537 | public void testGetNext() throws Exception { |
9b635e61 | 538 | |
25e48683 | 539 | // On lower bound, returns the first event (ts = 0) |
0316808c | 540 | final ITmfContext context = fExperiment.seekEvent(0); |
c32744d6 | 541 | ITmfEvent event = fExperiment.getNext(context); |
9b635e61 FC |
542 | assertEquals("Event timestamp", 1, event.getTimestamp().getValue()); |
543 | ||
544 | for (int i = 2; i < 20; i++) { | |
c32744d6 | 545 | event = fExperiment.getNext(context); |
9b635e61 FC |
546 | assertEquals("Event timestamp", i, event.getTimestamp().getValue()); |
547 | } | |
548 | } | |
549 | ||
1744ff0e PT |
550 | public void testGetNextLocation() throws Exception { |
551 | ||
552 | ITmfContext context1 = fExperiment.seekEvent(0); | |
553 | fExperiment.getNext(context1); | |
554 | ITmfLocation<?> location = context1.getLocation().clone(); | |
555 | ITmfEvent event1 = fExperiment.getNext(context1); | |
556 | ITmfContext context2 = fExperiment.seekEvent(location); | |
557 | ITmfEvent event2 = fExperiment.getNext(context2); | |
558 | assertEquals("Event timestamp", event1.getTimestamp().getValue(), event2.getTimestamp().getValue()); | |
559 | } | |
560 | ||
561 | public void testGetNextEndLocation() throws Exception { | |
562 | ITmfContext context1 = fExperiment.seekEvent(fExperiment.getNbEvents() - 1); | |
563 | fExperiment.getNext(context1); | |
564 | ITmfLocation<?> location = context1.getLocation().clone(); | |
565 | ITmfContext context2 = fExperiment.seekEvent(location); | |
566 | ITmfEvent event = fExperiment.getNext(context2); | |
567 | assertNull("Event", event); | |
568 | } | |
569 | ||
d18dd09b ASL |
570 | // ------------------------------------------------------------------------ |
571 | // processRequest | |
572 | // ------------------------------------------------------------------------ | |
573 | ||
574 | public void testProcessRequestForNbEvents() throws Exception { | |
cb866e08 | 575 | |
25e48683 | 576 | final int blockSize = 100; |
d18dd09b ASL |
577 | final int nbEvents = 1000; |
578 | final Vector<TmfEvent> requestedEvents = new Vector<TmfEvent>(); | |
579 | ||
25e48683 | 580 | final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH); |
d18dd09b ASL |
581 | final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, nbEvents, blockSize) { |
582 | @Override | |
25e48683 FC |
583 | public void handleData(final TmfEvent event) { |
584 | super.handleData(event); | |
f9673903 | 585 | requestedEvents.add(event); |
d18dd09b ASL |
586 | } |
587 | }; | |
588 | fExperiment.sendRequest(request); | |
589 | request.waitForCompletion(); | |
590 | ||
591 | assertEquals("nbEvents", nbEvents, requestedEvents.size()); | |
592 | assertTrue("isCompleted", request.isCompleted()); | |
593 | assertFalse("isCancelled", request.isCancelled()); | |
594 | ||
595 | // Ensure that we have distinct events. | |
25e48683 | 596 | // Don't go overboard: we are not validating the stub! |
20658947 | 597 | for (int i = 0; i < nbEvents; i++) { |
d18dd09b | 598 | assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue()); |
20658947 | 599 | } |
d18dd09b | 600 | } |
25e48683 | 601 | |
d18dd09b | 602 | public void testProcessRequestForNbEvents2() throws Exception { |
cb866e08 | 603 | |
25e48683 | 604 | final int blockSize = 2 * NB_EVENTS; |
d18dd09b ASL |
605 | final int nbEvents = 1000; |
606 | final Vector<TmfEvent> requestedEvents = new Vector<TmfEvent>(); | |
607 | ||
25e48683 | 608 | final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH); |
d18dd09b | 609 | final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, nbEvents, blockSize) { |
25e48683 FC |
610 | @Override |
611 | public void handleData(final TmfEvent event) { | |
612 | super.handleData(event); | |
613 | requestedEvents.add(event); | |
614 | } | |
d18dd09b ASL |
615 | }; |
616 | fExperiment.sendRequest(request); | |
617 | request.waitForCompletion(); | |
618 | ||
619 | assertEquals("nbEvents", nbEvents, requestedEvents.size()); | |
620 | assertTrue("isCompleted", request.isCompleted()); | |
621 | assertFalse("isCancelled", request.isCancelled()); | |
622 | ||
623 | // Ensure that we have distinct events. | |
25e48683 | 624 | // Don't go overboard: we are not validating the stub! |
20658947 | 625 | for (int i = 0; i < nbEvents; i++) { |
d18dd09b | 626 | assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue()); |
20658947 | 627 | } |
d18dd09b | 628 | } |
25e48683 | 629 | |
d18dd09b | 630 | public void testProcessRequestForAllEvents() throws Exception { |
cb866e08 | 631 | |
25e48683 | 632 | final int nbEvents = TmfEventRequest.ALL_DATA; |
d18dd09b ASL |
633 | final int blockSize = 1; |
634 | final Vector<TmfEvent> requestedEvents = new Vector<TmfEvent>(); | |
25e48683 | 635 | final long nbExpectedEvents = NB_EVENTS; |
d18dd09b | 636 | |
25e48683 | 637 | final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH); |
d18dd09b | 638 | final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, nbEvents, blockSize) { |
25e48683 FC |
639 | @Override |
640 | public void handleData(final TmfEvent event) { | |
641 | super.handleData(event); | |
642 | requestedEvents.add(event); | |
643 | } | |
d18dd09b ASL |
644 | }; |
645 | fExperiment.sendRequest(request); | |
646 | request.waitForCompletion(); | |
647 | ||
648 | assertEquals("nbEvents", nbExpectedEvents, requestedEvents.size()); | |
649 | assertTrue("isCompleted", request.isCompleted()); | |
650 | assertFalse("isCancelled", request.isCancelled()); | |
651 | ||
652 | // Ensure that we have distinct events. | |
25e48683 | 653 | // Don't go overboard: we are not validating the stub! |
20658947 | 654 | for (int i = 0; i < nbExpectedEvents; i++) { |
d18dd09b | 655 | assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue()); |
20658947 | 656 | } |
d18dd09b | 657 | } |
25e48683 | 658 | |
d18dd09b ASL |
659 | // ------------------------------------------------------------------------ |
660 | // cancel | |
661 | // ------------------------------------------------------------------------ | |
662 | ||
663 | public void testCancel() throws Exception { | |
cb866e08 | 664 | |
25e48683 | 665 | final int nbEvents = NB_EVENTS; |
0316808c | 666 | final int blockSize = BLOCK_SIZE; |
d18dd09b ASL |
667 | final Vector<TmfEvent> requestedEvents = new Vector<TmfEvent>(); |
668 | ||
25e48683 | 669 | final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH); |
d18dd09b | 670 | final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, nbEvents, blockSize) { |
25e48683 FC |
671 | int nbRead = 0; |
672 | @Override | |
673 | public void handleData(final TmfEvent event) { | |
674 | super.handleData(event); | |
675 | requestedEvents.add(event); | |
20658947 | 676 | if (++nbRead == blockSize) { |
25e48683 | 677 | cancel(); |
20658947 | 678 | } |
25e48683 | 679 | } |
cb866e08 FC |
680 | @Override |
681 | public void handleCancel() { | |
20658947 | 682 | if (requestedEvents.size() < blockSize) { |
25e48683 | 683 | System.out.println("aie"); |
20658947 | 684 | } |
cb866e08 | 685 | } |
d18dd09b ASL |
686 | }; |
687 | fExperiment.sendRequest(request); | |
688 | request.waitForCompletion(); | |
689 | ||
690 | assertEquals("nbEvents", blockSize, requestedEvents.size()); | |
691 | assertTrue("isCompleted", request.isCompleted()); | |
692 | assertTrue("isCancelled", request.isCancelled()); | |
693 | } | |
25e48683 | 694 | |
9a7f542f | 695 | } |