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

Back out tweaks

Browse source
This commit is contained in:
Kegan Dougal 2020-08-07 15:31:40 +01:00
parent 14f0ca3b78
commit cd720d3ba4
2 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
keyserver/internal/device_list_update.go
View file

@ -110,13 +110,10 @@ func NewDeviceListUpdater(
// Start the device list updater, which will try to refresh any stale device lists.
func (u *DeviceListUpdater) Start() error {
for i := 0; i < len(u.workerChans); i++ {
// Allocate no buffer per channel.
// Allocate a small buffer per channel.
// If the buffer limit is reached, backpressure will cause the processing of EDUs
// to stop (in this transaction) until key requests can be made.
// This is important for sytest as when the /send transaction 200 OKs it assumes that
// keys have been fetched and will then issue requests to /keys/query which it expects
// to be satisfied from the cache (which it won't be if we haven't processed it yet).
ch := make(chan gomatrixserverlib.ServerName)
ch := make(chan gomatrixserverlib.ServerName, 10)
u.workerChans[i] = ch
go u.worker(ch)
}

2
sytest-whitelist
View file

@ -138,7 +138,7 @@ Users receive device_list updates for their own devices
Get left notifs for other users in sync and /keys/changes when user leaves
Local device key changes get to remote servers
Local device key changes get to remote servers with correct prev_id
Server correctly handles incoming m.device_list_update
#Server correctly handles incoming m.device_list_update
Can add account data
Can add account data to room
Can get account data without syncing