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