Removed timeout for waiting for threads (it should close naturally, otherwise there are problems)
This commit is contained in:
parent
0b12f36507
commit
25c20fbf3f
@ -205,6 +205,8 @@ abstract class BaseTest {
|
|||||||
/**
|
/**
|
||||||
* Wait for network client/server threads to shutdown for the specified time.
|
* Wait for network client/server threads to shutdown for the specified time.
|
||||||
*
|
*
|
||||||
|
* it should close as close to naturally as possible, otherwise there are problems
|
||||||
|
*
|
||||||
* @param stopAfterSeconds how many seconds to wait, the default is 2 minutes.
|
* @param stopAfterSeconds how many seconds to wait, the default is 2 minutes.
|
||||||
*/
|
*/
|
||||||
fun waitForThreads(stopAfterSeconds: Long = AUTO_FAIL_TIMEOUT) {
|
fun waitForThreads(stopAfterSeconds: Long = AUTO_FAIL_TIMEOUT) {
|
||||||
|
@ -115,7 +115,7 @@ class MultipleServerTest : BaseTest() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
waitForThreads(30)
|
waitForThreads()
|
||||||
|
|
||||||
didSend.forEach {
|
didSend.forEach {
|
||||||
assertTrue(it.get())
|
assertTrue(it.get())
|
||||||
|
@ -118,7 +118,7 @@ class RmiSpamAsyncTest : BaseTest() {
|
|||||||
client.connect()
|
client.connect()
|
||||||
}
|
}
|
||||||
|
|
||||||
waitForThreads(200)
|
waitForThreads()
|
||||||
Assert.assertEquals(totalRuns.toLong(), counter.get())
|
Assert.assertEquals(totalRuns.toLong(), counter.get())
|
||||||
client.logger.error("kryos generated: ${client.config.serialization.getInitializedKryoCount()}")
|
client.logger.error("kryos generated: ${client.config.serialization.getInitializedKryoCount()}")
|
||||||
server.logger.error("kryos generated: ${server.config.serialization.getInitializedKryoCount()}")
|
server.logger.error("kryos generated: ${server.config.serialization.getInitializedKryoCount()}")
|
||||||
|
Loading…
Reference in New Issue
Block a user