From 4b08666755bc3a490815644c1a5f93abdb93a093 Mon Sep 17 00:00:00 2001 From: Mel Date: Thu, 7 Apr 2022 18:21:57 +0200 Subject: Fix heartbeat jitter order --- pkg/discord/heartbeat.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) (limited to 'pkg') diff --git a/pkg/discord/heartbeat.go b/pkg/discord/heartbeat.go index 5d2972f..5c4a955 100644 --- a/pkg/discord/heartbeat.go +++ b/pkg/discord/heartbeat.go @@ -46,6 +46,8 @@ func (h *HeartbeatImpl) Ack() { } func (h *HeartbeatImpl) heartbeatRoutine(interval uint64) { + h.logger.Debug().Msgf("beating heart every %dms", interval) + // REF: heartbeat_interval * jitter jitter := rand.Intn(int(interval)) time.Sleep(time.Duration(jitter) * time.Millisecond) @@ -54,14 +56,16 @@ func (h *HeartbeatImpl) heartbeatRoutine(interval uint64) { defer ticker.Stop() for { + h.logger.Debug().Msg("sending heartbeat") + if err := h.gateway.Heartbeat(); err != nil { + h.logger.Error().Err(err).Msg("failed to send heartbeat") + } + select { case <-h.ctx.Done(): return case <-ticker.C: - h.logger.Debug().Msg("sending heartbeat") - if err := h.gateway.Heartbeat(); err != nil { - h.logger.Error().Err(err).Msg("failed to send heartbeat") - } + continue } } } -- cgit 1.4.1