Add 'runOperationsAsyncronously' param to DistributedOptions

JetBrains · olgalupuleac · Dec 1, 2020 · Dec 1, 2020 · Dec 7, 2020 · Dec 9, 2020
commit ccaf23d379f46ed25169c20cf530668e9ddff947
diff --git a/src/jvm/main/org/jetbrains/kotlinx/lincheck/distributed/DistributedCTestConfiguration.kt b/src/jvm/main/org/jetbrains/kotlinx/lincheck/distributed/DistributedCTestConfiguration.kt
@@ -43,6 +43,7 @@ class DistributedCTestConfiguration<Message, Log>(testClass: Class<*>, iteration
                                                   val supportRecovery: Boolean,
                                                   val messageDuplication: Boolean,
                                                   val networkPartitions : Boolean,
+                                                  val asyncRun : Boolean,
                                                   val nodeTypes: HashMap<Class<out Node<Message>>, Int>,
                                                   requireStateEquivalenceCheck: Boolean,
                                                   minimizeFailedScenario: Boolean,

diff --git a/src/jvm/main/org/jetbrains/kotlinx/lincheck/distributed/DistributedOptions.kt b/src/jvm/main/org/jetbrains/kotlinx/lincheck/distributed/DistributedOptions.kt
@@ -21,6 +21,7 @@ class DistributedOptions<Message, Log> : Options<DistributedOptions<Message, Log
     private var networkPartitions: Boolean = false
     private var testClasses = HashMap<Class<out Node<Message>>, Int>()
     private var useVectorClock = false
+    private var asyncRun = false
 
     fun networkReliable(isReliable: Boolean): DistributedOptions<Message, Log> {
         this.isNetworkReliable = isReliable
@@ -57,6 +58,11 @@ class DistributedOptions<Message, Log> : Options<DistributedOptions<Message, Log
         return this
     }
 
+    fun runOperationsAsynchronously(asyncRun: Boolean): DistributedOptions<Message, Log> {
+        this.asyncRun = asyncRun
+        return this
+    }
+
     fun networkPartitions(partitions: Boolean): DistributedOptions<Message, Log> {
         this.networkPartitions = partitions
         return this
@@ -73,7 +79,7 @@ class DistributedOptions<Message, Log> : Options<DistributedOptions<Message, Log
             actorsPerThread, executionGenerator,
             verifier, invocationsPerIteration, isNetworkReliable,
             messageOrder, maxNumberOfFailedNodes, supportRecovery,
-            messageDuplication, networkPartitions, testClasses,
+            messageDuplication, networkPartitions, asyncRun, testClasses,
             requireStateEquivalenceImplementationCheck, false,
             chooseSequentialSpecification(sequentialSpecification, testClass), timeoutMs
         )