mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2024-11-27 00:31:55 -06:00
Code Issues Packages Projects Releases Wiki Activity

Report errors on sending to RS input

Browse source
This commit is contained in:
Neil Alexander 2022-01-17 11:53:42 +00:00
parent 14327faaf6
commit 3a62494082
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
federationapi/routing/send.go
View file

@ -284,7 +284,7 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
// pass the event to the roomserver which will do auth checks // pass the event to the roomserver which will do auth checks
// If the event fail auth checks, gmsl.NotAllowed error will be returned which we be silently // If the event fail auth checks, gmsl.NotAllowed error will be returned which we be silently
// discarded by the caller of this function // discarded by the caller of this function
_ = api.SendEvents( if err = api.SendEvents(
context.Background(), context.Background(),
t.rsAPI, t.rsAPI,
api.KindNew, api.KindNew,
@ -295,8 +295,15 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
api.DoNotSendToOtherServers, api.DoNotSendToOtherServers,
nil, nil,
true, true,
) ); err != nil {
util.GetLogger(ctx).WithError(err).Warnf("Transaction: Couldn't submit event %q to input queue: %s", event.EventID(), err)
results[event.EventID()] = gomatrixserverlib.PDUResult{
Error: err.Error(),
}
continue
}
util.GetLogger(ctx).WithError(err).Infof("XXX: Submitted event %q into input queue", event.EventID())
results[event.EventID()] = gomatrixserverlib.PDUResult{} results[event.EventID()] = gomatrixserverlib.PDUResult{}
} }