1 files changed, 100 insertions, 0 deletions
diff --git a/lttng/org.eclipse.linuxtools.lttng2.kernel.core.tests/src/org/eclipse/linuxtools/lttng2/kernel/core/tests/event/matchandsync/ExperimentSyncTest.java b/lttng/org.eclipse.linuxtools.lttng2.kernel.core.tests/src/org/eclipse/linuxtools/lttng2/kernel/core/tests/event/matchandsync/ExperimentSyncTest.java
new file mode 100644
index 0000000000..6267b03c1c
--- /dev/null
+++ b/lttng/org.eclipse.linuxtools.lttng2.kernel.core.tests/src/org/eclipse/linuxtools/lttng2/kernel/core/tests/event/matchandsync/ExperimentSyncTest.java
@@ -0,0 +1,100 @@
+/*******************************************************************************
+ * Copyright (c) 2013 École Polytechnique de Montréal
+ *
+ * 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
+ *
+ * Contributors:
+ *   Geneviève Bastien - Initial implementation
+ *******************************************************************************/
+
+package org.eclipse.linuxtools.lttng2.kernel.core.tests.event.matchandsync;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
+
+import org.eclipse.linuxtools.lttng2.kernel.core.event.matching.TcpEventMatching;
+import org.eclipse.linuxtools.lttng2.kernel.core.event.matching.TcpLttngEventMatching;
+import org.eclipse.linuxtools.tmf.core.ctfadaptor.CtfTmfTrace;
+import org.eclipse.linuxtools.tmf.core.event.matching.TmfEventMatching;
+import org.eclipse.linuxtools.tmf.core.exceptions.TmfTraceException;
+import org.eclipse.linuxtools.tmf.core.synchronization.ITmfTimestampTransform;
+import org.eclipse.linuxtools.tmf.core.synchronization.SynchronizationAlgorithm;
+import org.eclipse.linuxtools.tmf.core.synchronization.TmfTimestampTransform;
+import org.eclipse.linuxtools.tmf.core.tests.shared.CtfTmfTestTraces;
+import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;
+import org.eclipse.linuxtools.tmf.core.trace.TmfExperiment;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * Tests for experiment syncing
+ *
+ * @author Geneviève Bastien
+ */
+@SuppressWarnings("nls")
+public class ExperimentSyncTest {
+
+    private static final String EXPERIMENT   = "MyExperiment";
+    private static int          BLOCK_SIZE   = 1000;
+
+    private static ITmfTrace[] fTraces;
+    private static TmfExperiment fExperiment;
+
+    /**
+     * Setup the traces and experiment
+     */
+    @Before
+    public void setUp() {
+        CtfTmfTrace trace1 = CtfTmfTestTraces.getTestTrace(3);
+        CtfTmfTrace trace2 = CtfTmfTestTraces.getTestTrace(4);
+
+        fTraces = new CtfTmfTrace[2];
+        fTraces[0] = trace1;
+        fTraces[1] = trace2;
+
+        fExperiment = new TmfExperiment(trace1.getEventType(), EXPERIMENT, fTraces, BLOCK_SIZE);
+
+        TmfEventMatching.registerMatchObject(new TcpEventMatching());
+        TmfEventMatching.registerMatchObject(new TcpLttngEventMatching());
+    }
+
+    /**
+     * Reset the timestamp transforms on the traces
+     */
+    @After
+    public void cleanUp() {
+        fTraces[0].setTimestampTransform(TmfTimestampTransform.IDENTITY);
+        fTraces[1].setTimestampTransform(TmfTimestampTransform.IDENTITY);
+    }
+
+    /**
+     * Testing experiment synchronization
+     */
+    @Test
+    public void testExperimentSync() {
+        try {
+            SynchronizationAlgorithm syncAlgo = fExperiment.synchronizeTraces(true);
+
+            ITmfTimestampTransform tt1, tt2;
+
+            tt1 = syncAlgo.getTimestampTransform(fTraces[0]);
+            tt2 = syncAlgo.getTimestampTransform(fTraces[1]);
+
+            fTraces[0].setTimestampTransform(tt1);
+            fTraces[1].setTimestampTransform(tt2);
+
+            assertEquals("TmfTimestampTransform [ IDENTITY ]", tt2.toString());
+            assertEquals("TmfTimestampLinear [ alpha = 0.9999413783703139011056845831168394, beta = 79796507913179.33347660124688298171 ]", tt1.toString());
+
+            assertEquals(syncAlgo.getTimestampTransform(fTraces[0].getName()),fTraces[0].getTimestampTransform());
+            assertEquals(syncAlgo.getTimestampTransform(fTraces[1].getName()),fTraces[1].getTimestampTransform());
+
+        } catch (TmfTraceException e) {
+            fail("Exception thrown in experiment synchronization " + e.getMessage());
+        }
+    }
+}