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

Update tests

Browse source
This commit is contained in:
Neil Alexander 2020-05-28 09:43:13 +01:00
parent c859164597
commit 82974a38e0
1 changed files with 2 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
syncapi/sync/notifier_test.go
View file

@ -160,18 +160,6 @@ func TestCorrectStreamWakeup(t *testing.T) {
streamone := lockedFetchUserStream(n, alice, "one") streamone := lockedFetchUserStream(n, alice, "one")
streamtwo := lockedFetchUserStream(n, alice, "two") streamtwo := lockedFetchUserStream(n, alice, "two")
wait := func(stream *UserDeviceStream) {
select {
case <-time.After(time.Second * 10):
return
default:
waitForBlocking(stream, 1)
}
}
go wait(streamone)
go wait(streamtwo)
go func() { go func() {
select { select {
case <-streamone.signalChannel: case <-streamone.signalChannel:
@ -181,7 +169,7 @@ func TestCorrectStreamWakeup(t *testing.T) {
} }
}() }()
time.Sleep(1 * time.Microsecond) time.Sleep(1 * time.Second)
wake := "two" wake := "two"
n.wakeupUserDevice(map[string]string{alice: wake}, syncPositionAfter) n.wakeupUserDevice(map[string]string{alice: wake}, syncPositionAfter)
@ -354,7 +342,7 @@ func waitForEvents(n *Notifier, req syncRequest) (types.StreamingToken, error) {
func waitForBlocking(s *UserDeviceStream, numBlocking uint) { func waitForBlocking(s *UserDeviceStream, numBlocking uint) {
for numBlocking != s.NumWaiting() { for numBlocking != s.NumWaiting() {
// This is horrible but I don't want to add a signalling mechanism JUST for testing. // This is horrible but I don't want to add a signalling mechanism JUST for testing.
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Microsecond)
} }
} }