Only log RTT of connections to proxy if larger than 500ms.

This commit is contained in:
Joachim Bauch 2021-11-03 14:56:25 +01:00
parent 31294aee1d
commit 42dc476033
No known key found for this signature in database
GPG Key ID: 77C1D22D53E15F02
1 changed files with 6 additions and 2 deletions

View File

@ -66,6 +66,8 @@ const (
maxWaitDelay = 8 * time.Second
defaultProxyTimeoutSeconds = 2
rttLogDuration = 500 * time.Millisecond
)
type mcuProxyPubSubCommon struct {
@ -385,8 +387,10 @@ func (c *mcuProxyConnection) readPump() {
}
if ts, err := strconv.ParseInt(msg, 10, 64); err == nil {
rtt := now.Sub(time.Unix(0, ts))
rtt_ms := rtt.Nanoseconds() / time.Millisecond.Nanoseconds()
log.Printf("Proxy at %s has RTT of %d ms (%s)", c.url, rtt_ms, rtt)
if rtt >= rttLogDuration {
rtt_ms := rtt.Nanoseconds() / time.Millisecond.Nanoseconds()
log.Printf("Proxy at %s has RTT of %d ms (%s)", c.url, rtt_ms, rtt)
}
}
return nil
})