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

remove unused argument

Browse source
This commit is contained in:
Joakim Recht 2024-01-23 12:53:11 +01:00
parent da54821c9f
commit 432583ed47
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
syncapi/streams/stream_pdu.go
View file

@ -203,7 +203,7 @@ func (p *PDUStreamProvider) IncrementalSync(
req.Log.WithError(err).Error("unable to update event filter with ignored users") req.Log.WithError(err).Error("unable to update event filter with ignored users")
} }
dbEvents, err := p.getRecentEvents(ctx, stateDeltas, r, eventFilter, &stateFilter, req, snapshot) dbEvents, err := p.getRecentEvents(ctx, stateDeltas, r, eventFilter, req, snapshot)
if err != nil { if err != nil {
req.Log.WithError(err).Error("unable to get recent events") req.Log.WithError(err).Error("unable to get recent events")
return r.From return r.From
@ -249,7 +249,7 @@ func (p *PDUStreamProvider) IncrementalSync(
return newPos return newPos
} }
func (p *PDUStreamProvider) getRecentEvents(ctx context.Context, stateDeltas []types.StateDelta, r types.Range, eventFilter synctypes.RoomEventFilter, stateFilter *synctypes.StateFilter, req *types.SyncRequest, snapshot storage.DatabaseTransaction) (map[string]types.RecentEvents, error) { func (p *PDUStreamProvider) getRecentEvents(ctx context.Context, stateDeltas []types.StateDelta, r types.Range, eventFilter synctypes.RoomEventFilter, req *types.SyncRequest, snapshot storage.DatabaseTransaction) (map[string]types.RecentEvents, error) {
var roomIDs []string var roomIDs []string
var newlyJoinedRoomIDs []string var newlyJoinedRoomIDs []string
for _, delta := range stateDeltas { for _, delta := range stateDeltas {