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

Only apply rejection check to outliers

Browse source
This commit is contained in:
Neil Alexander 2022-08-18 09:43:00 +01:00
parent 2c7bc85bd6
commit 6411457f8b
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
roomserver/internal/input/input_events.go
View file

@ -119,11 +119,12 @@ func (r *Inputer) processRoomEvent(
return fmt.Errorf("room %s does not exist for event %s", event.RoomID(), event.EventID()) return fmt.Errorf("room %s does not exist for event %s", event.RoomID(), event.EventID())
} }
// If we already know about this event and it hasn't been rejected // If we already know about this outlier and it hasn't been rejected
// then we won't attempt to reprocess it. If it was rejected then we // then we won't attempt to reprocess it. If it was rejected or has now
// can attempt to reprocess, in case we have learned something new // arrived as a different kind of event, then we can attempt to reprocess,
// that will allow us to accept the event this time. // in case we have learned something new or need to weave the event into
if roomInfo != nil { // the DAG now.
if input.Kind == api.KindOutlier && roomInfo != nil {
wasRejected, werr := r.DB.IsEventRejected(ctx, roomInfo.RoomNID, event.EventID()) wasRejected, werr := r.DB.IsEventRejected(ctx, roomInfo.RoomNID, event.EventID())
switch { switch {
case werr == sql.ErrNoRows: case werr == sql.ErrNoRows: