#3371 - using a new port for each of the TcpConnectionSpec tests to avoid races with reuse of port numbers
This commit is contained in:
parent
336fb1b180
commit
76df8e60d5
1 changed files with 1 additions and 2 deletions
|
|
@ -24,8 +24,6 @@ import akka.util.{ Helpers, ByteString }
|
||||||
import akka.TestUtils._
|
import akka.TestUtils._
|
||||||
|
|
||||||
class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms") {
|
class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms") {
|
||||||
val serverAddress = temporaryServerAddress()
|
|
||||||
|
|
||||||
// Helper to avoid Windows localization specific differences
|
// Helper to avoid Windows localization specific differences
|
||||||
def ignoreIfWindows(): Unit =
|
def ignoreIfWindows(): Unit =
|
||||||
if (Helpers.isWindows) {
|
if (Helpers.isWindows) {
|
||||||
|
|
@ -705,6 +703,7 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
|
||||||
}
|
}
|
||||||
|
|
||||||
abstract class LocalServerTest extends ChannelRegistry {
|
abstract class LocalServerTest extends ChannelRegistry {
|
||||||
|
val serverAddress = temporaryServerAddress()
|
||||||
val localServerChannel = ServerSocketChannel.open()
|
val localServerChannel = ServerSocketChannel.open()
|
||||||
val userHandler = TestProbe()
|
val userHandler = TestProbe()
|
||||||
val selector = TestProbe()
|
val selector = TestProbe()
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue