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