Switch to using our own quasar fork with thread leak fix (#2443)

* Switch to using our own quasar fork with thread leak fix

* Update quasar.jar in lib

* Review changes

* Bump to 3.0.7

build.gradle

@@ -13,7 +13,9 @@ buildscript {
     //
     // TODO: Sort this alphabetically.
     ext.kotlin_version = constants.getProperty("kotlinVersion")
-    ext.quasar_version = '0.7.9'
+    // use our fork of quasar
+    ext.quasar_group = 'com.github.corda.quasar'
+    ext.quasar_version = '7629695563deae6cc95adcfbebcbc8322fd0241a'
 
     // gradle-capsule-plugin:1.0.2 contains capsule:1.0.1
     // TODO: Upgrade gradle-capsule-plugin to a version with capsule:1.0.3

confidential-identities/build.gradle

@@ -14,7 +14,7 @@ dependencies {
     compile project(':core')
 
     // Quasar, for suspendable fibres.
-    compileOnly "co.paralleluniverse:quasar-core:$quasar_version:jdk8"
+    compileOnly "$quasar_group:quasar-core:$quasar_version:jdk8"
 
     testCompile "org.jetbrains.kotlin:kotlin-test:$kotlin_version"
     testCompile "junit:junit:$junit_version"

constants.properties

@@ -1,4 +1,4 @@
-gradlePluginsVersion=3.0.6
+gradlePluginsVersion=3.0.7
 kotlinVersion=1.2.20
 platformVersion=2
 guavaVersion=21.0

core/build.gradle

@@ -75,7 +75,7 @@ dependencies {
     testCompile "org.jetbrains.kotlin:kotlin-test:$kotlin_version"
 
     // Quasar, for suspendable fibres.
-    compileOnly "co.paralleluniverse:quasar-core:$quasar_version:jdk8"
+    compileOnly "$quasar_group:quasar-core:$quasar_version:jdk8"
 
     // Thread safety annotations
     compile "com.google.code.findbugs:jsr305:$jsr305_version"

experimental/kryo-hook/build.gradle

@@ -34,7 +34,7 @@ dependencies {
     compile "org.jetbrains.kotlin:kotlin-reflect:$kotlin_version"
     compile "javassist:javassist:$javaassist_version"
     compile "com.esotericsoftware:kryo:4.0.0"
-    compile "co.paralleluniverse:quasar-core:$quasar_version:jdk8"
+    compile "$quasar_group:quasar-core:$quasar_version:jdk8"
 }
 
 jar {

gradle-plugins/quasar-utils/src/main/groovy/net/corda/plugins/QuasarPlugin.groovy

@@ -13,7 +13,7 @@ class QuasarPlugin implements Plugin<Project> {
         project.configurations.create("quasar")
 //        To add a local .jar dependency:
 //        project.dependencies.add("quasar", project.files("${project.rootProject.projectDir}/lib/quasar.jar"))
-        project.dependencies.add("quasar", "co.paralleluniverse:quasar-core:${project.rootProject.ext.quasar_version}:jdk8@jar")
+        project.dependencies.add("quasar", "${project.rootProject.ext.quasar_group}:quasar-core:${project.rootProject.ext.quasar_version}:jdk8@jar")
         project.dependencies.add("runtime", project.configurations.getByName("quasar"))
 
         project.tasks.withType(Test) {

node/src/main/kotlin/net/corda/node/services/statemachine/StateMachineManagerImpl.kt

@@ -211,6 +211,7 @@ class StateMachineManagerImpl(
         liveFibers.await()
         checkpointCheckerThread?.let { MoreExecutors.shutdownAndAwaitTermination(it, 5, SECONDS) }
         check(!unrestorableCheckpoints) { "Unrestorable checkpoints where created, please check the logs for details." }
+        scheduler.shutdown()
     }
 
     /**