/*******************************************************************************
- * Copyright (c) 2009, 2013 Ericsson
+ * Copyright (c) 2009, 2014 Ericsson
*
* All rights reserved. This program and the accompanying materials are
* made available under the terms of the Eclipse Public License v1.0 which
import java.io.IOException;
import java.net.URISyntaxException;
import java.net.URL;
-import java.util.Map;
import java.util.Vector;
import org.eclipse.core.resources.IFile;
import org.eclipse.linuxtools.tmf.core.analysis.IAnalysisModule;
import org.eclipse.linuxtools.tmf.core.event.ITmfEvent;
import org.eclipse.linuxtools.tmf.core.exceptions.TmfTraceException;
+import org.eclipse.linuxtools.tmf.core.request.ITmfEventRequest;
import org.eclipse.linuxtools.tmf.core.request.ITmfEventRequest.ExecutionType;
import org.eclipse.linuxtools.tmf.core.request.TmfEventRequest;
-import org.eclipse.linuxtools.tmf.core.statistics.ITmfStatistics;
import org.eclipse.linuxtools.tmf.core.tests.TmfCoreTestPlugin;
import org.eclipse.linuxtools.tmf.core.tests.shared.TmfTestTrace;
import org.eclipse.linuxtools.tmf.core.timestamp.TmfTimeRange;
assertEquals("getEndTime", NB_EVENTS, timeRange.getEndTime().getValue());
}
+ // ------------------------------------------------------------------------
+ // Experiment setup
+ // ------------------------------------------------------------------------
+
+ @Test
+ public void testExperimentInitialization() {
+ /*
+ * Calling default constructor, then init should be equivalent to
+ * calling the full constructor
+ */
+
+ TmfExperimentStub experiment = new TmfExperimentStub();
+ experiment.initExperiment(ITmfEvent.class, EXPERIMENT, fTestTraces, 5000, null);
+ experiment.getIndexer().buildIndex(0, TmfTimeRange.ETERNITY, true);
+
+ assertEquals("GetId", EXPERIMENT, fExperiment.getName());
+ assertEquals("GetNbEvents", NB_EVENTS, fExperiment.getNbEvents());
+
+ final long nbExperimentEvents = fExperiment.getNbEvents();
+ assertEquals("GetNbEvents", NB_EVENTS, nbExperimentEvents);
+
+ final long nbTraceEvents = fExperiment.getTraces()[0].getNbEvents();
+ assertEquals("GetNbEvents", NB_EVENTS, nbTraceEvents);
+
+ final TmfTimeRange timeRange = fExperiment.getTimeRange();
+ assertEquals("getStartTime", 1, timeRange.getStartTime().getValue());
+ assertEquals("getEndTime", NB_EVENTS, timeRange.getEndTime().getValue());
+ }
+
// ------------------------------------------------------------------------
// getTimestamp
// ------------------------------------------------------------------------
// State system, statistics and modules methods
// ------------------------------------------------------------------------
- @Test
- public void testGetStatistics() {
- /* There should not be any experiment-specific statistics */
- ITmfStatistics stats = fExperiment.getStatistics();
- assertNull(stats);
- }
-
@Test
public void testGetAnalysisModules() {
/* There should not be any modules at this point */
- Map<String, IAnalysisModule> modules = fExperiment.getAnalysisModules();
- assertTrue(modules.isEmpty());
+ Iterable<IAnalysisModule> modules = fExperiment.getAnalysisModules();
+ assertFalse(modules.iterator().hasNext());
}
// ------------------------------------------------------------------------
@Test
public void testProcessRequestForNbEvents() throws InterruptedException {
final int nbEvents = 1000;
- final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
+ final Vector<ITmfEvent> requestedEvents = new Vector<>();
final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class,
@Test
public void testProcessRequestForAllEvents() throws InterruptedException {
- final int nbEvents = TmfEventRequest.ALL_DATA;
- final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
+ final int nbEvents = ITmfEventRequest.ALL_DATA;
+ final Vector<ITmfEvent> requestedEvents = new Vector<>();
final long nbExpectedEvents = NB_EVENTS;
final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
public void testCancel() throws InterruptedException {
final int nbEvents = NB_EVENTS;
final int limit = BLOCK_SIZE;
- final Vector<ITmfEvent> requestedEvents = new Vector<ITmfEvent>();
+ final Vector<ITmfEvent> requestedEvents = new Vector<>();
final TmfTimeRange range = new TmfTimeRange(TmfTimestamp.BIG_BANG, TmfTimestamp.BIG_CRUNCH);
final TmfEventRequest request = new TmfEventRequest(ITmfEvent.class,