X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=ctf%2Forg.eclipse.tracecompass.tmf.ctf.core.tests%2Fsrc%2Forg%2Feclipse%2Ftracecompass%2Ftmf%2Fctf%2Fcore%2Ftests%2Ftrace%2FTmfTraceUtilsSearchingTest.java;fp=ctf%2Forg.eclipse.tracecompass.tmf.ctf.core.tests%2Fsrc%2Forg%2Feclipse%2Ftracecompass%2Ftmf%2Fctf%2Fcore%2Ftests%2Ftrace%2FTmfTraceUtilsSearchingTest.java;h=b220989654c2aa052a7d8f1d2a59bd08ad487a4b;hb=e4bc4695e263b0f4867e9efc10dced5571fd06ff;hp=0000000000000000000000000000000000000000;hpb=5bb21f6b559ed172e1319642b0755ec78887a8c6;p=deliverable%2Ftracecompass.git

diff --git a/ctf/org.eclipse.tracecompass.tmf.ctf.core.tests/src/org/eclipse/tracecompass/tmf/ctf/core/tests/trace/TmfTraceUtilsSearchingTest.java b/ctf/org.eclipse.tracecompass.tmf.ctf.core.tests/src/org/eclipse/tracecompass/tmf/ctf/core/tests/trace/TmfTraceUtilsSearchingTest.java
new file mode 100644
index 0000000000..b220989654
--- /dev/null
+++ b/ctf/org.eclipse.tracecompass.tmf.ctf.core.tests/src/org/eclipse/tracecompass/tmf/ctf/core/tests/trace/TmfTraceUtilsSearchingTest.java
@@ -0,0 +1,177 @@
+/*******************************************************************************
+ * Copyright (c) 2016 EfficiOS Inc., Alexandre Montplaisir
+ *
+ * All rights reserved. This program and the accompanying materials are
+ * made available under the terms of the Eclipse Public License v1.0 which
+ * accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *******************************************************************************/
+
+package org.eclipse.tracecompass.tmf.ctf.core.tests.trace;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertNotEquals;
+
+import java.util.function.Predicate;
+
+import org.eclipse.jdt.annotation.NonNull;
+import org.eclipse.tracecompass.testtraces.ctf.CtfTestTrace;
+import org.eclipse.tracecompass.tmf.core.event.ITmfEvent;
+import org.eclipse.tracecompass.tmf.core.trace.ITmfContext;
+import org.eclipse.tracecompass.tmf.core.trace.ITmfTrace;
+import org.eclipse.tracecompass.tmf.core.trace.TmfTraceUtils;
+import org.eclipse.tracecompass.tmf.ctf.core.tests.shared.CtfTmfTestTraceUtils;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * Tests for the event-searching methods in {@link TmfTraceUtils}.
+ *
+ * @author Alexandre Montplaisir
+ */
+public class TmfTraceUtilsSearchingTest {
+
+    private static final @NonNull CtfTestTrace TEST_TRACE = CtfTestTrace.TRACE2;
+    private static final long START_RANK = 500L;
+
+    private ITmfTrace fTrace;
+    private ITmfEvent fStartEvent;
+
+    /**
+     * Test setup
+     */
+    @Before
+    public void setUp() {
+        fTrace = CtfTmfTestTraceUtils.getTrace(TEST_TRACE);
+
+        ITmfContext ctx = fTrace.seekEvent(START_RANK);
+        fStartEvent = fTrace.getNext(ctx);
+        assertEquals("softirq_raise", fStartEvent.getName());
+    }
+
+    /**
+     * Test cleanup
+     */
+    @After
+    public void tearDown() {
+        if (fTrace != null) {
+            fTrace.dispose();
+        }
+    }
+
+    /**
+     * Test the {@link TmfTraceUtils#getNextEventMatching} method.
+     */
+    @Test
+    public void testNextMatchingEvent() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("sched_switch");
+
+        ITmfEvent actualEvent = TmfTraceUtils.getNextEventMatching(trace, START_RANK, predicate);
+
+        ITmfContext ctx = trace.seekEvent(508L); // following sched_switch event
+        ITmfEvent expectedEvent = trace.getNext(ctx);
+
+        assertEquals(expectedEvent, actualEvent);
+    }
+
+    /**
+     * Test the {@link TmfTraceUtils#getNextEventMatching} method, where the
+     * event from which we start the search already matches the criterion (it
+     * should be correctly skipped so we can advance).
+     */
+    @Test
+    public void testNextMatchingEventStartMatches() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("softirq_raise");
+        ITmfEvent foundEvent = TmfTraceUtils.getNextEventMatching(trace, START_RANK, predicate);
+
+        assertNotNull(foundEvent);
+        assertNotEquals(fStartEvent, foundEvent);
+    }
+
+    /**
+     * Test the {@link TmfTraceUtils#getPreviousEventMatching} method.
+     */
+    @Test
+    public void testPreviousMatchingEvent() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("sched_switch");
+
+        ITmfEvent actualEvent = TmfTraceUtils.getPreviousEventMatching(trace, START_RANK, predicate);
+
+        ITmfContext ctx = trace.seekEvent(455L); // previous sched_switch event
+        ITmfEvent expectedEvent = trace.getNext(ctx);
+
+        assertEquals(expectedEvent, actualEvent);
+    }
+
+    /**
+     * Test the {@link TmfTraceUtils#getPreviousEventMatching} method, where the
+     * event from which we start the search already matches the criterion (it
+     * should be correctly skipped).
+     */
+    @Test
+    public void testPreviousMatchingEventStartMatches() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("softirq_raise");
+        ITmfEvent foundEvent = TmfTraceUtils.getPreviousEventMatching(trace, START_RANK, predicate);
+
+        assertNotNull(foundEvent);
+        assertNotEquals(fStartEvent, foundEvent);
+    }
+
+    /**
+     * Test the {@link TmfTraceUtils#getPreviousEventMatching} method with an
+     * event that is expected to take more than one inner request.
+     */
+    @Test
+    public void testPreviousMatchingEventFar() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("sys_write");
+        ITmfEvent actualEvent = TmfTraceUtils.getPreviousEventMatching(trace, START_RANK, predicate);
+
+        ITmfContext ctx = trace.seekEvent(387L); // previous sched_switch event
+        ITmfEvent expectedEvent = trace.getNext(ctx);
+
+        assertEquals(expectedEvent, actualEvent);
+    }
+
+    /**
+     * When doing a backwards search near the beginning of the trace (when
+     * startRank < step), make sure that we do not go beyond the start rank.
+     */
+    @Test
+    public void testPreviousMatchingBeginningOfTrace() {
+        ITmfTrace trace = fTrace;
+        assertNotNull(trace);
+
+        final int startRank = 3;
+        ITmfContext ctx = fTrace.seekEvent(startRank);
+        ITmfEvent startEvent = fTrace.getNext(ctx);
+        assertEquals("exit_syscall", startEvent.getName());
+
+        /* There is a sys_mmap at rank 6, it should not be matched! */
+        Predicate<@NonNull ITmfEvent> predicate = event -> event.getName().equals("sys_mmap");
+        ITmfEvent foundEvent = TmfTraceUtils.getPreviousEventMatching(trace, startRank, predicate);
+        assertNull(foundEvent);
+
+        /* Do not match the event itself either, or any later "exit_syscall" */
+        predicate = event -> event.getName().equals("exit_syscall");
+        foundEvent = TmfTraceUtils.getPreviousEventMatching(trace, startRank, predicate);
+        assertNull(foundEvent);
+    }
+}