projects / deliverable / tracecompass.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Rename xxx.lttng to xxx.lttng.core
[deliverable/tracecompass.git] / org.eclipse.linuxtools.tmf.tests / src / org / eclipse / linuxtools / tmf / tests / trace / TmfTraceTest.java
diff --git a/org.eclipse.linuxtools.tmf.tests/src/org/eclipse/linuxtools/tmf/tests/trace/TmfTraceTest.java b/org.eclipse.linuxtools.tmf.tests/src/org/eclipse/linuxtools/tmf/tests/trace/TmfTraceTest.java
index f5b51aab43323409b7bec1707caff48f87648d4b..2bc01e5235b229ccb551a6ce5d7308c9c1a9b4fd 100644 (file)
--- a/org.eclipse.linuxtools.tmf.tests/src/org/eclipse/linuxtools/tmf/tests/trace/TmfTraceTest.java
+++ b/org.eclipse.linuxtools.tmf.tests/src/org/eclipse/linuxtools/tmf/tests/trace/TmfTraceTest.java
@@ -40,6 +40,7 @@ import org.eclipse.linuxtools.tmf.trace.TmfTraceStub;
  * <p>
  * Test suite for the TmfTrace class.
  */
+@SuppressWarnings("nls")
 public class TmfTraceTest extends TestCase {
 
        // ------------------------------------------------------------------------
@@ -66,6 +67,15 @@ public class TmfTraceTest extends TestCase {
        protected void setUp() throws Exception {
                super.setUp();  
                fTrace = setupTrace(DIRECTORY + File.separator + TEST_STREAM);
+               // Dummy request to force the trace indexing
+       TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class) {
+                       @Override
+                       public void handleData(TmfEvent event) {
+                       super.handleData(event);
+                       }
+       };
+       fTrace.sendRequest(request);
+       request.waitForCompletion();
        }
 
        @Override
@@ -85,7 +95,6 @@ public class TmfTraceTest extends TestCase {
                URL location = FileLocator.find(TmfCoreTestPlugin.getDefault().getBundle(), new Path(path), null);
                        File test = new File(FileLocator.toFileURL(location).toURI());
                fTrace = new TmfTraceStub(test.getPath(), BLOCK_SIZE, false);
-               fTrace.indexTrace(true);
                } catch (URISyntaxException e) {
                        e.printStackTrace();
                } catch (IOException e) {
@@ -115,7 +124,7 @@ public class TmfTraceTest extends TestCase {
                assertEquals("getType",      TmfEvent.class, trace.getType());
                assertEquals("getPath",      testfile.getPath(), trace.getPath());
                assertEquals("getName",      TEST_STREAM, trace.getName());
-               assertEquals("getCacheSize", TmfTrace.DEFAULT_CACHE_SIZE, trace.getCacheSize());
+               assertEquals("getCacheSize", TmfTrace.DEFAULT_INDEX_PAGE_SIZE, trace.getCacheSize());
     }
 
     public void testTmfTraceDefaultCacheSize() throws Exception {
@@ -134,7 +143,7 @@ public class TmfTraceTest extends TestCase {
                assertEquals("getType",      TmfEvent.class, trace.getType());
                assertEquals("getPath",      testfile.getPath(), trace.getPath());
                assertEquals("getName",      TEST_STREAM, trace.getName());
-               assertEquals("getCacheSize", TmfTrace.DEFAULT_CACHE_SIZE, trace.getCacheSize());
+               assertEquals("getCacheSize", TmfTrace.DEFAULT_INDEX_PAGE_SIZE, trace.getCacheSize());
     }
 
     public void testTmfTrace() throws Exception {
@@ -233,28 +242,43 @@ public class TmfTraceTest extends TestCase {
 
     public void testParseEvent() throws Exception {
 
+       int NB_READS = 20;
+
        // On lower bound, returns the first event (ts = 0)
        TmfContext context = fTrace.seekEvent(new TmfTimestamp(0, SCALE, 0));
+       TmfContext svContext = new TmfContext(context);
 
        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
+        assertEquals("Event rank", 0, context.getRank());
+        assertTrue("parseEvent", context.equals(svContext));
 
         event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
+        assertEquals("Event rank", 0, context.getRank());
+        assertTrue("parseEvent", context.equals(svContext));
 
         event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
+        assertEquals("Event rank", 0, context.getRank());
+        assertTrue("parseEvent", context.equals(svContext));
 
-        for (int i = 1; i < 20; i++) {
+        // Position the trace at event NB_READS
+        for (int i = 1; i < NB_READS; i++) {
             event = fTrace.getNextEvent(context);
             assertEquals("Event timestamp", i, event.getTimestamp().getValue());
         }
 
+       svContext = new TmfContext(context);
         event = fTrace.parseEvent(context);
-        assertEquals("Event timestamp", 20, event.getTimestamp().getValue());
+        assertEquals("Event timestamp", NB_READS, event.getTimestamp().getValue());
+        assertEquals("Event rank", NB_READS -1 , context.getRank());
+        assertTrue("parseEvent", context.equals(svContext));
 
         event = fTrace.parseEvent(context);
-        assertEquals("Event timestamp", 20, event.getTimestamp().getValue());
+        assertEquals("Event timestamp", NB_READS, event.getTimestamp().getValue());
+        assertEquals("Event rank", NB_READS - 1, context.getRank());
+        assertTrue("parseEvent", context.equals(svContext));
     }
 
     // ------------------------------------------------------------------------
@@ -263,15 +287,23 @@ public class TmfTraceTest extends TestCase {
 
     public void testGetNextEvent() throws Exception {
 
-       // On lower bound, returns the first event (ts = 0)
+       int NB_READS = 20;
+
+       // On lower bound, returns the first event (ts = 1)
        TmfContext context = fTrace.seekEvent(new TmfTimestamp(0, SCALE, 0));
-        TmfEvent event = fTrace.getNextEvent(context);
-        assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
 
-        for (int i = 2; i < 20; i++) {
+       // Read NB_EVENTS
+       TmfEvent event;
+        for (int i = 0; i < NB_READS; i++) {
             event = fTrace.getNextEvent(context);
-            assertEquals("Event timestamp", i, event.getTimestamp().getValue());
+            assertEquals("Event timestamp", i + 1, event.getTimestamp().getValue());
+            assertEquals("Event rank", i + 1, context.getRank());
         }
+
+        // Make sure we stay positioned
+        event = fTrace.parseEvent(context);
+        assertEquals("Event timestamp", NB_READS + 1, event.getTimestamp().getValue());
+        assertEquals("Event rank", NB_READS, context.getRank());
     }
 
     // ------------------------------------------------------------------------
@@ -283,33 +315,44 @@ public class TmfTraceTest extends TestCase {
 
        // Position trace at event rank 0
        TmfContext context = fTrace.seekLocation(null);
-        assertEquals("Event rank", 0, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 0, context.getRank());
-       event = fTrace.getNextEvent(context);
+
+        context = fTrace.seekLocation(context.getLocation());
+        assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
+
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
-        assertEquals("Event rank", 1, context.getRank());
+        assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
+
+        event = fTrace.getNextEvent(context);
+        assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
+        assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event rank 1000
         TmfContext tmpContext = fTrace.seekEvent(new TmfTimestamp(1001, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event rank 4000
         tmpContext = fTrace.seekEvent(new TmfTimestamp(4001, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
     }
@@ -318,45 +361,53 @@ public class TmfTraceTest extends TestCase {
 
        // Position trace at event rank 9
        TmfContext tmpContext = fTrace.seekEvent(new TmfTimestamp(10, SCALE, 0));
-        TmfContext context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        TmfContext context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event rank 999
         tmpContext = fTrace.seekEvent(new TmfTimestamp(1000, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event rank 1001
         tmpContext = fTrace.seekEvent(new TmfTimestamp(1002, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event rank 4500
         tmpContext = fTrace.seekEvent(new TmfTimestamp(4501, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
     }
@@ -365,23 +416,27 @@ public class TmfTraceTest extends TestCase {
 
        // Position trace at beginning
        TmfContext tmpContext = fTrace.seekLocation(null);
-        TmfContext context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        TmfContext context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
 
        // Position trace at event passed the end
         tmpContext = fTrace.seekEvent(new TmfTimestamp(NB_EVENTS + 1, SCALE, 0));
-        context = fTrace.seekLocation(tmpContext.getLocation().clone());
+        context = fTrace.seekLocation(tmpContext.getLocation());
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", ITmfContext.UNKNOWN_RANK, context.getRank());
     }
@@ -395,30 +450,36 @@ public class TmfTraceTest extends TestCase {
        // Position trace at event rank 0
        TmfContext context = fTrace.seekEvent(new TmfTimestamp(1, SCALE, 0));
         assertEquals("Event rank", 0, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 0, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 1, context.getRank());
 
        // Position trace at event rank 1000
         context = fTrace.seekEvent(new TmfTimestamp(1001, SCALE, 0));
         assertEquals("Event rank", 1000, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", 1000, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", 1001, context.getRank());
 
        // Position trace at event rank 4000
         context = fTrace.seekEvent(new TmfTimestamp(4001, SCALE, 0));
         assertEquals("Event rank", 4000, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", 4000, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", 4001, context.getRank());
     }
@@ -428,50 +489,60 @@ public class TmfTraceTest extends TestCase {
        // Position trace at event rank 1
        TmfContext context = fTrace.seekEvent(new TmfTimestamp(2, SCALE, 0));
         assertEquals("Event rank", 1, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
         assertEquals("Event rank", 1, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 2, event.getTimestamp().getValue());
         assertEquals("Event rank", 2, context.getRank());
 
        // Position trace at event rank 9
        context = fTrace.seekEvent(new TmfTimestamp(10, SCALE, 0));
         assertEquals("Event rank", 9, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", 9, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", 10, context.getRank());
 
        // Position trace at event rank 999
         context = fTrace.seekEvent(new TmfTimestamp(1000, SCALE, 0));
         assertEquals("Event rank", 999, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", 999, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", 1000, context.getRank());
 
        // Position trace at event rank 1001
         context = fTrace.seekEvent(new TmfTimestamp(1002, SCALE, 0));
         assertEquals("Event rank", 1001, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", 1001, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", 1002, context.getRank());
 
        // Position trace at event rank 4500
         context = fTrace.seekEvent(new TmfTimestamp(4501, SCALE, 0));
         assertEquals("Event rank", 4500, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", 4500, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", 4501, context.getRank());
     }
@@ -481,20 +552,24 @@ public class TmfTraceTest extends TestCase {
        // Position trace at beginning
        TmfContext context = fTrace.seekEvent(new TmfTimestamp(-1, SCALE, 0));
         assertEquals("Event rank", 0, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 0, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 1, context.getRank());
 
        // Position trace at event passed the end
         context = fTrace.seekEvent(new TmfTimestamp(NB_EVENTS + 1, SCALE, 0));
         assertEquals("Event rank", NB_EVENTS, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", NB_EVENTS, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", NB_EVENTS, context.getRank());
     }
@@ -508,30 +583,36 @@ public class TmfTraceTest extends TestCase {
        // On lower bound, returns the first event (ts = 1)
        TmfContext context = fTrace.seekEvent(0);
         assertEquals("Event rank", 0, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 0, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 1, context.getRank());
 
        // Position trace at event rank 1000
         context = fTrace.seekEvent(1000);
         assertEquals("Event rank", 1000, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", 1000, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1001, event.getTimestamp().getValue());
         assertEquals("Event rank", 1001, context.getRank());
 
        // Position trace at event rank 4000
         context = fTrace.seekEvent(4000);
         assertEquals("Event rank", 4000, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", 4000, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4001, event.getTimestamp().getValue());
         assertEquals("Event rank", 4001, context.getRank());
     }
@@ -541,40 +622,48 @@ public class TmfTraceTest extends TestCase {
        // Position trace at event rank 9
        TmfContext context = fTrace.seekEvent(9);
         assertEquals("Event rank", 9, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", 9, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 10, event.getTimestamp().getValue());
         assertEquals("Event rank", 10, context.getRank());
 
        // Position trace at event rank 999
         context = fTrace.seekEvent(999);
         assertEquals("Event rank", 999, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", 999, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1000, event.getTimestamp().getValue());
         assertEquals("Event rank", 1000, context.getRank());
 
        // Position trace at event rank 1001
         context = fTrace.seekEvent(1001);
         assertEquals("Event rank", 1001, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", 1001, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1002, event.getTimestamp().getValue());
         assertEquals("Event rank", 1002, context.getRank());
 
        // Position trace at event rank 4500
         context = fTrace.seekEvent(4500);
         assertEquals("Event rank", 4500, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", 4500, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 4501, event.getTimestamp().getValue());
         assertEquals("Event rank", 4501, context.getRank());
     }
@@ -584,20 +673,24 @@ public class TmfTraceTest extends TestCase {
        // Position trace at beginning
        TmfContext context = fTrace.seekEvent(-1);
         assertEquals("Event rank", 0, context.getRank());
-       TmfEvent event = fTrace.parseEvent(context);
+       
+        TmfEvent event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 0, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", 1, event.getTimestamp().getValue());
         assertEquals("Event rank", 1, context.getRank());
 
        // Position trace at event passed the end
         context = fTrace.seekEvent(NB_EVENTS);
         assertEquals("Event rank", NB_EVENTS, context.getRank());
-       event = fTrace.parseEvent(context);
+       
+        event = fTrace.parseEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", NB_EVENTS, context.getRank());
-       event = fTrace.getNextEvent(context);
+       
+        event = fTrace.getNextEvent(context);
         assertEquals("Event timestamp", null, event);
         assertEquals("Event rank", NB_EVENTS, context.getRank());
     }
@@ -614,13 +707,11 @@ public class TmfTraceTest extends TestCase {
 
         TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BigBang, TmfTimestamp.BigCrunch);
         final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, NB_EVENTS, BLOCK_SIZE) {
-            @Override
-            public void handleData() {
-               TmfEvent[] events = getData();
-                for (TmfEvent e : events) {
-                    requestedEvents.add(e);
-                }
-            }
+               @Override
+               public void handleData(TmfEvent event) {
+                       super.handleData(event);
+                       requestedEvents.add(event);
+               }
         };
         ITmfDataProvider<TmfEvent>[] providers = (ITmfDataProvider<TmfEvent>[]) TmfProviderManager.getProviders(TmfEvent.class, TmfTraceStub.class);
         providers[0].sendRequest(request);
@@ -644,13 +735,11 @@ public class TmfTraceTest extends TestCase {
 
         TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BigBang, TmfTimestamp.BigCrunch);
         final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, NB_EVENTS, BLOCK_SIZE) {
-            @Override
-            public void handleData() {
-               TmfEvent[] events = getData();
-                for (TmfEvent e : events) {
-                    requestedEvents.add(e);
-                }
-            }
+               @Override
+               public void handleData(TmfEvent event) {
+                       super.handleData(event);
+                       requestedEvents.add(event);
+               }
         };
         ITmfDataProvider<TmfEvent>[] providers = (ITmfDataProvider<TmfEvent>[]) TmfProviderManager.getProviders(TmfEvent.class, TmfTraceStub.class);
         providers[0].sendRequest(request);
@@ -676,22 +765,21 @@ public class TmfTraceTest extends TestCase {
         final Vector<TmfEvent> requestedEvents = new Vector<TmfEvent>();
 
         TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BigBang, TmfTimestamp.BigCrunch);
-        final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, NB_EVENTS, NB_EVENTS) {
-            @Override
-            public void handleData() {
-               TmfEvent[] events = getData();
-                for (TmfEvent e : events) {
-                    requestedEvents.add(e);
-                }
-                // Cancel request after the first chunk is received
-                cancel();
-            }
+        final TmfEventRequest<TmfEvent> request = new TmfEventRequest<TmfEvent>(TmfEvent.class, range, NB_EVENTS, BLOCK_SIZE) {
+               int nbRead = 0;
+               @Override
+               public void handleData(TmfEvent event) {
+                       super.handleData(event);
+                       requestedEvents.add(event);
+                       if (++nbRead == BLOCK_SIZE)
+                               cancel();
+               }
         };
         ITmfDataProvider<TmfEvent>[] providers = (ITmfDataProvider<TmfEvent>[]) TmfProviderManager.getProviders(TmfEvent.class, TmfTraceStub.class);
         providers[0].sendRequest(request);
         request.waitForCompletion();
 
-        assertEquals("nbEvents",  NB_EVENTS, requestedEvents.size());
+        assertEquals("nbEvents",  BLOCK_SIZE, requestedEvents.size());
         assertTrue("isCompleted", request.isCompleted());
         assertTrue("isCancelled", request.isCancelled());
     }
Tracecompass - Deliverables
This page took 0.030854 seconds and 5 git commands to generate.