diff options
| author | Kegsay <kegan@matrix.org> | 2020-08-11 10:44:59 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-11 10:44:59 +0100 |
| commit | befccd7d515f98730dbf6f5ff32fe63e6da6ffe4 (patch) | |
| tree | 21e2d23a5a0efe5f688633935f05288c3d062f54 /keyserver/internal | |
| parent | 52eeeb16279497e24ed6b1e34a7a16fc69b587d1 (diff) | |
Reduce cooldown to make sure sytest doesn't give up (#1257)
* Reduce cooldown to make sure sytest doesn't give up
* More sytests pass weeeeeee
Diffstat (limited to 'keyserver/internal')
| -rw-r--r-- | keyserver/internal/device_list_update.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/keyserver/internal/device_list_update.go b/keyserver/internal/device_list_update.go index ec7dff56..c4b098a4 100644 --- a/keyserver/internal/device_list_update.go +++ b/keyserver/internal/device_list_update.go @@ -222,7 +222,8 @@ func (u *DeviceListUpdater) worker(ch chan gomatrixserverlib.ServerName) { // last made a request to the server. If we get the server name during the cooloff // period, we'll ignore the poke. lastProcessed := make(map[gomatrixserverlib.ServerName]time.Time) - cooloffPeriod := time.Minute + // this can't be too long else sytest will give up trying to do a test + cooloffPeriod := 500 * time.Millisecond shouldProcess := func(srv gomatrixserverlib.ServerName) bool { // we should process requests when now is after the last process time + cooloff return time.Now().After(lastProcessed[srv].Add(cooloffPeriod)) |