lttng/org.eclipse.tracecompass.lttng2.kernel.core.tests/src/org/eclipse/tracecompass/lttng2/kernel/core/tests/event/matchandsync/ExperimentSyncTest.java

   1 /*******************************************************************************
   2  * Copyright (c) 2013, 2014 École Polytechnique de Montréal
   3  *
   4  * All rights reserved. This program and the accompanying materials are made
   5  * 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  *   Geneviève Bastien - Initial implementation
  11  *******************************************************************************/
  12
  13 package org.eclipse.tracecompass.lttng2.kernel.core.tests.event.matchandsync;
  14
  15 import static org.junit.Assert.assertEquals;
  16
  17 import java.util.concurrent.TimeUnit;
  18
  19 import org.eclipse.tracecompass.internal.lttng2.kernel.core.event.matching.TcpEventMatching;
  20 import org.eclipse.tracecompass.internal.lttng2.kernel.core.event.matching.TcpLttngEventMatching;
  21 import org.eclipse.tracecompass.testtraces.ctf.CtfTestTrace;
  22 import org.eclipse.tracecompass.tmf.core.event.matching.TmfEventMatching;
  23 import org.eclipse.tracecompass.tmf.core.synchronization.ITmfTimestampTransform;
  24 import org.eclipse.tracecompass.tmf.core.synchronization.SynchronizationAlgorithm;
  25 import org.eclipse.tracecompass.tmf.core.synchronization.TimestampTransformFactory;
  26 import org.eclipse.tracecompass.tmf.core.trace.ITmfTrace;
  27 import org.eclipse.tracecompass.tmf.core.trace.experiment.TmfExperiment;
  28 import org.eclipse.tracecompass.tmf.ctf.core.tests.shared.CtfTmfTestTraceUtils;
  29 import org.eclipse.tracecompass.tmf.ctf.core.trace.CtfTmfTrace;
  30 import org.junit.BeforeClass;
  31 import org.junit.Rule;
  32 import org.junit.Test;
  33 import org.junit.rules.TestRule;
  34 import org.junit.rules.Timeout;
  35
  36 /**
  37  * Tests for experiment syncing
  38  *
  39  * @author Geneviève Bastien
  40  */
  41 @SuppressWarnings("nls")
  42 public class ExperimentSyncTest {
  43
  44     /** Timeout the tests after 2 minutes */
  45     @Rule
  46     public TestRule timeoutRule = new Timeout(2, TimeUnit.MINUTES);
  47
  48     private static final String EXPERIMENT = "MyExperiment";
  49     private static int BLOCK_SIZE = 1000;
  50
  51     /**
  52      * Initialize some data
  53      */
  54     @BeforeClass
  55     public static void setUp() {
  56         TmfEventMatching.registerMatchObject(new TcpEventMatching());
  57         TmfEventMatching.registerMatchObject(new TcpLttngEventMatching());
  58     }
  59
  60     /**
  61      * Testing experiment synchronization
  62      */
  63     @Test
  64     public void testExperimentSync() {
  65         CtfTmfTrace trace1 = CtfTmfTestTraceUtils.getTrace(CtfTestTrace.SYNC_SRC);
  66         CtfTmfTrace trace2 = CtfTmfTestTraceUtils.getTrace(CtfTestTrace.SYNC_DEST);
  67
  68         ITmfTrace[] traces = { trace1, trace2 };
  69         TmfExperiment experiment = new TmfExperiment(traces[0].getEventType(), EXPERIMENT, traces, BLOCK_SIZE, null);
  70
  71         SynchronizationAlgorithm syncAlgo = experiment.synchronizeTraces(true);
  72
  73         ITmfTimestampTransform tt1 = syncAlgo.getTimestampTransform(trace1);
  74         ITmfTimestampTransform tt2 = syncAlgo.getTimestampTransform(trace2);
  75
  76         trace1.setTimestampTransform(tt1);
  77         trace2.setTimestampTransform(tt2);
  78
  79         assertEquals("TmfTimestampTransformLinearFast [ slope = 0.9999413783703139011056845831168394, offset = 79796507913179.33347660124688298171 ]", tt1.toString());
  80         assertEquals(TimestampTransformFactory.getDefaultTransform(), tt2);
  81
  82         assertEquals(syncAlgo.getTimestampTransform(trace1.getHostId()), trace1.getTimestampTransform());
  83         assertEquals(syncAlgo.getTimestampTransform(trace2.getHostId()), trace2.getTimestampTransform());
  84
  85         trace1.dispose();
  86         trace2.dispose();
  87     }
  88
  89     /**
  90      * Testing synchronization with 3 traces, one of which synchronizes with
  91      * both other
  92      */
  93     @Test
  94     public void testDjangoExperimentSync() {
  95         CtfTmfTrace trace1 = CtfTmfTestTraceUtils.getTrace(CtfTestTrace.DJANGO_CLIENT);
  96         CtfTmfTrace trace2 = CtfTmfTestTraceUtils.getTrace(CtfTestTrace.DJANGO_DB);
  97         CtfTmfTrace trace3 = CtfTmfTestTraceUtils.getTrace(CtfTestTrace.DJANGO_HTTPD);
  98
  99         ITmfTrace[] traces = { trace1, trace2, trace3 };
 100         TmfExperiment experiment = new TmfExperiment(traces[0].getEventType(), EXPERIMENT, traces, BLOCK_SIZE, null);
 101
 102         SynchronizationAlgorithm syncAlgo = experiment.synchronizeTraces(true);
 103
 104         ITmfTimestampTransform tt1 = syncAlgo.getTimestampTransform(trace1);
 105         ITmfTimestampTransform tt2 = syncAlgo.getTimestampTransform(trace2);
 106         ITmfTimestampTransform tt3 = syncAlgo.getTimestampTransform(trace3);
 107
 108         trace1.setTimestampTransform(tt1);
 109         trace2.setTimestampTransform(tt2);
 110         trace3.setTimestampTransform(tt3);
 111
 112         assertEquals(TimestampTransformFactory.getDefaultTransform(), tt1);
 113         assertEquals("TmfTimestampTransformLinearFast [ slope = 0.9999996313017589597204633828681240, offset = 498490309972.0038068817738527724192 ]", tt2.toString());
 114         assertEquals("TmfTimestampTransformLinearFast [ slope = 1.000000119014882262265342419815932, offset = -166652893534.6189900382736187431134 ]", tt3.toString());
 115
 116         trace1.dispose();
 117         trace2.dispose();
 118         trace3.dispose();
 119     }
 120 }