update dependencies
This commit is contained in:
parent
ef9f559833
commit
98f8ad794e
|
@ -33,7 +33,7 @@ import org.agrona.SystemUtil
|
||||||
import org.agrona.concurrent.AgentTerminationException
|
import org.agrona.concurrent.AgentTerminationException
|
||||||
import java.io.File
|
import java.io.File
|
||||||
import java.net.BindException
|
import java.net.BindException
|
||||||
import java.util.concurrent.TimeUnit
|
import java.util.concurrent.*
|
||||||
|
|
||||||
class ServerConfiguration : dorkbox.network.Configuration() {
|
class ServerConfiguration : dorkbox.network.Configuration() {
|
||||||
companion object {
|
companion object {
|
||||||
|
@ -487,7 +487,7 @@ open class Configuration {
|
||||||
*/
|
*/
|
||||||
fun suggestAeronLogLocation(logger: KLogger): File {
|
fun suggestAeronLogLocation(logger: KLogger): File {
|
||||||
return when {
|
return when {
|
||||||
OS.isMacOsX() -> {
|
OS.isMacOsX -> {
|
||||||
// does the recommended location exist??
|
// does the recommended location exist??
|
||||||
val suggestedLocation = File("/Volumes/DevShm")
|
val suggestedLocation = File("/Volumes/DevShm")
|
||||||
if (suggestedLocation.exists()) {
|
if (suggestedLocation.exists()) {
|
||||||
|
@ -499,7 +499,7 @@ open class Configuration {
|
||||||
File(System.getProperty("java.io.tmpdir"))
|
File(System.getProperty("java.io.tmpdir"))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
OS.isLinux() -> {
|
OS.isLinux -> {
|
||||||
// this is significantly faster for linux than using the temp dir
|
// this is significantly faster for linux than using the temp dir
|
||||||
File("/dev/shm/")
|
File("/dev/shm/")
|
||||||
}
|
}
|
||||||
|
|
|
@ -27,7 +27,17 @@ import dorkbox.network.ping.Ping
|
||||||
import dorkbox.network.ping.PingSerializer
|
import dorkbox.network.ping.PingSerializer
|
||||||
import dorkbox.network.rmi.CachedMethod
|
import dorkbox.network.rmi.CachedMethod
|
||||||
import dorkbox.network.rmi.RmiUtils
|
import dorkbox.network.rmi.RmiUtils
|
||||||
import dorkbox.network.rmi.messages.*
|
import dorkbox.network.rmi.messages.ConnectionObjectCreateRequest
|
||||||
|
import dorkbox.network.rmi.messages.ConnectionObjectCreateResponse
|
||||||
|
import dorkbox.network.rmi.messages.ConnectionObjectDeleteRequest
|
||||||
|
import dorkbox.network.rmi.messages.ConnectionObjectDeleteResponse
|
||||||
|
import dorkbox.network.rmi.messages.ContinuationSerializer
|
||||||
|
import dorkbox.network.rmi.messages.MethodRequest
|
||||||
|
import dorkbox.network.rmi.messages.MethodRequestSerializer
|
||||||
|
import dorkbox.network.rmi.messages.MethodResponse
|
||||||
|
import dorkbox.network.rmi.messages.MethodResponseSerializer
|
||||||
|
import dorkbox.network.rmi.messages.RmiClientSerializer
|
||||||
|
import dorkbox.network.rmi.messages.RmiServerSerializer
|
||||||
import dorkbox.objectPool.ObjectPool
|
import dorkbox.objectPool.ObjectPool
|
||||||
import dorkbox.objectPool.Pool
|
import dorkbox.objectPool.Pool
|
||||||
import dorkbox.objectPool.PoolObject
|
import dorkbox.objectPool.PoolObject
|
||||||
|
@ -150,7 +160,7 @@ open class Serialization<CONNECTION: Connection>(private val references: Boolean
|
||||||
val rmiHolder = RmiHolder()
|
val rmiHolder = RmiHolder()
|
||||||
|
|
||||||
// reflectASM doesn't work on android
|
// reflectASM doesn't work on android
|
||||||
private val useAsm = !OS.isAndroid()
|
private val useAsm = !OS.isAndroid
|
||||||
|
|
||||||
// These are GLOBAL, single threaded only kryo instances.
|
// These are GLOBAL, single threaded only kryo instances.
|
||||||
// The readKryo WILL RE-CONFIGURED during the client handshake! (it is all the same thread, so object visibility is not a problem)
|
// The readKryo WILL RE-CONFIGURED during the client handshake! (it is all the same thread, so object visibility is not a problem)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user