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