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

Use ApplyUpdates in user stream to ensure we don't go backwards

Browse source
This commit is contained in:
Neil Alexander 2021-01-12 14:47:47 +00:00
parent ec1b017906
commit b1770c5d75
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
syncapi/notifier/userstream.go
View file

@ -89,10 +89,9 @@ func (s *UserDeviceStream) Broadcast(pos types.StreamingToken) {
s.lock.Lock() s.lock.Lock()
defer s.lock.Unlock() defer s.lock.Unlock()
s.pos = pos s.pos.ApplyUpdates(pos)
close(s.signalChannel) close(s.signalChannel)
s.signalChannel = make(chan struct{}) s.signalChannel = make(chan struct{})
} }