mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/element-hq/dendrite.git synced 2025-09-13 12:52:24 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add some more logging

Browse source
This commit is contained in:
Till Faelligen 2024-12-19 19:42:45 +01:00
parent 44c52a2482
commit ece014ddfe
No known key found for this signature in database
GPG key ID: 3DF82D8AB9211D4E
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
roomserver/acls/acls.go
View file

@ -14,6 +14,7 @@ import (
"regexp" "regexp"
"strings" "strings"
"sync" "sync"
"time"
"github.com/element-hq/dendrite/roomserver/storage/tables" "github.com/element-hq/dendrite/roomserver/storage/tables"
"github.com/matrix-org/gomatrixserverlib" "github.com/matrix-org/gomatrixserverlib"
@ -40,6 +41,16 @@ type ServerACLs struct {
} }
func NewServerACLs(db ServerACLDatabase) *ServerACLs { func NewServerACLs(db ServerACLDatabase) *ServerACLs {
// Add some logging, as this can take a while.
logrus.Infof("Loading server ACLs")
start := time.Now()
aclCount := 0
defer func() {
logrus.WithFields(logrus.Fields{
"duration": time.Since(start),
"acls": aclCount,
}).Info("Finished loading server ACLs")
}()
ctx := context.TODO() ctx := context.TODO()
acls := &ServerACLs{ acls := &ServerACLs{
acls: make(map[string]*serverACL), acls: make(map[string]*serverACL),
@ -62,6 +73,8 @@ func NewServerACLs(db ServerACLDatabase) *ServerACLs {
logrus.WithError(err).Errorf("Failed to get server ACLs for all rooms: %q", err) logrus.WithError(err).Errorf("Failed to get server ACLs for all rooms: %q", err)
} }
aclCount = len(events)
for _, event := range events { for _, event := range events {
acls.OnServerACLUpdate(event) acls.OnServerACLUpdate(event)
} }