1
0
Fork 0
mirror of https://github.com/diamondburned/arikawa.git synced 2025-03-28 04:49:51 +00:00

Utils: Added extra wsutil logging

This commit is contained in:
diamondburned (Forefront) 2020-05-11 16:57:40 -07:00
parent d4bdf700f3
commit d82aa60fdc
3 changed files with 5 additions and 6 deletions

View file

@ -238,6 +238,8 @@ func (s *State) onEvent(iface interface{}) {
} }
} }
case *gateway.SessionsReplaceEvent:
case *gateway.UserGuildSettingsUpdateEvent: case *gateway.UserGuildSettingsUpdateEvent:
for i, ugs := range s.Ready.UserGuildSettings { for i, ugs := range s.Ready.UserGuildSettings {
if ugs.GuildID == ev.GuildID { if ugs.GuildID == ev.GuildID {

View file

@ -125,14 +125,11 @@ func (p *Pacemaker) start() error {
p.Echo() p.Echo()
for { for {
Debug("Pacemaker loop restarted.")
if err := p.Pace(); err != nil { if err := p.Pace(); err != nil {
return err return err
} }
Debug("Paced.")
// Paced, save: // Paced, save:
p.SentBeat.Set(time.Now()) p.SentBeat.Set(time.Now())
@ -142,11 +139,9 @@ func (p *Pacemaker) start() error {
select { select {
case <-p.stop.Recv(): case <-p.stop.Recv():
Debug("Received stop signal.")
return nil return nil
case <-tick.C: case <-tick.C:
Debug("Ticked. Restarting.")
} }
} }
} }

View file

@ -84,11 +84,13 @@ func (p *PacemakerLoop) startLoop() error {
for { for {
select { select {
case err := <-p.pacedeath: case err := <-p.pacedeath:
// return nil if err == nil WSDebug("Pacedeath returned with error:", err)
return errors.Wrap(err, "Pacemaker died, reconnecting") return errors.Wrap(err, "Pacemaker died, reconnecting")
case ev, ok := <-p.events: case ev, ok := <-p.events:
if !ok { if !ok {
WSDebug("Events channel closed, stopping pacemaker.")
defer WSDebug("Pacemaker stopped automatically.")
// Events channel is closed. Kill the pacemaker manually and // Events channel is closed. Kill the pacemaker manually and
// die. // die.
p.pacemaker.Stop() p.pacemaker.Stop()