diff options
| author | Mel <einebeere@gmail.com> | 2022-04-07 18:21:57 +0200 |
|---|---|---|
| committer | Mel <einebeere@gmail.com> | 2022-04-07 18:21:57 +0200 |
| commit | 4b08666755bc3a490815644c1a5f93abdb93a093 (patch) | |
| tree | bfa936664915a30988199efaaa9ee100d48cb5c3 /pkg | |
| parent | 782e75b403c0d14beabdd7b74ad12388087b1321 (diff) | |
| download | jinx-4b08666755bc3a490815644c1a5f93abdb93a093.tar.zst jinx-4b08666755bc3a490815644c1a5f93abdb93a093.zip | |
Fix heartbeat jitter order
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/discord/heartbeat.go | 12 |
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 } } } |
