mirror of
https://github.com/1f349/dendrite.git
synced 2024-12-23 08:44:11 +00:00
Mutex protect query keys response (#2812)
This commit is contained in:
parent
b58c9bb094
commit
9041491201
@ -472,7 +472,9 @@ func (a *KeyInternalAPI) queryRemoteKeys(
|
|||||||
close(resultCh)
|
close(resultCh)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
for result := range resultCh {
|
processResult := func(result *gomatrixserverlib.RespQueryKeys) {
|
||||||
|
respMu.Lock()
|
||||||
|
defer respMu.Unlock()
|
||||||
for userID, nest := range result.DeviceKeys {
|
for userID, nest := range result.DeviceKeys {
|
||||||
res.DeviceKeys[userID] = make(map[string]json.RawMessage)
|
res.DeviceKeys[userID] = make(map[string]json.RawMessage)
|
||||||
for deviceID, deviceKey := range nest {
|
for deviceID, deviceKey := range nest {
|
||||||
@ -495,6 +497,10 @@ func (a *KeyInternalAPI) queryRemoteKeys(
|
|||||||
// TODO: do we want to persist these somewhere now
|
// TODO: do we want to persist these somewhere now
|
||||||
// that we have fetched them?
|
// that we have fetched them?
|
||||||
}
|
}
|
||||||
|
|
||||||
|
for result := range resultCh {
|
||||||
|
processResult(result)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *KeyInternalAPI) queryRemoteKeysOnServer(
|
func (a *KeyInternalAPI) queryRemoteKeysOnServer(
|
||||||
|
Loading…
Reference in New Issue
Block a user