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