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

Logging

Browse source
This commit is contained in:
Neil Alexander 2021-12-14 12:38:47 +00:00
parent bb5ee2ecc4
commit 69111355d0
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -273,6 +273,8 @@ func (r *Inputer) checkForMissingAuthEvents(
}
if len(unknown) > 0 {
logrus.Printf("XXX: There are %d missing auth events", len(unknown))
serverReq := &fedapi.QueryJoinedHostServerNamesInRoomRequest{
RoomID: event.RoomID(),
}
@ -281,6 +283,8 @@ func (r *Inputer) checkForMissingAuthEvents(
return fmt.Errorf("r.FSAPI.QueryJoinedHostServerNamesInRoom: %w", err)
}
logrus.Printf("XXX: Asking servers %+v", serverRes.ServerNames)
var res gomatrixserverlib.RespEventAuth
var found bool
for _, serverName := range serverRes.ServerNames {
@ -289,9 +293,12 @@ func (r *Inputer) checkForMissingAuthEvents(
logrus.WithError(err).Warnf("Failed to get event auth from federation for %q: %s", event.EventID(), err)
continue
}
logrus.Printf("XXX: Server %q provided us with %d auth events", serverName, len(res.AuthEvents))
found = true
break
}
if !found {
logrus.Printf("XXX: None of the %d servers provided us with auth events", len(serverRes.ServerNames))
return fmt.Errorf("no servers provided event auth")
}