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