raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Terminates actor systems in parallel (#29606)

Browse source
This commit is contained in:
Ignasi Marimon-Clos 2020-09-16 13:33:48 +02:00 • committed by GitHub
parent ffc4235980
commit 5ea4c1751c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-remote/src/test/scala/akka/remote/artery/tcp/ssl/RotatingKeysSSLEngineProviderSpec.scala
View file

@ -25,15 +25,12 @@ import akka.remote.artery.tcp.SSLEngineProviderSetup
import akka.remote.artery.tcp.TlsTcpSpec
import akka.testkit.ImplicitSender
import akka.testkit.TestActors
import akka.testkit.TestDuration
import akka.testkit.TestProbe
import com.typesafe.config.ConfigFactory
import javax.net.ssl.SSLContext
import javax.net.ssl.SSLEngine
import javax.net.ssl.SSLSession
import scala.concurrent.duration._
import scala.concurrent.Await
import scala.concurrent.blocking
import scala.util.control.NonFatal
@ -271,11 +268,9 @@ abstract class RotatingKeysSSLEngineProviderSpec(extraConfig: String)
override def beforeTermination(): Unit = {
systemsToTerminate.foreach { systemToTerminate =>
system.log.info(s"Terminating $systemToTerminate...")
val now = System.nanoTime()
Await.result(systemToTerminate.terminate(), 8.seconds.dilated)
val lasted = System.nanoTime() - now
system.log.info(s"Terminated $systemToTerminate after ${lasted / 1000000} ms")
systemToTerminate.terminate()
}
systemsToTerminate.foreach(shutdown(_, verifySystemShutdown = true))
super.beforeTermination()
}