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

code cleanup

This commit is contained in:
Robinson 2023-08-09 22:12:24 -06:00
parent 19b36bde9f
commit 1ded010b89
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/dorkbox/network/aeron/AeronDriver.kt
View File

@ -516,6 +516,7 @@ class AeronDriver private constructor(config: Configuration, val logger: KLogger
}
}
/**
* This does TWO things
* - start the media driver if not already running
@ -672,7 +673,7 @@ class AeronDriver private constructor(config: Configuration, val logger: KLogger
*
* @return true if the media driver was explicitly closed
*/
suspend fun closed() = internal.closed()
fun closed() = internal.closed()
/**
* Checks to see if there are any critical network errors (for example, a VPN connection getting disconnected while running)

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

@ -44,7 +44,7 @@ import java.net.BindException
import java.net.SocketException
import java.util.concurrent.*
internal class AeronDriverInternal(endPoint: EndPoint<*>?, private val config: Configuration.MediaDriverConfig, logger: KLogger) {
internal class AeronDriverInternal(endPoint: EndPoint<*>?, config: Configuration.MediaDriverConfig, logger: KLogger) {
companion object {
// on close, the publication CAN linger (in case a client goes away, and then comes back)
// AERON_PUBLICATION_LINGER_TIMEOUT, 5s by default (this can also be set as a URI param)
@ -98,7 +98,7 @@ internal class AeronDriverInternal(endPoint: EndPoint<*>?, private val config: C
val driverId = config.mediaDriverId()
private val endPointUsages = mutableListOf<EndPoint<*>>()
internal val endPointUsages = mutableListOf<EndPoint<*>>()
@Volatile
private var aeron: Aeron? = null