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

Remove dupe clearChannel

Browse source
This commit is contained in:
Till Faelligen 2023-10-02 17:08:26 +02:00
parent 0a116fb51a
commit fa8ba0de8f
No known key found for this signature in database
GPG key ID: ACCDC9606D472758
1 changed files with 0 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
userapi/internal/device_list_update.go
View file

@ -450,13 +450,6 @@ func (u *DeviceListUpdater) processServer(serverName spec.ServerName) (time.Dura
return waitTime, true return waitTime, true
} }
defer func() {
for _, userID := range userIDs {
// always clear the channel to unblock Update calls regardless of success/failure
u.clearChannel(userID)
}
}()
for _, userID := range userIDs { for _, userID := range userIDs {
userWait, err := u.processServerUser(ctx, serverName, userID) userWait, err := u.processServerUser(ctx, serverName, userID)
if err != nil { if err != nil {