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

getting the aeron log location is now static public.

Browse Source
This commit is contained in:
Robinson 2023-05-28 17:03:05 +02:00
parent 4df378e8d4
commit e1997eb8cc
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 37 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/dorkbox/network/Configuration.kt
View File

@ -199,6 +199,42 @@ abstract class Configuration {
else -> { true }
}
}
/**
* Depending on the OS, different base locations for the Aeron log directory are preferred.
*/
fun defaultAeronLogLocation(logger: KLogger = NOP_LOGGER): File {
return when {
OS.isMacOsX -> {
// does the recommended location exist??
// Default is to try the RAM drive
val suggestedLocation = File("/Volumes/DevShm")
if (suggestedLocation.exists()) {
suggestedLocation
}
else {
if (logger !== NOP_LOGGER) {
if (!alreadyShownTempFsTips) {
alreadyShownTempFsTips = true
logger.info(
"It is recommended to create a RAM drive for best performance. For example\n" + "\$ diskutil erasevolume HFS+ \"DevShm\" `hdiutil attach -nomount ram://\$((2048 * 2048))`"
)
}
}
OS.TEMP_DIR
}
}
OS.isLinux -> {
// this is significantly faster for linux than using the temp dir
File("/dev/shm/")
}
else -> {
OS.TEMP_DIR
}
}
}
}
/**
@ -596,42 +632,6 @@ abstract class Configuration {
internal var contextDefined: Boolean = false
/**
* Depending on the OS, different base locations for the Aeron log directory are preferred.
*/
private fun suggestAeronLogLocation(logger: KLogger): File {
return when {
OS.isMacOsX -> {
// does the recommended location exist??
// Default is to try the RAM drive
val suggestedLocation = File("/Volumes/DevShm")
if (suggestedLocation.exists()) {
suggestedLocation
}
else {
if (logger !== NOP_LOGGER) {
if (!alreadyShownTempFsTips) {
alreadyShownTempFsTips = true
logger.info(
"It is recommended to create a RAM drive for best performance. For example\n" + "\$ diskutil erasevolume HFS+ \"DevShm\" `hdiutil attach -nomount ram://\$((2048 * 2048))`"
)
}
}
OS.TEMP_DIR
}
}
OS.isLinux -> {
// this is significantly faster for linux than using the temp dir
File("/dev/shm/")
}
else -> {
OS.TEMP_DIR
}
}
}
/**
* Validates the current configuration. Throws an exception if there are problems.
*/
@ -742,7 +742,7 @@ abstract class Configuration {
*/
var dir = aeronDirectory
if (dir == null) {
val baseFileLocation = suggestAeronLogLocation(logger)
val baseFileLocation = defaultAeronLogLocation(logger)
val aeronLogDirectory = if (uniqueAeronDirectory) {
// this is incompatible with IPC, and will not be set if IPC is enabled (error will be thrown on validate)
File(baseFileLocation, "aeron_${mediaDriverId()}")