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

Send auth events as outliers

Browse source
This commit is contained in:
Neil Alexander 2020-09-29 10:20:09 +01:00
parent 4bcdb8fa0c
commit 4cdc223ed6
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
federationapi/routing/send.go
View file

@ -393,10 +393,21 @@ func (t *txnReq) processEvent(ctx context.Context, e gomatrixserverlib.Event, is
logger.WithError(err).Errorf("Failed to unmarshal auth event %q", missingAuthEventID) logger.WithError(err).Errorf("Failed to unmarshal auth event %q", missingAuthEventID)
continue // try the next server continue // try the next server
} }
if err = t.processEvent(ctx, ev, false); err != nil { if err = api.SendInputRoomEvents(
logger.WithError(err).Errorf("Failed to process auth event %q", missingAuthEventID) context.Background(),
t.rsAPI,
[]api.InputRoomEvent{
{
Kind: api.KindOutlier,
Event: ev.Headered(stateResp.RoomVersion),
AuthEventIDs: ev.AuthEventIDs(),
SendAsServer: api.DoNotSendToOtherServers,
},
},
); err != nil {
logger.WithError(err).Errorf("Failed to send auth event %q to roomserver", missingAuthEventID)
continue getAuthEvent // move onto the next event
} }
continue getAuthEvent // move onto the next event
} }
} }
} }