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

modified delayLingerTimeout() to be more intelligent with regards to the delay linger timeout

This commit is contained in:
Robinson 2023-10-18 20:00:54 +02:00
parent cfc08a2f4b
commit a15478c535
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/dorkbox/network/aeron/AeronDriverInternal.kt
View File

@ -125,6 +125,9 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, config: Configuration
@Volatile
internal var mustRestartDriverOnError = false
@Volatile
private var closedTime = 0L
@Volatile
private var closed = false
@ -1011,6 +1014,7 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, config: Configuration
logger.debug("Aeron Driver [$driverId]: Closed the media driver at '${driverDirectory}'")
}
closed = true
closedTime = System.nanoTime()
return@write true
}
@ -1136,10 +1140,22 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, config: Configuration
}
/**
* Make sure that we DO NOT approach the Aeron linger timeout!
* Make sure that we DO NOT approach the Aeron linger timeout! If we have already passed it, do nothing.
*/
fun delayLingerTimeout(multiplier: Number = 1) {
Thread.sleep(driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds((lingerNs() * multiplier.toDouble()).toLong())) )
val lingerTimeoutNs = (lingerNs() * multiplier.toDouble()).toLong()
val driverTimeoutSec = driverTimeout().coerceAtLeast(TimeUnit.NANOSECONDS.toSeconds(lingerTimeoutNs))
val driverTimeoutNs = TimeUnit.SECONDS.toNanos(driverTimeoutSec)
val elapsedNs = System.nanoTime() - closedTime
if (elapsedNs >= driverTimeoutNs) {
// timeout already expired, do nothing.
return
}
// not always the full duration, but the duration since the close event
val adjustedTimeoutSec = TimeUnit.NANOSECONDS.toSeconds(driverTimeoutNs - elapsedNs)
Thread.sleep(adjustedTimeoutSec)
}
override fun equals(other: Any?): Boolean {