Cleaned up logs
This commit is contained in:
parent
0c7202d00c
commit
fb3d2f3f98
|
@ -348,7 +348,7 @@ class IpcMediaDriverConnection(override val streamId: Int,
|
||||||
|
|
||||||
override fun clientInfo() : String {
|
override fun clientInfo() : String {
|
||||||
return if (sessionId != AeronConfig.RESERVED_SESSION_ID_INVALID) {
|
return if (sessionId != AeronConfig.RESERVED_SESSION_ID_INVALID) {
|
||||||
"[$sessionId] aeron connection established to [$streamIdSubscription|$streamId]"
|
"[$sessionId] IPC connection established to [$streamIdSubscription|$streamId]"
|
||||||
} else {
|
} else {
|
||||||
"Connecting handshake to IPC [$streamIdSubscription|$streamId]"
|
"Connecting handshake to IPC [$streamIdSubscription|$streamId]"
|
||||||
}
|
}
|
||||||
|
|
|
@ -257,7 +257,7 @@ internal class ServerHandshake<CONNECTION : Connection>(private val logger: KLog
|
||||||
clientConnection.buildServer(aeron, logger)
|
clientConnection.buildServer(aeron, logger)
|
||||||
|
|
||||||
logger.info {
|
logger.info {
|
||||||
"[${clientConnection.sessionId}] aeron IPC connection established to $clientConnection"
|
"[${clientConnection.sessionId}] IPC connection established to [${clientConnection.streamIdSubscription}|${clientConnection.streamId}]"
|
||||||
}
|
}
|
||||||
|
|
||||||
val connection = server.newConnection(ConnectionParams(server, clientConnection, PublicKeyValidationState.VALID))
|
val connection = server.newConnection(ConnectionParams(server, clientConnection, PublicKeyValidationState.VALID))
|
||||||
|
|
Loading…
Reference in New Issue
Block a user