Skip to content
Snippets Groups Projects
Commit 6c9f7889 authored by Janne Mareike Koschinski's avatar Janne Mareike Koschinski
Browse files

Fixed a bug with logging issues

parent 292fa5e8
Branches
Tags
No related merge requests found
...@@ -60,7 +60,7 @@ class CoreConnection( ...@@ -60,7 +60,7 @@ class CoreConnection(
} }
fun setState(value: ConnectionState) { fun setState(value: ConnectionState) {
log(INFO, "CoreConnection", value.name) log(INFO, TAG, value.name)
internalState.onNext(value) internalState.onNext(value)
} }
...@@ -84,7 +84,7 @@ class CoreConnection( ...@@ -84,7 +84,7 @@ class CoreConnection(
sizeBuffer.flip() sizeBuffer.flip()
val protocol = ProtocolInfoSerializer.deserialize(sizeBuffer, session.coreFeatures) val protocol = ProtocolInfoSerializer.deserialize(sizeBuffer, session.coreFeatures)
log(DEBUG, "Protocol negotiated $protocol") log(DEBUG, TAG, "Protocol negotiated $protocol")
// Wrap socket in SSL context if ssl is enabled // Wrap socket in SSL context if ssl is enabled
if (protocol.flags.hasFlag(ProtocolFeature.TLS)) { if (protocol.flags.hasFlag(ProtocolFeature.TLS)) {
......
...@@ -31,11 +31,10 @@ abstract class ProtocolHandler : SignalProxy, AuthHandler, Closeable { ...@@ -31,11 +31,10 @@ abstract class ProtocolHandler : SignalProxy, AuthHandler, Closeable {
override fun handle(f: SignalProxyMessage): Boolean { override fun handle(f: SignalProxyMessage): Boolean {
try { try {
if (!super<SignalProxy>.handle(f)) { if (!super<SignalProxy>.handle(f)) {
log(DEBUG, "No receiver registered for $f") log(DEBUG, "ProtocolHandler", "No receiver registered for $f")
} }
} catch (e: Throwable) { } catch (e: Throwable) {
log(WARN, "ProtocolHandler", log(WARN, "ProtocolHandler", "Error Handling SignalProxyMessage", e)
"Error Handling SignalProxyMessage", e)
} }
return true return true
} }
...@@ -43,11 +42,10 @@ abstract class ProtocolHandler : SignalProxy, AuthHandler, Closeable { ...@@ -43,11 +42,10 @@ abstract class ProtocolHandler : SignalProxy, AuthHandler, Closeable {
override fun handle(f: HandshakeMessage): Boolean { override fun handle(f: HandshakeMessage): Boolean {
try { try {
if (!super<AuthHandler>.handle(f)) { if (!super<AuthHandler>.handle(f)) {
log(DEBUG, "No receiver registered for $f") log(DEBUG, "ProtocolHandler", "No receiver registered for $f")
} }
} catch (e: Throwable) { } catch (e: Throwable) {
log(WARN, "ProtocolHandler", log(WARN, "ProtocolHandler", "Error Handling HandshakeMessage", e)
"Error Handling HandshakeMessage", e)
} }
return true return true
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment