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

tweaked function names and timeouts

This commit is contained in:
Robinson 2023-09-05 12:56:14 +02:00
parent 2d061220f5
commit 769bad6aac
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -76,7 +76,7 @@ internal class EventPoller {
private var threadId = Thread.currentThread().id
fun inDispatch(): Boolean {
fun isDispatch(): Boolean {
// this only works because we are a single thread dispatch
return threadId == Thread.currentThread().id
}
@ -197,7 +197,7 @@ internal class EventPoller {
*/
fun close(logger: KLogger, endPoint: EndPoint<*>) {
// make sure that we close on the CLOSE dispatcher if we run on the poll dispatcher!
if (inDispatch()) {
if (isDispatch()) {
EventDispatcher.CLOSE.launch {
close(logger, endPoint)
}
@ -242,7 +242,7 @@ internal class EventPoller {
val wasRunning = running
running = false
while (!shutdownLatch.await(100, TimeUnit.MILLISECONDS)) {
while (!shutdownLatch.await(500, TimeUnit.MILLISECONDS)) {
logger.error { "Waiting for Network Event Poller to close. It should not take this long" }
}
configured = false