fixed KiekerLoadDriver

.settings/edu.umd.cs.findbugs.core.prefs

 #FindBugs User Preferences
-#Wed Dec 17 15:04:09 CET 2014
+#Fri Dec 19 10:27:19 CET 2014
 detector_threshold=3
 effort=max
 excludefilter0=.fbExcludeFilterFile|true

src/main/java/util/KiekerLoadDriver.java

@@ -34,14 +34,15 @@ import kieker.common.util.registry.Registry;
 public class KiekerLoadDriver {
 
 	private final List<IMonitoringRecord> elementCollection = new LinkedList<IMonitoringRecord>();
+	private final IPipeFactory intraThreadPipeFactory;
 	private final RunnableStage runnableStage;
+
 	private long[] timings;
-	private final IPipeFactory intraThreadPipeFactory;
 
 	public KiekerLoadDriver(final File directory) {
+		intraThreadPipeFactory = PipeFactoryRegistry.INSTANCE.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false);
 		Stage producerPipeline = this.buildProducerPipeline(directory);
 		runnableStage = new RunnableStage(producerPipeline);
-		intraThreadPipeFactory = PipeFactoryRegistry.INSTANCE.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false);
 	}
 
 	private Stage buildProducerPipeline(final File directory) {

src/main/resources/pipe-factories.conf

+teetime.framework.pipe.SingleElementPipeFactory
+teetime.framework.pipe.OrderedGrowableArrayPipeFactory
+teetime.framework.pipe.UnorderedGrowablePipeFactory
+teetime.framework.pipe.SpScPipeFactory
\ No newline at end of file

src/performancetest/java/teetime/examples/traceReductionWithThreads/ChwWorkTcpTraceReductionAnalysisWithThreadsTest.java

@@ -148,30 +148,30 @@ public class ChwWorkTcpTraceReductionAnalysisWithThreadsTest {
 	}
 
 	public static void main(final String[] args) {
-		ChwWorkTcpTraceReductionAnalysisWithThreadsTest analysis = new ChwWorkTcpTraceReductionAnalysisWithThreadsTest();
-		analysis.before();
+		ChwWorkTcpTraceReductionAnalysisWithThreadsTest analysisTest = new ChwWorkTcpTraceReductionAnalysisWithThreadsTest();
+		analysisTest.before();
 		try {
-			analysis.performAnalysisWith1Thread();
+			analysisTest.performAnalysisWith1Thread();
 		} catch (Exception e) {
 			System.err.println(e);
 		}
-		analysis.after();
+		analysisTest.after();
 
-		analysis.before();
+		analysisTest.before();
 		try {
-			analysis.performAnalysisWith2Threads();
+			analysisTest.performAnalysisWith2Threads();
 		} catch (Exception e) {
 			System.err.println(e);
 		}
-		analysis.after();
+		analysisTest.after();
 
-		analysis.before();
+		analysisTest.before();
 		try {
-			analysis.performAnalysisWith4Threads();
+			analysisTest.performAnalysisWith4Threads();
 		} catch (Exception e) {
 			System.err.println(e);
 		}
-		analysis.after();
+		analysisTest.after();
 	}
 
 }