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