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

Bug fixes

Browse source
This commit is contained in:
Neil Alexander 2022-03-25 12:16:34 +00:00
parent 8a0c2a47e5
commit 021f276255
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
syncapi/streams/stream_pdu.go
View file

@ -147,7 +147,6 @@ func (p *PDUStreamProvider) IncrementalSync(
To: to, To: to,
Backwards: from > to, Backwards: from > to,
} }
newPos = from
var err error var err error
var stateDeltas []types.StateDelta var stateDeltas []types.StateDelta
@ -168,10 +167,15 @@ func (p *PDUStreamProvider) IncrementalSync(
} }
} }
if len(stateDeltas) == 0 {
return to
}
for _, roomID := range joinedRooms { for _, roomID := range joinedRooms {
req.Rooms[roomID] = gomatrixserverlib.Join req.Rooms[roomID] = gomatrixserverlib.Join
} }
newPos = from
for _, delta := range stateDeltas { for _, delta := range stateDeltas {
var pos types.StreamPosition var pos types.StreamPosition
if pos, err = p.addRoomDeltaToResponse(ctx, req.Device, r, delta, &eventFilter, req.Response); err != nil { if pos, err = p.addRoomDeltaToResponse(ctx, req.Device, r, delta, &eventFilter, req.Response); err != nil {