Properly instantiate models

Author: ckittl

src/main/scala/edu/ie3/simbench/actor/Converter.scala

@@ -45,6 +45,7 @@ object Converter {
           targetDirectory,
           csvColumnSeparator,
           compress,
+          amountOfMutatorWorkers,
           converter
         )
         ) =>
@@ -57,6 +58,7 @@ object Converter {
         targetDirectory,
         csvColumnSeparator,
         compress,
+        amountOfMutatorWorkers,
         ctx
       )
       initializing(
@@ -429,6 +431,7 @@ object Converter {
       targetDirectory: String,
       csvColumnSeparator: String,
       compress: Boolean,
+      amountOfWorkers: Int,
       ctx: ActorContext[ConverterMessage]
   ): Unit = {
     val mutator = ctx.spawn(Mutator(), s"mutator_$simBenchCode")
@@ -438,6 +441,7 @@ object Converter {
       targetDirectory,
       csvColumnSeparator,
       compress,
+      amountOfWorkers,
       ctx.self
     )
     ctx.watchWith(mutator, MutatorTerminated)
@@ -680,6 +684,7 @@ object Converter {
       targetDirectory: String,
       csvColumnSeparator: String,
       compressConverted: Boolean,
+      amountOfMutatorWorkers: Int,
       replyTo: ActorRef[Coordinator.CoordinatorMessage]
   ) extends ConverterMessage
 

src/main/scala/edu/ie3/simbench/actor/Coordinator.scala

@@ -30,7 +30,8 @@ object Coordinator {
             config.io.output.csv.directoryHierarchy,
             config.io.output.targetFolder,
             config.io.output.csv.separator,
-            config.io.output.compress
+            config.io.output.compress,
+            config.io.output.workers
           )
           val initializingConverters = List(firstSimBenchCode)
 
@@ -49,7 +50,8 @@ object Coordinator {
             config.io.output.csv.directoryHierarchy,
             config.io.output.targetFolder,
             config.io.output.csv.separator,
-            config.io.output.compress
+            config.io.output.compress,
+            config.io.output.workers
           )
 
           idle(stateData)
@@ -101,7 +103,8 @@ object Coordinator {
             stateData.useDirectoryHierarchy,
             stateData.targetDirectory,
             stateData.csvColumnSeparator,
-            stateData.compressConverted
+            stateData.compressConverted,
+            stateData.amountOfMutatorWorkers
           )
           val yetInitializingConverters = stateData.initializingConverters :+ nextSimBenchCode
           idle(
@@ -135,7 +138,8 @@ object Coordinator {
       useDirectoryHierarchy: Boolean,
       targetDirectory: String,
       csvColumnSeparator: String,
-      compressConverted: Boolean
+      compressConverted: Boolean,
+      amountOfMutatorWorkers: Int
   ): Unit = {
     val converter = ctx.spawn(Converter(), s"converter_$simBenchCode")
     converter ! Converter.Init(
@@ -152,6 +156,7 @@ object Coordinator {
       targetDirectory,
       csvColumnSeparator,
       compressConverted,
+      amountOfMutatorWorkers,
       ctx.self
     )
   }
@@ -171,7 +176,8 @@ object Coordinator {
       useDirectoryHierarchy: Boolean,
       targetDirectory: String,
       csvColumnSeparator: String,
-      compressConverted: Boolean
+      compressConverted: Boolean,
+      amountOfMutatorWorkers: Int
   )
 
   /** Messages, a coordinator will understand */

src/test/scala/edu/ie3/test/common/ConfigTestData.scala

@@ -17,7 +17,8 @@ trait ConfigTestData {
   val validIoOutputConfig = new SimbenchConfig.Io.Output(
     false,
     new config.SimbenchConfig.CsvConfig(false, "UTF-8", ".csv", ";"),
-    "convertedData"
+    "convertedData",
+    20
   )
 
   val validIo = new SimbenchConfig.Io(