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

More clear logging/checking when closing the poller

Browse Source
This commit is contained in:
Robinson 2023-06-07 11:44:52 +02:00
parent 6bbab72ca7
commit ebc7b1cd76
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -180,12 +180,14 @@ internal class EventPoller {
// when an endpoint closes its polling, it will automatically be removed from this datastructure.
val cEvents = configureEvents.decrementAndGet()
val pEvents = pollEvents.size()
if (running && submitEvents.value == 0 && cEvents == 0 && pEvents == 0) {
val sEvents = submitEvents.value
if (running && sEvents == 0 && cEvents == 0 && pEvents == 0) {
logger.debug { "Closing the Network Event Poller..." }
running = false
true
} else {
logger.debug { "Not closing the Network Event Poller... (isRunning=$running submitEvents=${submitEvents.value} configureEvents=${cEvents} pollEvents=$pEvents)" }
logger.debug { "Not closing the Network Event Poller... (isRunning=$running submitEvents=$sEvents configureEvents=${cEvents} pollEvents=$pEvents)" }
false
}
}