dorkbox
/
Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

disconnect period is as short as possible to improve unit test performance

This commit is contained in:
Robinson 2023-11-13 14:15:13 +01:00
parent 8e32e0980c
commit bae5b41d1c
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 22 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
test/dorkboxTest/network/DisconnectReconnectTest.kt
View File

@ -29,7 +29,7 @@ import org.slf4j.LoggerFactory
import java.util.concurrent.* import java.util.concurrent.*
class DisconnectReconnectTest : BaseTest() { class DisconnectReconnectTest : BaseTest() {
private val reconnects = 2 private val reconnects = 5
@Test @Test
fun reconnectClient() { fun reconnectClient() {
@ -37,9 +37,10 @@ class DisconnectReconnectTest : BaseTest() {
val reconnectCount = atomic(0) val reconnectCount = atomic(0)
val server = run { val server = run {
val configuration = serverConfig() val config = serverConfig()
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val server: Server<Connection> = Server(configuration) val server: Server<Connection> = Server(config)
addEndPoint(server) addEndPoint(server)
server.onConnect { server.onConnect {
@ -55,6 +56,7 @@ class DisconnectReconnectTest : BaseTest() {
val client = run { val client = run {
val config = clientConfig() val config = clientConfig()
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client: Client<Connection> = Client(config) val client: Client<Connection> = Client(config)
addEndPoint(client) addEndPoint(client)
@ -90,11 +92,13 @@ class DisconnectReconnectTest : BaseTest() {
val reconnectCount = atomic(0) val reconnectCount = atomic(0)
val server = run { val server = run {
val configuration = serverConfig { val config = serverConfig {
uniqueAeronDirectory = true uniqueAeronDirectory = true
} }
val server: Server<Connection> = Server(configuration) config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val server: Server<Connection> = Server(config)
addEndPoint(server) addEndPoint(server)
server server
} }
@ -104,6 +108,8 @@ class DisconnectReconnectTest : BaseTest() {
uniqueAeronDirectory = true uniqueAeronDirectory = true
} }
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client: Client<Connection> = Client(config) val client: Client<Connection> = Client(config)
addEndPoint(client) addEndPoint(client)
@ -164,6 +170,7 @@ class DisconnectReconnectTest : BaseTest() {
val server = run { val server = run {
val config = serverConfig() val config = serverConfig()
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
config.serialization.rmi.register(CloseIface::class.java) config.serialization.rmi.register(CloseIface::class.java)
val server: Server<Connection> = Server(config) val server: Server<Connection> = Server(config)
@ -190,6 +197,7 @@ class DisconnectReconnectTest : BaseTest() {
val client = run { val client = run {
val config = clientConfig() val config = clientConfig()
config.serialization.rmi.register(CloseIface::class.java, CloseImpl::class.java) config.serialization.rmi.register(CloseIface::class.java, CloseImpl::class.java)
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client: Client<Connection> = Client(config) val client: Client<Connection> = Client(config)
addEndPoint(client) addEndPoint(client)
@ -234,8 +242,10 @@ class DisconnectReconnectTest : BaseTest() {
aeronDriver.start() aeronDriver.start()
val server = run { val server = run {
val serverConfiguration = serverConfig() val config = serverConfig()
val server: Server<Connection> = Server(serverConfiguration) config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val server: Server<Connection> = Server(config)
addEndPoint(server, false) addEndPoint(server, false)
server.onConnect { server.onConnect {
@ -251,6 +261,7 @@ class DisconnectReconnectTest : BaseTest() {
val client = run { val client = run {
val config = clientConfig() val config = clientConfig()
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client: Client<Connection> = Client(config) val client: Client<Connection> = Client(config)
addEndPoint(client, false) addEndPoint(client, false)
@ -296,6 +307,7 @@ class DisconnectReconnectTest : BaseTest() {
val server = run { val server = run {
val config = serverConfig() val config = serverConfig()
config.enableIpc = false config.enableIpc = false
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val server: Server<Connection> = Server(config) val server: Server<Connection> = Server(config)
addEndPoint(server) addEndPoint(server)
@ -314,6 +326,7 @@ class DisconnectReconnectTest : BaseTest() {
val client = run { val client = run {
val config = clientConfig() val config = clientConfig()
config.enableIpc = true config.enableIpc = true
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client: Client<Connection> = Client(config) val client: Client<Connection> = Client(config)
addEndPoint(client) addEndPoint(client)
@ -350,6 +363,7 @@ class DisconnectReconnectTest : BaseTest() {
val config = serverConfig() val config = serverConfig()
config.enableIpc = false config.enableIpc = false
config.uniqueAeronDirectory = true config.uniqueAeronDirectory = true
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val server = Server<Connection>(config) val server = Server<Connection>(config)
addEndPoint(server) addEndPoint(server)
@ -364,6 +378,7 @@ class DisconnectReconnectTest : BaseTest() {
val config = clientConfig() val config = clientConfig()
config.enableIpc = false config.enableIpc = false
config.uniqueAeronDirectory = true config.uniqueAeronDirectory = true
config.connectionCloseTimeoutInSeconds = 0 // we want the unit test to go fast (there will be a limit with aeron linger, etc)
val client = Client<Connection>(config) val client = Client<Connection>(config)
addEndPoint(client) addEndPoint(client)