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

code cleanup

This commit is contained in:
Robinson 2023-08-10 20:03:06 -06:00
parent 77d56b8804
commit 466363901c
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
2 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/dorkbox/network/aeron/EventPoller.kt
View File

@ -238,12 +238,13 @@ internal class EventPoller {
running = false
while (!shutdownLatch.await(200)) {
logger.error { "Waiting for poller to close. It should not take this long" }
logger.error { "Waiting for Network Event Poller to close. It should not take this long" }
}
configured = false
if (wasRunning) {
dispatchScope.cancel("Closed event dispatch")
dispatchScope.cancel("Closed Network Event Poller dispatch")
}
logger.error { "Closed Network Event Poller: wasRunning=$wasRunning" }
}
}

10
src/dorkbox/network/connection/EndPoint.kt
View File

@ -220,20 +220,12 @@ abstract class EndPoint<CONNECTION : Connection> private constructor(val type: C
// NOTE: in the event that we are IPC -- only ONE SERVER can be running IPC at a time for a single driver!
if (type == Server::class.java && config.enableIpc) {
runBlocking {
var configuration = config.copy()
val configuration = config.copy()
if (AeronDriver.isLoaded(configuration, logger)) {
val e = ServerException("Only one server at a time can share a single aeron driver! Make the driver unique or change it's directory: ${configuration.aeronDirectory}")
listenerManager.notifyError(e)
throw e
}
configuration = config.copy()
if (AeronDriver.isRunning(configuration, logger)) {
val e = ServerException("Only one server at a time can share a single aeron driver! Make the driver unique or change it's directory: ${configuration.aeronDirectory}")
listenerManager.notifyError(e)
throw e
}
}
}