Code cleanup
This commit is contained in:
parent
7f6550f1c1
commit
a140c844db
@ -95,16 +95,6 @@ abstract class EndPoint<CONNECTION : Connection> private constructor(val type: C
|
|||||||
internal val responseManager = ResponseManager()
|
internal val responseManager = ResponseManager()
|
||||||
|
|
||||||
internal val lanAddress = IP.lanAddress()
|
internal val lanAddress = IP.lanAddress()
|
||||||
|
|
||||||
|
|
||||||
// the first byte manage: byte/message/stream/etc, no-crypt, crypt, crypt+compress
|
|
||||||
const val kryo = 0.toByte()
|
|
||||||
const val byteArray = 1.toByte()
|
|
||||||
const val file = 2.toByte()
|
|
||||||
const val stream = 3.toByte()
|
|
||||||
|
|
||||||
const val ENCRYPTD = (1 shl 6).toByte()
|
|
||||||
const val COMPRESS = (1 shl 7).toByte()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
val logger: KLogger = KotlinLogging.logger(loggerName)
|
val logger: KLogger = KotlinLogging.logger(loggerName)
|
||||||
|
@ -279,6 +279,7 @@ class AeronRmiClientServer {
|
|||||||
|
|
||||||
config.appId = "aeron_test"
|
config.appId = "aeron_test"
|
||||||
config.uniqueAeronDirectory = true
|
config.uniqueAeronDirectory = true
|
||||||
|
config.forceAllowSharedAeronDriver = true
|
||||||
|
|
||||||
config.enableIpc = false
|
config.enableIpc = false
|
||||||
config.enableIPv6 = false
|
config.enableIPv6 = false
|
||||||
@ -291,7 +292,7 @@ class AeronRmiClientServer {
|
|||||||
|
|
||||||
// https://blah.cloud/networks/test-jumbo-frames-working/
|
// https://blah.cloud/networks/test-jumbo-frames-working/
|
||||||
// This must be a multiple of 32, and we leave some space for headers/etc
|
// This must be a multiple of 32, and we leave some space for headers/etc
|
||||||
config.networkMtuSize = 8960
|
config.networkMtuSize = 8192
|
||||||
|
|
||||||
// 4 MB for receive
|
// 4 MB for receive
|
||||||
config.receiveBufferSize = 4194304
|
config.receiveBufferSize = 4194304
|
||||||
|
Loading…
Reference in New Issue
Block a user