Skip to content
Snippets Groups Projects
Verified Commit 9514bd18 authored by Janne Mareike Koschinski's avatar Janne Mareike Koschinski
Browse files

More heartbeat debug info

parent e88d6ccd
No related branches found
No related tags found
No related merge requests found
Pipeline #
......@@ -15,9 +15,10 @@ class HeartBeatThread(private val session: Session) : Thread() {
val now = Instant.now()
val duration = Duration.between(lastHeartBeatReply, now).toMillis()
if (duration > TIMEOUT) {
log(INFO, "Session", "Ping Timeout: Last Response ${duration}ms ago")
log(INFO, "Heartbeat", "Ping Timeout: Last Response ${duration}ms ago")
session.close()
} else {
log(INFO, "Heartbeat", "Sending Heartbeat")
session.dispatch(SignalProxyMessage.HeartBeat(now))
}
}
......
......@@ -27,6 +27,8 @@ import de.kuschku.libquassel.quassel.ExtendedFeature
import de.kuschku.libquassel.quassel.QuasselFeatures
import de.kuschku.libquassel.quassel.syncables.*
import de.kuschku.libquassel.util.compatibility.HandlerService
import de.kuschku.libquassel.util.compatibility.LoggingHandler
import de.kuschku.libquassel.util.compatibility.LoggingHandler.Companion.log
import io.reactivex.BackpressureStrategy
import io.reactivex.Observable
import io.reactivex.subjects.BehaviorSubject
......@@ -239,6 +241,7 @@ class Session(
val now = Instant.now()
heartBeatThread.setLastHeartBeatReply(f.timestamp)
val latency = now.toEpochMilli() - f.timestamp.toEpochMilli()
log(LoggingHandler.LogLevel.INFO, "Heartbeat", "Received Heartbeat with ${latency}ms latency")
lag.onNext(latency)
return true
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment