projects / deliverable / tracecompass.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
tmf: Consolidate constructors in TmfDataRequest
[deliverable/tracecompass.git] / org.eclipse.linuxtools.tmf.core.tests / src / org / eclipse / linuxtools / tmf / core / tests / trace / TmfMultiTraceExperimentTest.java
CommitLineData
d18dd09b 1/*******************************************************************************
61759503 2 * Copyright (c) 2009, 2013 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
9e0640dc 16package org.eclipse.linuxtools.tmf.core.tests.trace;
d18dd09b 17
6e1886bc
AM		 18import static org.junit.Assert.assertEquals;
19import static org.junit.Assert.assertFalse;
20import static org.junit.Assert.assertNull;
21import static org.junit.Assert.assertTrue;
22
d18dd09b
ASL		 23import java.io.File;
24import java.io.IOException;
25import java.net.URISyntaxException;
26import java.net.URL;
27import java.util.Vector;
28
d18dd09b
ASL		 29import org.eclipse.core.runtime.FileLocator;
30import org.eclipse.core.runtime.Path;
17324c9a 31import org.eclipse.linuxtools.internal.tmf.core.trace.TmfExperimentContext;
72f1e62a 32import org.eclipse.linuxtools.tmf.core.event.ITmfEvent;
b4f71e4a 33import org.eclipse.linuxtools.tmf.core.exceptions.TmfTraceException;
9b749023 34import org.eclipse.linuxtools.tmf.core.request.TmfDataRequest;
6c13869b
FC		 35import org.eclipse.linuxtools.tmf.core.request.TmfEventRequest;
36import org.eclipse.linuxtools.tmf.core.tests.TmfCoreTestPlugin;
3bd46eef
AM		 37import org.eclipse.linuxtools.tmf.core.timestamp.ITmfTimestamp;
38import org.eclipse.linuxtools.tmf.core.timestamp.TmfTimeRange;
39import org.eclipse.linuxtools.tmf.core.timestamp.TmfTimestamp;
6c13869b 40import org.eclipse.linuxtools.tmf.core.trace.ITmfContext;
0316808c 41import org.eclipse.linuxtools.tmf.core.trace.ITmfLocation;
6c13869b 42import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;
9e0640dc 43import org.eclipse.linuxtools.tmf.tests.stubs.trace.TmfExperimentStub;
4918b8f2 44import org.eclipse.linuxtools.tmf.tests.stubs.trace.TmfTraceStub;
850a3ae2
PT		 45import org.junit.AfterClass;
46import org.junit.BeforeClass;
6e1886bc 47import org.junit.Test;
d18dd09b
ASL		 48
49/**
0316808c 50 * Test suite for the TmfExperiment class (multiple traces).
d18dd09b 51 */
cad06250 52@SuppressWarnings("javadoc")
6e1886bc 53public class TmfMultiTraceExperimentTest {
d18dd09b 54
0316808c
FC		 55 // ------------------------------------------------------------------------
56 // Attributes
57 // ------------------------------------------------------------------------
6e1886bc 58
66262ad8 59 private static final long DEFAULT_INITIAL_OFFSET_VALUE = (1L * 100 * 1000 * 1000); // .1sec
d18dd09b
ASL		 60 private static final String DIRECTORY = "testfiles";
61 private static final String TEST_STREAM1 = "O-Test-10K";
62 private static final String TEST_STREAM2 = "E-Test-10K";
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() {
88 final String path1 = DIRECTORY + File.separator + TEST_STREAM1;
89 final String path2 = DIRECTORY + File.separator + TEST_STREAM2;
90 try {
91 ITmfTrace[] traces = new ITmfTrace[2];
92
93 URL location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(path1), null);
94 File test = new File(FileLocator.toFileURL(location).toURI());
95 final TmfTraceStub trace1 = new TmfTraceStub(test.getPath(), 0, true);
96 traces[0] = trace1;
97
98 location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(path2), null);
99 test = new File(FileLocator.toFileURL(location).toURI());
100 final TmfTraceStub trace2 = new TmfTraceStub(test.getPath(), 0, true);
101 traces[1] = trace2;
102
103 return traces;
104 } catch (final TmfTraceException e) {
105 e.printStackTrace();
106 } catch (final URISyntaxException e) {
107 e.printStackTrace();
108 } catch (final IOException e) {
109 e.printStackTrace();
25e48683 110 }
850a3ae2 111 return new ITmfTrace[0];
d18dd09b
ASL		 112 }
113
d18dd09b
ASL		 114 // ------------------------------------------------------------------------
115 // Constructor
116 // ------------------------------------------------------------------------
117
6e1886bc 118 @Test
25e48683 119 public void testBasicTmfExperimentConstructor() {
25e48683 120 assertEquals("GetId", EXPERIMENT, fExperiment.getName());
d18dd09b
ASL		 121 assertEquals("GetNbEvents", NB_EVENTS, fExperiment.getNbEvents());
122
25e48683 123 final TmfTimeRange timeRange = fExperiment.getTimeRange();
d18dd09b
ASL		 124 assertEquals("getStartTime", 1, timeRange.getStartTime().getValue());
125 assertEquals("getEndTime", NB_EVENTS, timeRange.getEndTime().getValue());
66262ad8 126
850a3ae2 127 TmfTimestamp initRange = new TmfTimestamp(DEFAULT_INITIAL_OFFSET_VALUE, ITmfTimestamp.NANOSECOND_SCALE);
66262ad8 128 assertEquals("getInitialRangeOffset", initRange, fExperiment.getInitialRangeOffset());
25e48683 129 }
d18dd09b 130
d18dd09b 131 // ------------------------------------------------------------------------
0316808c 132 // seekEvent on rank
d18dd09b
ASL		 133 // ------------------------------------------------------------------------
134
6e1886bc 135 @Test
54a7a54c 136 public void testSeekRankOnCacheBoundary() {
0316808c 137 long cacheSize = fExperiment.getCacheSize();
9b635e61 138
0316808c
FC		 139 // On lower bound, returns the first event (TS = 1)
140 ITmfContext context = fExperiment.seekEvent(0);
141 assertEquals("Context rank", 0, context.getRank());
25e48683 142
c32744d6 143 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 144 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 145 assertEquals("Context rank", 1, context.getRank());
25e48683 146
0316808c
FC		 147 // Position trace at event rank [cacheSize]
148 context = fExperiment.seekEvent(cacheSize);
149 assertEquals("Context rank", cacheSize, context.getRank());
25e48683 150
c32744d6 151 event = fExperiment.getNext(context);
0316808c
FC		 152 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
153 assertEquals("Context rank", cacheSize + 1, context.getRank());
d18dd09b 154
0316808c
FC		 155 // Position trace at event rank [4 * cacheSize]
156 context = fExperiment.seekEvent(4 * cacheSize);
157 assertEquals("Context rank", 4 * cacheSize, context.getRank());
25e48683 158
c32744d6 159 event = fExperiment.getNext(context);
0316808c
FC		 160 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
161 assertEquals("Context rank", 4 * cacheSize + 1, context.getRank());
d18dd09b
ASL		 162 }
163
6e1886bc 164 @Test
54a7a54c 165 public void testSeekRankNotOnCacheBoundary() {
0316808c 166 long cacheSize = fExperiment.getCacheSize();
25e48683 167
0316808c
FC		 168 // Position trace at event rank 9
169 ITmfContext context = fExperiment.seekEvent(9);
170 assertEquals("Context rank", 9, context.getRank());
25e48683 171
c32744d6 172 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 173 assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
0316808c 174 assertEquals("Context rank", 10, context.getRank());
d18dd09b 175
0316808c
FC		 176 // Position trace at event rank [cacheSize - 1]
177 context = fExperiment.seekEvent(cacheSize - 1);
178 assertEquals("Context rank", cacheSize - 1, context.getRank());
25e48683 179
c32744d6 180 event = fExperiment.getNext(context);
0316808c
FC		 181 assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue());
182 assertEquals("Context rank", cacheSize, context.getRank());
d18dd09b 183
0316808c
FC		 184 // Position trace at event rank [cacheSize + 1]
185 context = fExperiment.seekEvent(cacheSize + 1);
186 assertEquals("Context rank", cacheSize + 1, context.getRank());
25e48683 187
c32744d6 188 event = fExperiment.getNext(context);
0316808c
FC		 189 assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue());
190 assertEquals("Context rank", cacheSize + 2, context.getRank());
d18dd09b 191
25e48683 192 // Position trace at event rank 4500
0316808c
FC		 193 context = fExperiment.seekEvent(4500);
194 assertEquals("Context rank", 4500, context.getRank());
25e48683 195
c32744d6 196 event = fExperiment.getNext(context);
d18dd09b 197 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
0316808c 198 assertEquals("Context rank", 4501, context.getRank());
d18dd09b
ASL		 199 }
200
6e1886bc 201 @Test
54a7a54c 202 public void testSeekRankOutOfScope() {
25e48683 203 // Position trace at beginning
0316808c 204 ITmfContext context = fExperiment.seekEvent(-1);
d18dd09b 205 assertEquals("Event rank", 0, context.getRank());
25e48683 206
c32744d6 207 ITmfEvent event = fExperiment.getNext(context);
d18dd09b 208 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 209 assertEquals("Context rank", 1, context.getRank());
d18dd09b 210
25e48683 211 // Position trace at event passed the end
0316808c
FC		 212 context = fExperiment.seekEvent(NB_EVENTS);
213 assertEquals("Context rank", NB_EVENTS, context.getRank());
214
c32744d6 215 event = fExperiment.getNext(context);
0316808c
FC		 216 assertNull("Event", event);
217 assertEquals("Context rank", NB_EVENTS, context.getRank());
d18dd09b
ASL		 218 }
219
25e48683
FC		 220 // ------------------------------------------------------------------------
221 // seekEvent on timestamp
222 // ------------------------------------------------------------------------
223
6e1886bc 224 @Test
54a7a54c 225 public void testSeekTimestampOnCacheBoundary() {
0316808c 226 long cacheSize = fExperiment.getCacheSize();
25e48683 227
0316808c
FC		 228 // Position trace at event rank 0
229 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(1, SCALE, 0));
230 assertEquals("Context rank", 0, context.getRank());
25e48683 231
c32744d6 232 ITmfEvent event = fExperiment.getNext(context);
25e48683 233 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
0316808c 234 assertEquals("Context rank", 1, context.getRank());
25e48683 235
0316808c
FC		 236 // Position trace at event rank [cacheSize]
237 context = fExperiment.seekEvent(new TmfTimestamp(cacheSize + 1, SCALE, 0));
238 assertEquals("Event rank", cacheSize, context.getRank());
25e48683 239
c32744d6 240 event = fExperiment.getNext(context);
0316808c
FC		 241 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
242 assertEquals("Context rank", cacheSize + 1, context.getRank());
25e48683 243
0316808c
FC		 244 // Position trace at event rank [4 * cacheSize]
245 context = fExperiment.seekEvent(new TmfTimestamp(4 * cacheSize + 1, SCALE, 0));
246 assertEquals("Context rank", 4 * cacheSize, context.getRank());
25e48683 247
c32744d6 248 event = fExperiment.getNext(context);
0316808c
FC		 249 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
250 assertEquals("Context rank", 4 * cacheSize + 1, context.getRank());
25e48683
FC		 251 }
252
6e1886bc 253 @Test
54a7a54c 254 public void testSeekTimestampNotOnCacheBoundary() {
0316808c
FC		 255 // Position trace at event rank 1 (TS = 2)
256 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(2, SCALE, 0));
257 assertEquals("Context rank", 1, context.getRank());
25e48683 258
c32744d6 259 ITmfEvent event = fExperiment.getNext(context);
25e48683 260 assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
0316808c 261 assertEquals("Context rank", 2, context.getRank());
25e48683 262
0316808c 263 // Position trace at event rank 9 (TS = 10)
25e48683 264 context = fExperiment.seekEvent(new TmfTimestamp(10, SCALE, 0));
0316808c 265 assertEquals("Context rank", 9, context.getRank());
25e48683 266
c32744d6 267 event = fExperiment.getNext(context);
25e48683 268 assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
0316808c 269 assertEquals("Context rank", 10, context.getRank());
25e48683 270
0316808c 271 // Position trace at event rank 999 (TS = 1000)
25e48683 272 context = fExperiment.seekEvent(new TmfTimestamp(1000, SCALE, 0));
0316808c 273 assertEquals("Context rank", 999, context.getRank());
25e48683 274
c32744d6 275 event = fExperiment.getNext(context);
25e48683 276 assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
0316808c 277 assertEquals("Context rank", 1000, context.getRank());
25e48683 278
0316808c 279 // Position trace at event rank 1001 (TS = 1002)
25e48683 280 context = fExperiment.seekEvent(new TmfTimestamp(1002, SCALE, 0));
0316808c 281 assertEquals("Context rank", 1001, context.getRank());
25e48683 282
c32744d6 283 event = fExperiment.getNext(context);
25e48683 284 assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
0316808c 285 assertEquals("Context rank", 1002, context.getRank());
25e48683 286
0316808c 287 // Position trace at event rank 4500 (TS = 4501)
25e48683 288 context = fExperiment.seekEvent(new TmfTimestamp(4501, SCALE, 0));
0316808c 289 assertEquals("Context rank", 4500, context.getRank());
25e48683 290
c32744d6 291 event = fExperiment.getNext(context);
25e48683 292 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
0316808c 293 assertEquals("Context rank", 4501, context.getRank());
25e48683
FC		 294 }
295
6e1886bc 296 @Test
54a7a54c 297 public void testSeekTimestampOutOfScope() {
25e48683 298 // Position trace at beginning
0316808c 299 ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(-1, SCALE, 0));
25e48683
FC		 300 assertEquals("Event rank", 0, context.getRank());
301
c32744d6 302 ITmfEvent event = fExperiment.getNext(context);
25e48683
FC		 303 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
304 assertEquals("Event rank", 1, context.getRank());
305
306 // Position trace at event passed the end
307 context = fExperiment.seekEvent(new TmfTimestamp(NB_EVENTS + 1, SCALE, 0));
c32744d6 308 event = fExperiment.getNext(context);
0316808c 309 assertNull("Event location", event);
9b635e61 310 assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
25e48683
FC		 311 }
312
313 // ------------------------------------------------------------------------
0316808c 314 // seekEvent by location (context rank is undefined)
25e48683
FC		 315 // ------------------------------------------------------------------------
316
6e1886bc 317 @Test
54a7a54c 318 public void testSeekLocationOnCacheBoundary() {
0316808c 319 long cacheSize = fExperiment.getCacheSize();
25e48683 320
0316808c
FC		 321 // Position trace at event rank 0
322 ITmfContext tmpContext = fExperiment.seekEvent(0);
323 ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 324
c32744d6 325 ITmfEvent event = fExperiment.getNext(context);
25e48683 326 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
25e48683 327
c32744d6 328 event = fExperiment.getNext(context);
0316808c 329 assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
25e48683 330
0316808c
FC		 331 // Position trace at event rank 'cacheSize'
332 tmpContext = fExperiment.seekEvent(cacheSize);
333 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 334
c32744d6 335 event = fExperiment.getNext(context);
0316808c 336 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
25e48683 337
c32744d6 338 event = fExperiment.getNext(context);
0316808c 339 assertEquals("Event timestamp", cacheSize + 2, event.getTimestamp().getValue());
25e48683 340
0316808c
FC		 341 // Position trace at event rank 4 * 'cacheSize'
342 tmpContext = fExperiment.seekEvent(4 * cacheSize);
343 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 344
c32744d6 345 event = fExperiment.getNext(context);
0316808c 346 assertEquals("Event timestamp", 4 * cacheSize + 1, event.getTimestamp().getValue());
25e48683 347
c32744d6 348 event = fExperiment.getNext(context);
0316808c 349 assertEquals("Event timestamp", 4 * cacheSize + 2, event.getTimestamp().getValue());
25e48683
FC		 350 }
351
6e1886bc 352 @Test
54a7a54c 353 public void testSeekLocationNotOnCacheBoundary() {
0316808c 354 long cacheSize = fExperiment.getCacheSize();
25e48683 355
0316808c
FC		 356 // Position trace at event 'cacheSize' - 1
357 ITmfContext tmpContext = fExperiment.seekEvent(cacheSize - 1);
358 ITmfContext context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 359
c32744d6 360 ITmfEvent event = fExperiment.getNext(context);
0316808c 361 assertEquals("Event timestamp", cacheSize, event.getTimestamp().getValue());
25e48683 362
c32744d6 363 event = fExperiment.getNext(context);
0316808c 364 assertEquals("Event timestamp", cacheSize + 1, event.getTimestamp().getValue());
25e48683 365
0316808c
FC		 366 // Position trace at event rank 2 * 'cacheSize' - 1
367 tmpContext = fExperiment.seekEvent(2 * cacheSize - 1);
368 context = fExperiment.seekEvent(tmpContext.getLocation());
369 context = fExperiment.seekEvent(2 * cacheSize - 1);
25e48683 370
c32744d6 371 event = fExperiment.getNext(context);
0316808c 372 assertEquals("Event timestamp", 2 * cacheSize, event.getTimestamp().getValue());
25e48683 373
c32744d6 374 event = fExperiment.getNext(context);
0316808c 375 assertEquals("Event timestamp", 2 * cacheSize + 1, event.getTimestamp().getValue());
25e48683
FC		 376
377 // Position trace at event rank 4500
0316808c
FC		 378 tmpContext = fExperiment.seekEvent(4500);
379 context = fExperiment.seekEvent(tmpContext.getLocation());
25e48683 380
c32744d6 381 event = fExperiment.getNext(context);
25e48683 382 assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
25e48683 383
c32744d6 384 event = fExperiment.getNext(context);
0316808c 385 assertEquals("Event timestamp", 4502, event.getTimestamp().getValue());
25e48683
FC		 386 }
387
6e1886bc 388 @Test
54a7a54c 389 public void testSeekLocationOutOfScope() {
25e48683 390 // Position trace at beginning
1e1bef82 391 ITmfContext context = fExperiment.seekEvent((ITmfLocation) null);
25e48683 392
c32744d6 393 ITmfEvent event = fExperiment.getNext(context);
25e48683 394 assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
25e48683 395 }
d18dd09b 396
9b635e61 397 // ------------------------------------------------------------------------
17324c9a 398 // getNext - updates the context
9b635e61 399 // ------------------------------------------------------------------------
d18dd09b 400
54a7a54c 401 private static void validateContextRanks(ITmfContext context) {
17324c9a
FC		 402 assertTrue("Experiment context type", context instanceof TmfExperimentContext);
403 TmfExperimentContext ctx = (TmfExperimentContext) context;
9b635e61 404
17324c9a
FC		 405 int nbTraces = ctx.getContexts().length;
406
407 // expRank = sum(trace ranks) - nbTraces + 1 (if lastTraceRead != NO_TRACE)
408 long expRank = -nbTraces + ((ctx.getLastTrace() != TmfExperimentContext.NO_TRACE) ? 1 : 0);
409 for (int i = 0; i < nbTraces; i++) {
410 long rank = ctx.getContexts()[i].getRank();
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)
426 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE, 0));
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)
452 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE, 0));
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)
478 final ITmfContext context = fExperiment.seekEvent(new TmfTimestamp(INITIAL_TS, SCALE, 0));
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 {
25e48683 680 final int blockSize = 100;
d18dd09b 681 final int nbEvents = 1000;
6256d8ad 682 final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
d18dd09b 683
25e48683 684 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
2771b032 685 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class, range, nbEvents, blockSize) {
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 testProcessRequestForNbEvents2() throws InterruptedException {
25e48683 708 final int blockSize = 2 * NB_EVENTS;
d18dd09b 709 final int nbEvents = 1000;
6256d8ad 710 final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
d18dd09b 711
25e48683 712 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
2771b032 713 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class, range, nbEvents, blockSize) {
25e48683 714 @Override
6256d8ad 715 public void handleData(final ITmfEvent event) {
25e48683
FC		 716 super.handleData(event);
717 requestedEvents.add(event);
718 }
d18dd09b
ASL		 719 };
720 fExperiment.sendRequest(request);
721 request.waitForCompletion();
722
723 assertEquals("nbEvents", nbEvents, requestedEvents.size());
724 assertTrue("isCompleted", request.isCompleted());
725 assertFalse("isCancelled", request.isCancelled());
726
727 // Ensure that we have distinct events.
25e48683 728 // Don't go overboard: we are not validating the stub!
20658947 729 for (int i = 0; i < nbEvents; i++) {
d18dd09b 730 assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue());
20658947 731 }
d18dd09b 732 }
25e48683 733
6e1886bc 734 @Test
54a7a54c 735 public void testProcessRequestForAllEvents() throws InterruptedException {
9b749023 736 final int nbEvents = TmfDataRequest.ALL_DATA;
d18dd09b 737 final int blockSize = 1;
6256d8ad 738 final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
25e48683 739 final long nbExpectedEvents = NB_EVENTS;
d18dd09b 740
25e48683 741 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
2771b032 742 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class, range, nbEvents, blockSize) {
25e48683 743 @Override
6256d8ad 744 public void handleData(final ITmfEvent event) {
25e48683
FC		 745 super.handleData(event);
746 requestedEvents.add(event);
747 }
d18dd09b
ASL		 748 };
749 fExperiment.sendRequest(request);
750 request.waitForCompletion();
751
9b635e61 752 assertEquals("nbEvents", nbExpectedEvents, requestedEvents.size());
d18dd09b
ASL		 753 assertTrue("isCompleted", request.isCompleted());
754 assertFalse("isCancelled", request.isCancelled());
755
756 // Ensure that we have distinct events.
25e48683 757 // Don't go overboard: we are not validating the stub!
20658947 758 for (int i = 0; i < nbExpectedEvents; i++) {
d18dd09b 759 assertEquals("Distinct events", i+1, requestedEvents.get(i).getTimestamp().getValue());
20658947 760 }
d18dd09b 761 }
25e48683 762
d18dd09b
ASL		 763 // ------------------------------------------------------------------------
764 // cancel
765 // ------------------------------------------------------------------------
766
6e1886bc 767 @Test
54a7a54c 768 public void testCancel() throws InterruptedException {
25e48683 769 final int nbEvents = NB_EVENTS;
9b635e61 770 final int blockSize = BLOCK_SIZE;
6256d8ad 771 final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
d18dd09b 772
25e48683 773 final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
2771b032 774 final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class, range, nbEvents, blockSize) {
25e48683
FC		 775 int nbRead = 0;
776 @Override
6256d8ad 777 public void handleData(final ITmfEvent event) {
25e48683
FC		 778 super.handleData(event);
779 requestedEvents.add(event);
20658947 780 if (++nbRead == blockSize) {
25e48683 781 cancel();
20658947 782 }
25e48683 783 }
9b635e61
FC		 784 @Override
785 public void handleCancel() {
20658947 786 if (requestedEvents.size() < blockSize) {
25e48683 787 System.out.println("aie");
20658947 788 }
9b635e61 789 }
d18dd09b
ASL		 790 };
791 fExperiment.sendRequest(request);
792 request.waitForCompletion();
793
794 assertEquals("nbEvents", blockSize, requestedEvents.size());
795 assertTrue("isCompleted", request.isCompleted());
796 assertTrue("isCancelled", request.isCancelled());
797 }
25e48683 798
d18dd09b
ASL		 799 // ------------------------------------------------------------------------
800 // getTimestamp
801 // ------------------------------------------------------------------------
802
6e1886bc 803 @Test
54a7a54c 804 public void testGetTimestamp() {
17324c9a
FC		 805 assertEquals("getTimestamp", new TmfTimestamp( 1, (byte) -3), fExperiment.getTimestamp( 0));
806 assertEquals("getTimestamp", new TmfTimestamp( 2, (byte) -3), fExperiment.getTimestamp( 1));
807 assertEquals("getTimestamp", new TmfTimestamp( 11, (byte) -3), fExperiment.getTimestamp( 10));
808 assertEquals("getTimestamp", new TmfTimestamp( 101, (byte) -3), fExperiment.getTimestamp( 100));
809 assertEquals("getTimestamp", new TmfTimestamp( 1001, (byte) -3), fExperiment.getTimestamp( 1000));
810 assertEquals("getTimestamp", new TmfTimestamp( 2001, (byte) -3), fExperiment.getTimestamp( 2000));
811 assertEquals("getTimestamp", new TmfTimestamp( 2501, (byte) -3), fExperiment.getTimestamp( 2500));
812 assertEquals("getTimestamp", new TmfTimestamp(10000, (byte) -3), fExperiment.getTimestamp( 9999));
813 assertEquals("getTimestamp", new TmfTimestamp(20000, (byte) -3), fExperiment.getTimestamp(19999));
814 assertNull("getTimestamp", fExperiment.getTimestamp(20000));
d18dd09b
ASL		 815 }
816
66262ad8
BH		 817 // ------------------------------------------------------------------------
818 // getInitialRangeOffset, getCurrentRange, getCurrentTime
819 // ------------------------------------------------------------------------
2771b032 820
6e1886bc 821 @Test
66262ad8 822 public void testDefaultCurrentTimeValues() {
850a3ae2
PT		 823 ITmfTrace[] traces = setupTraces();
824 TmfExperimentStub exp = new TmfExperimentStub(EXPERIMENT, traces, BLOCK_SIZE);
66262ad8
BH		 825
826 // verify initial values
827 TmfTimestamp initRange = new TmfTimestamp(DEFAULT_INITIAL_OFFSET_VALUE, ITmfTimestamp.NANOSECOND_SCALE);
828 assertEquals("getInitialRangeOffset", initRange, exp.getInitialRangeOffset());
850a3ae2
PT		 829
830 exp.dispose();
831 }
832
833 @Test
834 public void testInitialRangeOffset() {
835 ITmfTrace[] traces = setupTraces();
836 ((TmfTraceStub) traces[0]).setInitialRangeOffset(new TmfTimestamp(5, ITmfTimestamp.MILLISECOND_SCALE));
837 ((TmfTraceStub) traces[1]).setInitialRangeOffset(new TmfTimestamp(2, ITmfTimestamp.MILLISECOND_SCALE));
838 TmfExperimentStub exp = new TmfExperimentStub(EXPERIMENT, traces, BLOCK_SIZE);
839
840 TmfTimestamp initRange = new TmfTimestamp(2, ITmfTimestamp.MILLISECOND_SCALE);
841 assertEquals("getInitialRangeOffset", initRange, exp.getInitialRangeOffset());
842
843 exp.dispose();
66262ad8 844 }
6e1886bc 845
17324c9a 846}
Tracecompass - Deliverables
This page took 0.096234 seconds and 5 git commands to generate.