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

prevent connection leak when temporaryServerAddress throws

Browse source
This commit is contained in:
Johannes Rudolph 2013-01-22 16:05:03 +01:00
parent fccf596649
commit 64d832377b
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-io/src/test/scala/akka/io/TestUtils.scala
View file

@ -13,10 +13,11 @@ object TestUtils {
def temporaryServerAddress(address: String = "127.0.0.1"): InetSocketAddress = {
val serverSocket = ServerSocketChannel.open()
serverSocket.socket.bind(new InetSocketAddress(address, 0))
val port = serverSocket.socket.getLocalPort
serverSocket.close()
new InetSocketAddress(address, port)
try {
serverSocket.socket.bind(new InetSocketAddress(address, 0))
val port = serverSocket.socket.getLocalPort
new InetSocketAddress(address, port)
} finally serverSocket.close()
}
def verifyActorTermination(actor: ActorRef)(implicit system: ActorSystem): Unit = {