mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-03 04:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Delay device list updates too

Browse source
This commit is contained in:
Neil Alexander 2022-04-04 13:21:36 +01:00
parent be24eea797
commit d45e629460
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationapi/queue/queue.go
View file

@ -119,11 +119,11 @@ func NewOutgoingQueues(
} else { } else {
log.WithError(err).Error("Failed to get EDU server names for destination queue hydration") log.WithError(err).Error("Failed to get EDU server names for destination queue hydration")
} }
offset := time.Duration(5) offset := time.Second * 5
for serverName := range serverNames { for serverName := range serverNames {
if queue := queues.getQueue(serverName); queue != nil { if queue := queues.getQueue(serverName); queue != nil {
time.AfterFunc(time.Second*offset, queue.wakeQueueIfNeeded) time.AfterFunc(offset, queue.wakeQueueIfNeeded)
offset++ offset += time.Second
} }
} }
} }

6
keyserver/internal/device_list_update.go
View file

@ -157,8 +157,12 @@ func (u *DeviceListUpdater) Start() error {
if err != nil { if err != nil {
return err return err
} }
offset := time.Second * 10
for _, userID := range staleLists { for _, userID := range staleLists {
u.notifyWorkers(userID) time.AfterFunc(offset, func() {
u.notifyWorkers(userID)
})
offset += time.Second
} }
return nil return nil
} }