mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-21 04:53:14 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add debug logging

Browse source
This commit is contained in:
Till Faelligen 2022-11-08 16:13:27 +01:00
parent 8246b20d85
commit 296184c789
No known key found for this signature in database
GPG key ID: ACCDC9606D472758
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationapi/consumers/presence.go
View file

@ -114,17 +114,18 @@ func (t *OutputPresenceConsumer) onMessage(ctx context.Context, msgs []*nats.Msg
WantMembership: "join", WantMembership: "join",
}, &queryRes) }, &queryRes)
if err != nil { if err != nil {
log.WithError(err).Error("failed to calculate joined rooms for user") log.WithError(err).Error("::: failed to calculate joined rooms for user")
return true return true
} }
joined, err = t.db.GetJoinedHostsForRooms(t.ctx, queryRes.RoomIDs, true) joined, err = t.db.GetJoinedHostsForRooms(t.ctx, queryRes.RoomIDs, true)
if err != nil { if err != nil {
log.WithError(err).Error("failed to get joined hosts") log.WithError(err).Error("::: failed to get joined hosts")
return true return true
} }
if len(joined) == 0 { if len(joined) == 0 {
log.Debugf("::: no joined hosts, retrying (%d/%d)", i+1, maxRetries)
time.Sleep(retryDelay) time.Sleep(retryDelay)
continue continue
} }
@ -132,6 +133,7 @@ func (t *OutputPresenceConsumer) onMessage(ctx context.Context, msgs []*nats.Msg
} }
// If we still have no joined hosts, discard the event. // If we still have no joined hosts, discard the event.
if len(joined) == 0 { if len(joined) == 0 {
log.Debugf("::: no joined hosts after retrying")
return true return true
} }