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

Removed delayed close from event poller

This commit is contained in:
Robinson 2023-10-24 12:06:55 +02:00
parent 2270b815b4
commit 14544d3296
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -64,9 +64,6 @@ internal class EventPoller {
private val submitEvents = atomic(0)
private val configureEventsEndpoints = mutableSetOf<ByteArrayWrapper>()
@Volatile
private var delayClose = false
@Volatile
private var shutdownLatch = CountDownLatch(0)
@ -92,7 +89,6 @@ internal class EventPoller {
logger.trace("Configuring the Network Event Poller...")
}
delayClose = false
running = true
configured = true
shutdownLatch = CountDownLatch(1)
@ -119,11 +115,6 @@ internal class EventPoller {
// remove our event, it is no longer valid
pollEvents.remove(this)
it.onClose() // shutting down
// check to see if we requested a shutdown
if (delayClose) {
doClose(eventLogger)
}
} else if (poll > 0) {
pollCount += poll
}
@ -133,11 +124,6 @@ internal class EventPoller {
// remove our event, it is no longer valid
pollEvents.remove(this)
it.onClose() // shutting down
// check to see if we requested a shutdown
if (delayClose) {
doClose(eventLogger)
}
}
}
@ -226,11 +212,6 @@ internal class EventPoller {
logger.debug("Closing the Network Event Poller...")
doClose(logger)
}
1 -> {
// this means we are trying to close on our poll event, and obviously it won't work.
logger.debug("Delayed closing the Network Event Poller...")
delayClose = true
}
else -> {
if (logger.isDebugEnabled) {
logger.debug("Not closing the Network Event Poller... (isRunning=$running submitEvents=$sEvents configureEvents=${cEvents} pollEvents=$pEvents)")