aboutsummaryrefslogtreecommitdiff
path: root/src/test/scala/firrtlTests/MultiThreadingSpec.scala
diff options
context:
space:
mode:
authorchick2020-08-14 19:47:53 -0700
committerJack Koenig2020-08-14 19:47:53 -0700
commit6fc742bfaf5ee508a34189400a1a7dbffe3f1cac (patch)
tree2ed103ee80b0fba613c88a66af854ae9952610ce /src/test/scala/firrtlTests/MultiThreadingSpec.scala
parentb516293f703c4de86397862fee1897aded2ae140 (diff)
All of src/ formatted with scalafmt
Diffstat (limited to 'src/test/scala/firrtlTests/MultiThreadingSpec.scala')
-rw-r--r--src/test/scala/firrtlTests/MultiThreadingSpec.scala15
1 files changed, 8 insertions, 7 deletions
diff --git a/src/test/scala/firrtlTests/MultiThreadingSpec.scala b/src/test/scala/firrtlTests/MultiThreadingSpec.scala
index c7b18624..6ec1a2bd 100644
--- a/src/test/scala/firrtlTests/MultiThreadingSpec.scala
+++ b/src/test/scala/firrtlTests/MultiThreadingSpec.scala
@@ -24,7 +24,8 @@ class MultiThreadingSpec extends FirrtlPropSpec {
new firrtl.HighFirrtlCompiler,
new firrtl.MiddleFirrtlCompiler,
new firrtl.LowFirrtlCompiler,
- new firrtl.VerilogCompiler)
+ new firrtl.VerilogCompiler
+ )
val inputFilePath = s"/integration/GCDTester.fir" // arbitrary
val numThreads = 64 // arbitrary
@@ -35,20 +36,20 @@ class MultiThreadingSpec extends FirrtlPropSpec {
import ExecutionContext.Implicits.global
try { // Use try-catch because error can manifest in many ways
// Execute for each compiler
- val compilerResults = compilers map { compiler =>
+ val compilerResults = compilers.map { compiler =>
// Run compiler serially once
val serialResult = runCompiler(inputStrings, compiler)
Future {
- val threadFutures = (0 until numThreads) map { i =>
- Future {
- runCompiler(inputStrings, compiler) == serialResult
- }
+ val threadFutures = (0 until numThreads).map { i =>
+ Future {
+ runCompiler(inputStrings, compiler) == serialResult
}
+ }
Await.result(Future.sequence(threadFutures), Duration.Inf)
}
}
val results = Await.result(Future.sequence(compilerResults), Duration.Inf)
- assert(results.flatten reduce (_ && _)) // check all true (ie. success)
+ assert(results.flatten.reduce(_ && _)) // check all true (ie. success)
} catch {
case _: Throwable => fail("The Compiler is not thread safe")
}