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