projects / deliverable / tracecompass.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
Use o.e.test and jdt.annotation from Eclipse 4.5
[deliverable/tracecompass.git] / tmf / org.eclipse.tracecompass.tmf.core.tests / src / org / eclipse / tracecompass / tmf / core / tests / trace / TmfMultiTraceExperimentTest.java
CommitLineData
d18dd09b 1/*******************************************************************************
ed902a2b 2 * Copyright (c) 2009, 2014 Ericsson
9b749023 3 *
d18dd09b
ASL		 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
9b749023 8 *
d18dd09b
ASL		 9 * Contributors:
10 * Francois Chouinard - Initial API and implementation
0316808c 11 * Francois Chouinard - Adjusted for new Trace Model
6e1886bc 12 * Alexandre Montplaisir - Port to JUnit4
850a3ae2 13 * Patrick Tasse - Fix for concurrency
d18dd09b
ASL		 14 *******************************************************************************/
15
2bdf0193 16package org.eclipse.tracecompass.tmf.core.tests.trace;
d18dd09b 17
6e1886bc
AM		 18import static org.junit.Assert.assertEquals;
19import static org.junit.Assert.assertFalse;
07ef7847 20import static org.junit.Assert.assertNotNull;
6e1886bc
AM		 21import static org.junit.Assert.assertNull;
22import static org.junit.Assert.assertTrue;
23
d18dd09b
ASL		 24import java.io.File;
25import java.io.IOException;
26import java.net.URISyntaxException;
27import java.net.URL;
28import java.util.Vector;
29
d18dd09b
ASL		 30import org.eclipse.core.runtime.FileLocator;
31import org.eclipse.core.runtime.Path;
5c5fa260 32import org.eclipse.tracecompass.internal.tmf.core.trace.experiment.TmfExperimentContext;
2bdf0193
AM		 33import org.eclipse.tracecompass.tmf.core.event.ITmfEvent;
34import org.eclipse.tracecompass.tmf.core.exceptions.TmfTraceException;
35import org.eclipse.tracecompass.tmf.core.request.ITmfEventRequest;
36import org.eclipse.tracecompass.tmf.core.request.TmfEventRequest;
37import org.eclipse.tracecompass.tmf.core.request.ITmfEventRequest.ExecutionType;
38import org.eclipse.tracecompass.tmf.core.tests.TmfCoreTestPlugin;
39import org.eclipse.tracecompass.tmf.core.tests.shared.TmfTestTrace;
40import org.eclipse.tracecompass.tmf.core.timestamp.ITmfTimestamp;
41import org.eclipse.tracecompass.tmf.core.timestamp.TmfTimeRange;
42import org.eclipse.tracecompass.tmf.core.timestamp.TmfTimestamp;
43import org.eclipse.tracecompass.tmf.core.trace.ITmfContext;
44import org.eclipse.tracecompass.tmf.core.trace.ITmfTrace;
45import org.eclipse.tracecompass.tmf.core.trace.location.ITmfLocation;
46import org.eclipse.tracecompass.tmf.tests.stubs.trace.TmfExperimentStub;
47import org.eclipse.tracecompass.tmf.tests.stubs.trace.TmfTraceStub;
850a3ae2
PT		 48import org.junit.AfterClass;
49import org.junit.BeforeClass;
6e1886bc 50import org.junit.Test;
d18dd09b
ASL		 51
52/**
0316808c 53 * Test suite for the TmfExperiment class (multiple traces).
d18dd09b 54 */
cad06250 55@SuppressWarnings("javadoc")
6e1886bc 56public class TmfMultiTraceExperimentTest {
d18dd09b 57
0316808c
FC		 58 // ------------------------------------------------------------------------
59 // Attributes
60 // ------------------------------------------------------------------------
6e1886bc 61
66262ad8 62 private static final long DEFAULT_INITIAL_OFFSET_VALUE = (1L * 100 * 1000 * 1000); // .1sec
d18dd09b
ASL		 63 private static final String EXPERIMENT = "MyExperiment";
64 private static int NB_EVENTS = 20000;
9b635e61 65 private static int BLOCK_SIZE = 1000;
d18dd09b 66
6256d8ad 67 private static TmfExperimentStub fExperiment;
d18dd09b
ASL		 68
69 private static byte SCALE = (byte) -3;
70
71 // ------------------------------------------------------------------------
72 // Housekeeping
73 // ------------------------------------------------------------------------
74
850a3ae2
PT		 75 @BeforeClass
76 public static void setUp() {
77 ITmfTrace[] traces = setupTraces();
78 fExperiment = new TmfExperimentStub(EXPERIMENT, traces, BLOCK_SIZE);
79 fExperiment.getIndexer().buildIndex(0, TmfTimeRange.ETERNITY, true);
6e1886bc
AM		 80 }
81
850a3ae2
PT		 82 @AfterClass
83 public static void tearDown() {
84 fExperiment.dispose();
85 }
86
87 private static ITmfTrace[] setupTraces() {
850a3ae2
PT		 88 try {
89 ITmfTrace[] traces = new ITmfTrace[2];
90
9c4d52ee 91 URL location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(TmfTestTrace.O_TEST_10K.getFullPath()), null);
850a3ae2 92 File test = new File(FileLocator.toFileURL(location).toURI());
ab186fbb 93 final TmfTraceStub trace1 = new TmfTraceStub(test.getPath(), 0, true, null);
850a3ae2
PT		 94 traces[0] = trace1;
95
9c4d52ee 96 location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(TmfTestTrace.E_TEST_10K.getFullPath()), null);
850a3ae2 97 test = new File(FileLocator.toFileURL(location).toURI());
ab186fbb 98 final TmfTraceStub trace2 = new TmfTraceStub(test.getPath(), 0, true, null);
850a3ae2
PT		 99 traces[1] = trace2;
100
101 return traces;
102 } catch (final TmfTraceException e) {
103 e.printStackTrace();
104 } catch (final URISyntaxException e) {
105 e.printStackTrace();
106 } catch (final IOException e) {
107 e.printStackTrace();
25e48683 108 }
850a3ae2 109 return new ITmfTrace[0];
d18dd09b
ASL		 110 }
111
d18dd09b
ASL		 112 // ------------------------------------------------------------------------
113 // Constructor
114 // ------------------------------------------------------------------------
115
6e1886bc 116 @Test
25e48683 117 public void testBasicTmfExperimentConstructor() {
25e48683 118 assertEquals("GetId", EXPERIMENT, fExperiment.getName());
d18dd09b
ASL		 119 assertEquals("GetNbEvents", NB_EVENTS, fExperiment.getNbEvents());
120
25e48683 121 final TmfTimeRange timeRange = fExperiment.getTimeRange();
d18dd09b
ASL		 122 assertEquals("getStartTime", 1, timeRange.getStartTime().getValue());
123 assertEquals("getEndTime", NB_EVENTS, timeRange.getEndTime().getValue());
66262ad8 124
850a3ae2 125 TmfTimestamp initRange = new TmfTimestamp(DEFAULT_INITIAL_OFFSET_VALUE, ITmfTimestamp.NANOSECOND_SCALE);
66262ad8 126 assertEquals("getInitialRangeOffset", initRange, fExperiment.getInitialRangeOffset());
25e48683 127 }
d18dd09b 128
d18dd09b 129 // ------------------------------------------------------------------------
0316808c 130 // seekEvent on rank
d18dd09b
ASL		 131 // ------------------------------------------------------------------------
132
6e1886bc 133 @Test
54a7a54c 134 public void testSeekRankOnCacheBoundary() {
0316808c 135 long cacheSize = fExperiment.getCacheSize();
9b635e61 136
0316808c
FC		 137 // On lower bound, returns the first event (TS = 1)
138 ITmfContext context = fExperiment.seekEvent(0);
139 assertEquals("Context rank", 0, context.getRank());
25e48683 140
c32744d6 141 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 142 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 143 assertEquals("Context rank", 1, context.getRank());
25e48683 144
0316808c
FC		 145 // Position trace at event rank [cacheSize]
146 context = fExperiment.seekEvent(cacheSize);
147 assertEquals("Context rank", cacheSize, context.getRank());
25e48683 148
c32744d6 149 event = fExperiment.getNext(context);
0316808c
FC		 150 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
151 assertEquals("Context rank", cacheSize + 1, context.getRank());
d18dd09b 152
0316808c
FC		 153 // Position trace at event rank [4 * cacheSize]
154 context = fExperiment.seekEvent(4 * cacheSize);
155 assertEquals("Context rank", 4 * cacheSize, context.getRank());
25e48683 156
c32744d6 157 event = fExperiment.getNext(context);
0316808c
FC		 158 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
159 assertEquals("Context rank", 4 * cacheSize + 1, context.getRank());
d18dd09b
ASL		 160 }
161
6e1886bc 162 @Test
54a7a54c 163 public void testSeekRankNotOnCacheBoundary() {
0316808c 164 long cacheSize = fExperiment.getCacheSize();
25e48683 165
0316808c
FC		 166 // Position trace at event rank 9
167 ITmfContext context = fExperiment.seekEvent(9);
168 assertEquals("Context rank", 9, context.getRank());
25e48683 169
c32744d6 170 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 171 assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
0316808c 172 assertEquals("Context rank", 10, context.getRank());
d18dd09b 173
0316808c
FC		 174 // Position trace at event rank [cacheSize - 1]
175 context = fExperiment.seekEvent(cacheSize - 1);
176 assertEquals("Context rank", cacheSize - 1, context.getRank());
25e48683 177
c32744d6 178 event = fExperiment.getNext(context);
0316808c
FC		 179 assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue());
180 assertEquals("Context rank", cacheSize, context.getRank());
d18dd09b 181
0316808c
FC		 182 // Position trace at event rank [cacheSize + 1]
183 context = fExperiment.seekEvent(cacheSize + 1);
184 assertEquals("Context rank", cacheSize + 1, context.getRank());
25e48683 185
c32744d6 186 event = fExperiment.getNext(context);
0316808c
FC		 187 assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue());
188 assertEquals("Context rank", cacheSize + 2, context.getRank());
d18dd09b 189
25e48683 190 // Position trace at event rank 4500
0316808c
FC		 191 context = fExperiment.seekEvent(4500);
192 assertEquals("Context rank", 4500, context.getRank());
25e48683 193
c32744d6 194 event = fExperiment.getNext(context);
d18dd09b 195 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
0316808c 196 assertEquals("Context rank", 4501, context.getRank());
d18dd09b
ASL		 197 }
198
6e1886bc 199 @Test
54a7a54c 200 public void testSeekRankOutOfScope() {
25e48683 201 // Position trace at beginning
0316808c 202 ITmfContext context = fExperiment.seekEvent(-1);
d18dd09b 203 assertEquals("Event rank", 0, context.getRank());
25e48683 204
c32744d6 205 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 206 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 207 assertEquals("Context rank", 1, context.getRank());
d18dd09b 208
25e48683 209 // Position trace at event passed the end
0316808c
FC		 210 context = fExperiment.seekEvent(NB_EVENTS);
211 assertEquals("Context rank", NB_EVENTS, context.getRank());
212
c32744d6 213 event = fExperiment.getNext(context);
0316808c
FC		 214 assertNull("Event", event);
215 assertEquals("Context rank", NB_EVENTS, context.getRank());
d18dd09b
ASL		 216 }
217
25e48683
FC		 218 // ------------------------------------------------------------------------
219 // seekEvent on timestamp
220 // ------------------------------------------------------------------------
221
6e1886bc 222 @Test
54a7a54c 223 public void testSeekTimestampOnCacheBoundary() {
0316808c 224 long cacheSize = fExperiment.getCacheSize();
25e48683 225
0316808c 226 // Position trace at event rank 0
065cc19b 227 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(1, SCALE));
0316808c 228 assertEquals("Context rank", 0, context.getRank());
25e48683 229
c32744d6 230 ITmfEvent event = fExperiment.getNext(context);
25e48683 231 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 232 assertEquals("Context rank", 1, context.getRank());
25e48683 233
0316808c 234 // Position trace at event rank [cacheSize]
065cc19b 235 context = fExperiment.seekEvent(new TmfTimestamp(cacheSize + 1, SCALE));
0316808c 236 assertEquals("Event rank", cacheSize, context.getRank());
25e48683 237
c32744d6 238 event = fExperiment.getNext(context);
0316808c
FC		 239 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
240 assertEquals("Context rank", cacheSize + 1, context.getRank());
25e48683 241
0316808c 242 // Position trace at event rank [4 * cacheSize]
065cc19b 243 context = fExperiment.seekEvent(new TmfTimestamp(4 * cacheSize + 1, SCALE));
0316808c 244 assertEquals("Context rank", 4 * cacheSize, context.getRank());
25e48683 245
c32744d6 246 event = fExperiment.getNext(context);
0316808c
FC		 247 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
248 assertEquals("Context rank", 4 * cacheSize + 1, context.getRank());
25e48683
FC		 249 }
250
6e1886bc 251 @Test
54a7a54c 252 public void testSeekTimestampNotOnCacheBoundary() {
0316808c 253 // Position trace at event rank 1 (TS = 2)
065cc19b 254 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(2, SCALE));
0316808c 255 assertEquals("Context rank", 1, context.getRank());
25e48683 256
c32744d6 257 ITmfEvent event = fExperiment.getNext(context);
25e48683 258 assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
0316808c 259 assertEquals("Context rank", 2, context.getRank());
25e48683 260
0316808c 261 // Position trace at event rank 9 (TS = 10)
065cc19b 262 context = fExperiment.seekEvent(new TmfTimestamp(10, SCALE));
0316808c 263 assertEquals("Context rank", 9, context.getRank());
25e48683 264
c32744d6 265 event = fExperiment.getNext(context);
25e48683 266 assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
0316808c 267 assertEquals("Context rank", 10, context.getRank());
25e48683 268
0316808c 269 // Position trace at event rank 999 (TS = 1000)
065cc19b 270 context = fExperiment.seekEvent(new TmfTimestamp(1000, SCALE));
0316808c 271 assertEquals("Context rank", 999, context.getRank());
25e48683 272
c32744d6 273 event = fExperiment.getNext(context);
25e48683 274 assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
0316808c 275 assertEquals("Context rank", 1000, context.getRank());
25e48683 276
0316808c 277 // Position trace at event rank 1001 (TS = 1002)
065cc19b 278 context = fExperiment.seekEvent(new TmfTimestamp(1002, SCALE));
0316808c 279 assertEquals("Context rank", 1001, context.getRank());
25e48683 280
c32744d6 281 event = fExperiment.getNext(context);
25e48683 282 assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
0316808c 283 assertEquals("Context rank", 1002, context.getRank());
25e48683 284
0316808c 285 // Position trace at event rank 4500 (TS = 4501)
065cc19b 286 context = fExperiment.seekEvent(new TmfTimestamp(4501, SCALE));
0316808c 287 assertEquals("Context rank", 4500, context.getRank());
25e48683 288
c32744d6 289 event = fExperiment.getNext(context);
25e48683 290 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
0316808c 291 assertEquals("Context rank", 4501, context.getRank());
25e48683
FC		 292 }
293
6e1886bc 294 @Test
54a7a54c 295 public void testSeekTimestampOutOfScope() {
25e48683 296 // Position trace at beginning
065cc19b 297 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(-1, SCALE));
25e48683
FC		 298 assertEquals("Event rank", 0, context.getRank());
299
c32744d6 300 ITmfEvent event = fExperiment.getNext(context);
25e48683
FC		 301 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
302 assertEquals("Event rank", 1, context.getRank());
303
304 // Position trace at event passed the end
065cc19b 305 context = fExperiment.seekEvent(new TmfTimestamp(NB_EVENTS + 1, SCALE));
c32744d6 306 event = fExperiment.getNext(context);
0316808c 307 assertNull("Event location", event);
9b635e61 308 assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
25e48683
FC		 309 }
310
311 // ------------------------------------------------------------------------
0316808c 312 // seekEvent by location (context rank is undefined)
25e48683
FC		 313 // ------------------------------------------------------------------------
314
6e1886bc 315 @Test
54a7a54c 316 public void testSeekLocationOnCacheBoundary() {
0316808c 317 long cacheSize = fExperiment.getCacheSize();
25e48683 318
0316808c
FC		 319 // Position trace at event rank 0
320 ITmfContext tmpContext = fExperiment.seekEvent(0);
321 ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 322
c32744d6 323 ITmfEvent event = fExperiment.getNext(context);
25e48683 324 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
25e48683 325
c32744d6 326 event = fExperiment.getNext(context);
0316808c 327 assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
25e48683 328
0316808c
FC		 329 // Position trace at event rank 'cacheSize'
330 tmpContext = fExperiment.seekEvent(cacheSize);
331 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 332
c32744d6 333 event = fExperiment.getNext(context);
0316808c 334 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
25e48683 335
c32744d6 336 event = fExperiment.getNext(context);
0316808c 337 assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue());
25e48683 338
0316808c
FC		 339 // Position trace at event rank 4 * 'cacheSize'
340 tmpContext = fExperiment.seekEvent(4 * cacheSize);
341 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 342
c32744d6 343 event = fExperiment.getNext(context);
0316808c 344 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
25e48683 345
c32744d6 346 event = fExperiment.getNext(context);
0316808c 347 assertEquals("Event timestamp", 4 * cacheSize + 2, event.getTimestamp().getValue());
25e48683
FC		 348 }
349
6e1886bc 350 @Test
54a7a54c 351 public void testSeekLocationNotOnCacheBoundary() {
0316808c 352 long cacheSize = fExperiment.getCacheSize();
25e48683 353
0316808c
FC		 354 // Position trace at event 'cacheSize' - 1
355 ITmfContext tmpContext = fExperiment.seekEvent(cacheSize - 1);
356 ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 357
c32744d6 358 ITmfEvent event = fExperiment.getNext(context);
0316808c 359 assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue());
25e48683 360
c32744d6 361 event = fExperiment.getNext(context);
0316808c 362 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
25e48683 363
0316808c
FC		 364 // Position trace at event rank 2 * 'cacheSize' - 1
365 tmpContext = fExperiment.seekEvent(2 * cacheSize - 1);
366 context = fExperiment.seekEvent(tmpContext.getLocation());
367 context = fExperiment.seekEvent(2 * cacheSize - 1);
25e48683 368
c32744d6 369 event = fExperiment.getNext(context);
0316808c 370 assertEquals("Event timestamp", 2 * cacheSize, event.getTimestamp().getValue());
25e48683 371
c32744d6 372 event = fExperiment.getNext(context);
0316808c 373 assertEquals("Event timestamp", 2 * cacheSize + 1, event.getTimestamp().getValue());
25e48683
FC		 374
375 // Position trace at event rank 4500
0316808c
FC		 376 tmpContext = fExperiment.seekEvent(4500);
377 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 378
c32744d6 379 event = fExperiment.getNext(context);
25e48683 380 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
25e48683 381
c32744d6 382 event = fExperiment.getNext(context);
0316808c 383 assertEquals("Event timestamp", 4502, event.getTimestamp().getValue());
25e48683
FC		 384 }
385
6e1886bc 386 @Test
54a7a54c 387 public void testSeekLocationOutOfScope() {
25e48683 388 // Position trace at beginning
1e1bef82 389 ITmfContext context = fExperiment.seekEvent((ITmfLocation) null);
25e48683 390
c32744d6 391 ITmfEvent event = fExperiment.getNext(context);
25e48683 392 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
25e48683 393 }
d18dd09b 394
9b635e61 395 // ------------------------------------------------------------------------
17324c9a 396 // getNext - updates the context
9b635e61 397 // ------------------------------------------------------------------------
d18dd09b 398
54a7a54c 399 private static void validateContextRanks(ITmfContext context) {
17324c9a
FC		 400 assertTrue("Experiment context type", context instanceof TmfExperimentContext);
401 TmfExperimentContext ctx = (TmfExperimentContext) context;
9b635e61 402
07ef7847 403 int nbTraces = ctx.getNbTraces();
17324c9a
FC		 404
405 // expRank = sum(trace ranks) - nbTraces + 1 (if lastTraceRead != NO_TRACE)
406 long expRank = -nbTraces + ((ctx.getLastTrace() != TmfExperimentContext.NO_TRACE) ? 1 : 0);
407 for (int i = 0; i < nbTraces; i++) {
07ef7847
AM		 408 ITmfContext subContext = ctx.getContext(i);
409 assertNotNull(subContext);
410 long rank = subContext.getRank();
17324c9a
FC		 411 if (rank == -1) {
412 expRank = -1;
413 break;
414 }
415 expRank += rank;
416 }
417 assertEquals("Experiment context rank", expRank, ctx.getRank());
418 }
419
6e1886bc 420 @Test
54a7a54c 421 public void testGetNextAfteSeekingOnTS_1() {
17324c9a
FC		 422 final long INITIAL_TS = 1;
423 final int NB_READS = 20;
424
425 // On lower bound, returns the first event (ts = 1)
065cc19b 426 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE));
17324c9a
FC		 427
428 validateContextRanks(context);
429
430 // Read NB_EVENTS
431 ITmfEvent event;
432 for (int i = 0; i < NB_READS; i++) {
433 event = fExperiment.getNext(context);
434 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
435 assertEquals("Event rank", INITIAL_TS + i, context.getRank());
436 }
437
438 // Make sure we stay positioned
439 event = fExperiment.parseEvent(context);
440 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
441 assertEquals("Event rank", INITIAL_TS + NB_READS - 1, context.getRank());
442
443 validateContextRanks(context);
444 }
445
6e1886bc 446 @Test
54a7a54c 447 public void testGetNextAfteSeekingOnTS_2() {
17324c9a
FC		 448 final long INITIAL_TS = 2;
449 final int NB_READS = 20;
450
451 // On lower bound, returns the first event (ts = 2)
065cc19b 452 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE));
17324c9a
FC		 453
454 validateContextRanks(context);
455
456 // Read NB_EVENTS
457 ITmfEvent event;
458 for (int i = 0; i < NB_READS; i++) {
459 event = fExperiment.getNext(context);
460 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
461 assertEquals("Event rank", INITIAL_TS + i, context.getRank());
462 }
463
464 // Make sure we stay positioned
465 event = fExperiment.parseEvent(context);
466 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
467 assertEquals("Event rank", INITIAL_TS + NB_READS - 1, context.getRank());
468
469 validateContextRanks(context);
470 }
471
6e1886bc 472 @Test
54a7a54c 473 public void testGetNextAfteSeekingOnTS_3() {
17324c9a
FC		 474 final long INITIAL_TS = 500;
475 final int NB_READS = 20;
476
477 // On lower bound, returns the first event (ts = 500)
065cc19b 478 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE));
17324c9a
FC		 479
480 validateContextRanks(context);
481
482 // Read NB_EVENTS
483 ITmfEvent event;
484 for (int i = 0; i < NB_READS; i++) {
485 event = fExperiment.getNext(context);
486 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
487 assertEquals("Event rank", INITIAL_TS + i, context.getRank());
488 }
489
490 // Make sure we stay positioned
491 event = fExperiment.parseEvent(context);
492 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
493 assertEquals("Event rank", INITIAL_TS + NB_READS - 1, context.getRank());
494
495 validateContextRanks(context);
496 }
497
6e1886bc 498 @Test
54a7a54c 499 public void testGetNextAfterSeekingOnRank_1() {
17324c9a
FC		 500 final long INITIAL_RANK = 0L;
501 final int NB_READS = 20;
502
503 // On lower bound, returns the first event (rank = 0)
504 final ITmfContext context = fExperiment.seekEvent(INITIAL_RANK);
505
506 validateContextRanks(context);
507
508 // Read NB_EVENTS
509 ITmfEvent event;
510 for (int i = 0; i < NB_READS; i++) {
511 event = fExperiment.getNext(context);
512 assertEquals("Event timestamp", INITIAL_RANK + i + 1, event.getTimestamp().getValue());
513 assertEquals("Event rank", INITIAL_RANK + i + 1, context.getRank());
514 }
515
516 // Make sure we stay positioned
517 event = fExperiment.parseEvent(context);
518 assertEquals("Event timestamp", INITIAL_RANK + NB_READS + 1, event.getTimestamp().getValue());
519 assertEquals("Event rank", INITIAL_RANK + NB_READS, context.getRank());
520
521 validateContextRanks(context);
522 }
523
6e1886bc 524 @Test
54a7a54c 525 public void testGetNextAfterSeekingOnRank_2() {
17324c9a
FC		 526 final long INITIAL_RANK = 1L;
527 final int NB_READS = 20;
528
529 // On lower bound, returns the first event (rank = 0)
530 final ITmfContext context = fExperiment.seekEvent(INITIAL_RANK);
d18dd09b 531
17324c9a
FC		 532 validateContextRanks(context);
533
534 // Read NB_EVENTS
535 ITmfEvent event;
536 for (int i = 0; i < NB_READS; i++) {
c32744d6 537 event = fExperiment.getNext(context);
17324c9a
FC		 538 assertEquals("Event timestamp", INITIAL_RANK + i + 1, event.getTimestamp().getValue());
539 assertEquals("Event rank", INITIAL_RANK + i + 1, context.getRank());
9b635e61 540 }
17324c9a
FC		 541
542 // Make sure we stay positioned
543 event = fExperiment.parseEvent(context);
544 assertEquals("Event timestamp", INITIAL_RANK + NB_READS + 1, event.getTimestamp().getValue());
545 assertEquals("Event rank", INITIAL_RANK + NB_READS, context.getRank());
546
547 validateContextRanks(context);
548 }
549
6e1886bc 550 @Test
54a7a54c 551 public void testGetNextAfterSeekingOnRank_3() {
17324c9a
FC		 552 final long INITIAL_RANK = 500L;
553 final int NB_READS = 20;
554
555 // On lower bound, returns the first event (rank = 0)
556 final ITmfContext context = fExperiment.seekEvent(INITIAL_RANK);
557
558 validateContextRanks(context);
559
560 // Read NB_EVENTS
561 ITmfEvent event;
562 for (int i = 0; i < NB_READS; i++) {
563 event = fExperiment.getNext(context);
564 assertEquals("Event timestamp", INITIAL_RANK + i + 1, event.getTimestamp().getValue());
565 assertEquals("Event rank", INITIAL_RANK + i + 1, context.getRank());
566 }
567
568 // Make sure we stay positioned
569 event = fExperiment.parseEvent(context);
570 assertEquals("Event timestamp", INITIAL_RANK + NB_READS + 1, event.getTimestamp().getValue());
571 assertEquals("Event rank", INITIAL_RANK + NB_READS, context.getRank());
572
573 validateContextRanks(context);
574 }
575
6e1886bc 576 @Test
54a7a54c 577 public void testGetNextAfterSeekingOnLocation_1() {
1e1bef82 578 final ITmfLocation INITIAL_LOC = null;
17324c9a
FC		 579 final long INITIAL_TS = 1;
580 final int NB_READS = 20;
581
582 // On lower bound, returns the first event (ts = 1)
583 final ITmfContext context = fExperiment.seekEvent(INITIAL_LOC);
584
585 validateContextRanks(context);
586
587 // Read NB_EVENTS
588 ITmfEvent event;
589 for (int i = 0; i < NB_READS; i++) {
590 event = fExperiment.getNext(context);
591 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
592 assertEquals("Event rank", INITIAL_TS + i, context.getRank());
593 }
594
595 // Make sure we stay positioned
596 event = fExperiment.parseEvent(context);
597 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
598 assertEquals("Event rank", INITIAL_TS + NB_READS - 1, context.getRank());
599
600 validateContextRanks(context);
601 }
602
6e1886bc 603 @Test
54a7a54c 604 public void testGetNextAfterSeekingOnLocation_2() {
1e1bef82 605 final ITmfLocation INITIAL_LOC = fExperiment.seekEvent(1L).getLocation();
17324c9a
FC		 606 final long INITIAL_TS = 2;
607 final int NB_READS = 20;
608
609 // On lower bound, returns the first event (ts = 2)
610 final ITmfContext context = fExperiment.seekEvent(INITIAL_LOC);
611
612 validateContextRanks(context);
613
614 // Read NB_EVENTS
615 ITmfEvent event;
616 for (int i = 0; i < NB_READS; i++) {
617 event = fExperiment.getNext(context);
618 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
619 }
620
621 // Make sure we stay positioned
622 event = fExperiment.parseEvent(context);
623 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
624
625 validateContextRanks(context);
626 }
627
6e1886bc 628 @Test
54a7a54c 629 public void testGetNextAfterSeekingOnLocation_3() {
1e1bef82 630 final ITmfLocation INITIAL_LOC = fExperiment.seekEvent(500L).getLocation();
17324c9a
FC		 631 final long INITIAL_TS = 501;
632 final int NB_READS = 20;
633
634 // On lower bound, returns the first event (ts = 501)
635 final ITmfContext context = fExperiment.seekEvent(INITIAL_LOC);
636
637 validateContextRanks(context);
638
639 // Read NB_EVENTS
640 ITmfEvent event;
641 for (int i = 0; i < NB_READS; i++) {
642 event = fExperiment.getNext(context);
643 assertEquals("Event timestamp", INITIAL_TS + i, event.getTimestamp().getValue());
644 }
645
646 // Make sure we stay positioned
647 event = fExperiment.parseEvent(context);
648 assertEquals("Event timestamp", INITIAL_TS + NB_READS, event.getTimestamp().getValue());
649
650 validateContextRanks(context);
651 }
652
6e1886bc 653 @Test
54a7a54c 654 public void testGetNextLocation() {
17324c9a
FC		 655 ITmfContext context1 = fExperiment.seekEvent(0);
656 fExperiment.getNext(context1);
d62bb185 657 ITmfLocation location = context1.getLocation();
17324c9a
FC		 658 ITmfEvent event1 = fExperiment.getNext(context1);
659 ITmfContext context2 = fExperiment.seekEvent(location);
660 ITmfEvent event2 = fExperiment.getNext(context2);
661 assertEquals("Event timestamp", event1.getTimestamp().getValue(), event2.getTimestamp().getValue());
662 }
663
6e1886bc 664 @Test
54a7a54c 665 public void testGetNextEndLocation() {
17324c9a
FC		 666 ITmfContext context1 = fExperiment.seekEvent(fExperiment.getNbEvents() - 1);
667 fExperiment.getNext(context1);
d62bb185 668 ITmfLocation location = context1.getLocation();
17324c9a
FC		 669 ITmfContext context2 = fExperiment.seekEvent(location);
670 ITmfEvent event = fExperiment.getNext(context2);
671 assertNull("Event", event);
d18dd09b 672 }
9b635e61 673
d18dd09b
ASL		 674 // ------------------------------------------------------------------------
675 // processRequest
676 // ------------------------------------------------------------------------
677
6e1886bc 678 @Test
54a7a54c 679 public void testProcessRequestForNbEvents() throws InterruptedException {
d18dd09b 680 final int nbEvents = 1000;
ccf2bbb4 681 final Vector<ITmfEvent> requestedEvents = new Vector<>();
d18dd09b 682
25e48683 683 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
7184fc40 684 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class,
672a642a 685 range, 0, nbEvents, ExecutionType.FOREGROUND) {
25e48683 686 @Override
6256d8ad 687 public void handleData(final ITmfEvent event) {
25e48683
FC		 688 super.handleData(event);
689 requestedEvents.add(event);
690 }
d18dd09b
ASL		 691 };
692 fExperiment.sendRequest(request);
693 request.waitForCompletion();
694
695 assertEquals("nbEvents", nbEvents, requestedEvents.size());
696 assertTrue("isCompleted", request.isCompleted());
697 assertFalse("isCancelled", request.isCancelled());
698
699 // Ensure that we have distinct events.
25e48683 700 // Don't go overboard: we are not validating the stub!
20658947 701 for (int i = 0; i < nbEvents; i++) {
d18dd09b 702 assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue());
20658947 703 }
d18dd09b 704 }
25e48683 705
6e1886bc 706 @Test
54a7a54c 707 public void testProcessRequestForAllEvents() throws InterruptedException {
2740e05c 708 final int nbEvents = ITmfEventRequest.ALL_DATA;
ccf2bbb4 709 final Vector<ITmfEvent> requestedEvents = new Vector<>();
25e48683 710 final long nbExpectedEvents = NB_EVENTS;
d18dd09b 711
25e48683 712 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
7184fc40 713 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class,
672a642a 714 range, 0, nbEvents, ExecutionType.FOREGROUND) {
25e48683 715 @Override
6256d8ad 716 public void handleData(final ITmfEvent event) {
25e48683
FC		 717 super.handleData(event);
718 requestedEvents.add(event);
719 }
d18dd09b
ASL		 720 };
721 fExperiment.sendRequest(request);
722 request.waitForCompletion();
723
9b635e61 724 assertEquals("nbEvents", nbExpectedEvents, requestedEvents.size());
d18dd09b
ASL		 725 assertTrue("isCompleted", request.isCompleted());
726 assertFalse("isCancelled", request.isCancelled());
727
728 // Ensure that we have distinct events.
25e48683 729 // Don't go overboard: we are not validating the stub!
20658947 730 for (int i = 0; i < nbExpectedEvents; i++) {
d18dd09b 731 assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue());
20658947 732 }
d18dd09b 733 }
25e48683 734
d18dd09b
ASL		 735 // ------------------------------------------------------------------------
736 // cancel
737 // ------------------------------------------------------------------------
738
6e1886bc 739 @Test
54a7a54c 740 public void testCancel() throws InterruptedException {
25e48683 741 final int nbEvents = NB_EVENTS;
672a642a 742 final int limit = BLOCK_SIZE;
ccf2bbb4 743 final Vector<ITmfEvent> requestedEvents = new Vector<>();
d18dd09b 744
25e48683 745 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
7184fc40 746 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class,
672a642a 747 range, 0, nbEvents, ExecutionType.FOREGROUND) {
25e48683 748 int nbRead = 0;
672a642a 749
25e48683 750 @Override
6256d8ad 751 public void handleData(final ITmfEvent event) {
25e48683
FC		 752 super.handleData(event);
753 requestedEvents.add(event);
672a642a 754 if (++nbRead == limit) {
25e48683 755 cancel();
20658947 756 }
25e48683 757 }
d18dd09b
ASL		 758 };
759 fExperiment.sendRequest(request);
760 request.waitForCompletion();
761
672a642a 762 assertEquals("nbEvents", limit, requestedEvents.size());
d18dd09b
ASL		 763 assertTrue("isCompleted", request.isCompleted());
764 assertTrue("isCancelled", request.isCancelled());
765 }
25e48683 766
d18dd09b
ASL		 767 // ------------------------------------------------------------------------
768 // getTimestamp
769 // ------------------------------------------------------------------------
770
6e1886bc 771 @Test
54a7a54c 772 public void testGetTimestamp() {
17324c9a
FC		 773 assertEquals("getTimestamp", new TmfTimestamp( 1, (byte) -3), fExperiment.getTimestamp( 0));
774 assertEquals("getTimestamp", new TmfTimestamp( 2, (byte) -3), fExperiment.getTimestamp( 1));
775 assertEquals("getTimestamp", new TmfTimestamp( 11, (byte) -3), fExperiment.getTimestamp( 10));
776 assertEquals("getTimestamp", new TmfTimestamp( 101, (byte) -3), fExperiment.getTimestamp( 100));
777 assertEquals("getTimestamp", new TmfTimestamp( 1001, (byte) -3), fExperiment.getTimestamp( 1000));
778 assertEquals("getTimestamp", new TmfTimestamp( 2001, (byte) -3), fExperiment.getTimestamp( 2000));
779 assertEquals("getTimestamp", new TmfTimestamp( 2501, (byte) -3), fExperiment.getTimestamp( 2500));
780 assertEquals("getTimestamp", new TmfTimestamp(10000, (byte) -3), fExperiment.getTimestamp( 9999));
781 assertEquals("getTimestamp", new TmfTimestamp(20000, (byte) -3), fExperiment.getTimestamp(19999));
782 assertNull("getTimestamp", fExperiment.getTimestamp(20000));
d18dd09b
ASL		 783 }
784
66262ad8
BH		 785 // ------------------------------------------------------------------------
786 // getInitialRangeOffset, getCurrentRange, getCurrentTime
787 // ------------------------------------------------------------------------
2771b032 788
6e1886bc 789 @Test
66262ad8 790 public void testDefaultCurrentTimeValues() {
850a3ae2
PT		 791 ITmfTrace[] traces = setupTraces();
792 TmfExperimentStub exp = new TmfExperimentStub(EXPERIMENT, traces, BLOCK_SIZE);
66262ad8
BH		 793
794 // verify initial values
795 TmfTimestamp initRange = new TmfTimestamp(DEFAULT_INITIAL_OFFSET_VALUE, ITmfTimestamp.NANOSECOND_SCALE);
796 assertEquals("getInitialRangeOffset", initRange, exp.getInitialRangeOffset());
850a3ae2
PT		 797
798 exp.dispose();
799 }
800
801 @Test
802 public void testInitialRangeOffset() {
803 ITmfTrace[] traces = setupTraces();
804 ((TmfTraceStub) traces[0]).setInitialRangeOffset(new TmfTimestamp(5, ITmfTimestamp.MILLISECOND_SCALE));
805 ((TmfTraceStub) traces[1]).setInitialRangeOffset(new TmfTimestamp(2, ITmfTimestamp.MILLISECOND_SCALE));
806 TmfExperimentStub exp = new TmfExperimentStub(EXPERIMENT, traces, BLOCK_SIZE);
807
808 TmfTimestamp initRange = new TmfTimestamp(2, ITmfTimestamp.MILLISECOND_SCALE);
809 assertEquals("getInitialRangeOffset", initRange, exp.getInitialRangeOffset());
810
811 exp.dispose();
66262ad8 812 }
6e1886bc 813
17324c9a 814}
Tracecompass - Deliverables
This page took 0.13289 seconds and 5 git commands to generate.