seang96/gmessages
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Bump next bugle default check time before doing check

Browse source
This commit is contained in:
Tulir Asokan 2024-04-03 17:56:45 +03:00
parent fcfd04f47c
commit f6a9f7811d
2 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
libgm/event_handler.go
View file

@ -214,7 +214,9 @@ func (c *Client) handleUpdatesEvent(msg *IncomingRPCMessage) {
c.triggerEvent(&events.GaiaLoggedOut{})
return
}
if !msg.IsOld {
c.bumpNextBugleDefaultCheck(DefaultBugleDefaultCheckInterval)
}
data, ok := msg.DecryptedMessage.(*gmproto.UpdateEvents)
if !ok {
c.Logger.Error().

11
libgm/longpoll.go
View file

@ -199,9 +199,8 @@ func (dp *dittoPinger) Loop() {
case <-dp.stop:
return
}
if time.Until(dp.client.getNextBugleDefaultCheck()) <= 0 {
if dp.client.shouldDoBugleDefaultCheck() {
go dp.BugleDefaultCheck()
dp.client.bumpNextBugleDefaultCheck(DefaultBugleDefaultCheckInterval)
}
}
}
@ -226,10 +225,14 @@ func (dp *dittoPinger) BugleDefaultCheck() {
}
}
func (c *Client) getNextBugleDefaultCheck() time.Time {
func (c *Client) shouldDoBugleDefaultCheck() bool {
c.nextBugleDefaultCheckLock.Lock()
defer c.nextBugleDefaultCheckLock.Unlock()
return c.nextBugleDefaultCheck
if time.Until(c.nextBugleDefaultCheck) <= 0 {
c.nextBugleDefaultCheck = time.Now().Add(DefaultBugleDefaultCheckInterval)
return true
}
return false
}
func (c *Client) bumpNextBugleDefaultCheck(after time.Duration) {