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

Maximum two minute warmup period

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

7
federationapi/queue/queue.go
View file

@ -119,11 +119,14 @@ 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.Second * 5 offset, step := time.Second*5, time.Second
if max := len(serverNames); max > 120 {
step = (time.Second * 120) / time.Duration(max)
}
for serverName := range serverNames { for serverName := range serverNames {
if queue := queues.getQueue(serverName); queue != nil { if queue := queues.getQueue(serverName); queue != nil {
time.AfterFunc(offset, queue.wakeQueueIfNeeded) time.AfterFunc(offset, queue.wakeQueueIfNeeded)
offset += time.Second offset += step
} }
} }
} }

7
keyserver/internal/device_list_update.go
View file

@ -157,12 +157,15 @@ func (u *DeviceListUpdater) Start() error {
if err != nil { if err != nil {
return err return err
} }
offset := time.Second * 10 offset, step := time.Second*10, time.Second
if max := len(staleLists); max > 120 {
step = (time.Second * 120) / time.Duration(max)
}
for _, userID := range staleLists { for _, userID := range staleLists {
time.AfterFunc(offset, func() { time.AfterFunc(offset, func() {
u.notifyWorkers(userID) u.notifyWorkers(userID)
}) })
offset += time.Second offset += step
} }
return nil return nil
} }