aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMel <einebeere@gmail.com>2022-04-07 18:21:57 +0200
committerMel <einebeere@gmail.com>2022-04-07 18:21:57 +0200
commit4b08666755bc3a490815644c1a5f93abdb93a093 (patch)
treebfa936664915a30988199efaaa9ee100d48cb5c3
parent782e75b403c0d14beabdd7b74ad12388087b1321 (diff)
downloadjinx-4b08666755bc3a490815644c1a5f93abdb93a093.tar.zst
jinx-4b08666755bc3a490815644c1a5f93abdb93a093.zip
Fix heartbeat jitter order
-rw-r--r--pkg/discord/heartbeat.go12
1 files changed, 8 insertions, 4 deletions
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
}
}
}