mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-04-01 22:44:28 -05:00
Code Issues Packages Projects Releases Wiki Activity

Moar

Browse source
This commit is contained in:
Neil Alexander 2022-02-06 13:09:03 +00:00
parent 2a2f84052e
commit bab59dd1c2
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 8 additions and 3 deletions

7
roomserver/internal/input/input_missing.go
View file

@ -82,9 +82,11 @@ func (t *missingStateReq) processEventWithMissingState(
SendAsServer: api.DoNotSendToOtherServers, SendAsServer: api.DoNotSendToOtherServers,
}) })
if err != nil { if err != nil {
if _, ok := err.(types.RejectedError); !ok {
return fmt.Errorf("t.inputer.processRoomEvent: %w", err) return fmt.Errorf("t.inputer.processRoomEvent: %w", err)
} }
} }
}
return nil return nil
} }
@ -184,10 +186,13 @@ func (t *missingStateReq) processEventWithMissingState(
} }
// TODO: we could do this concurrently? // TODO: we could do this concurrently?
for _, ire := range outlierRoomEvents { for _, ire := range outlierRoomEvents {
if _, err = t.inputer.processRoomEvent(ctx, t.db, &ire); err != nil { _, err = t.inputer.processRoomEvent(ctx, t.db, &ire)
if err != nil {
if _, ok := err.(types.RejectedError); !ok {
return fmt.Errorf("t.inputer.processRoomEvent[outlier]: %w", err) return fmt.Errorf("t.inputer.processRoomEvent[outlier]: %w", err)
} }
} }
}
// Now send the backward extremity into the roomserver with the // Now send the backward extremity into the roomserver with the
// newly resolved state. This marks the "oldest" point in the backfill and // newly resolved state. This marks the "oldest" point in the backfill and