mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-28 09:13:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Sigh

Browse source
This commit is contained in:
Kegan Dougal 2021-04-08 12:05:41 +01:00
parent 844a8fcd76
commit 12386d32c6
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
keyserver/internal/device_list_update.go
View file

@ -305,7 +305,7 @@ func (u *DeviceListUpdater) worker(ch chan gomatrixserverlib.ServerName) {
retriesMu.Lock() retriesMu.Lock()
now := time.Now() now := time.Now()
for srv, retryAt := range retries { for srv, retryAt := range retries {
if retryAt.After(now) { if now.After(retryAt) {
serversToRetry = append(serversToRetry, srv) serversToRetry = append(serversToRetry, srv)
} }
} }
@ -374,7 +374,7 @@ func (u *DeviceListUpdater) processServer(serverName gomatrixserverlib.ServerNam
} }
} }
if failCount > 0 { if failCount > 0 {
logger.WithField("total", len(userIDs)).WithField("failed", failCount).Error("failed to query device keys for some users") logger.WithField("total", len(userIDs)).WithField("failed", failCount).WithField("wait", waitTime).Error("failed to query device keys for some users")
} }
for _, userID := range userIDs { for _, userID := range userIDs {
// always clear the channel to unblock Update calls regardless of success/failure // always clear the channel to unblock Update calls regardless of success/failure