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

More logging

Browse source
This commit is contained in:
Neil Alexander 2022-10-27 13:34:52 +01:00
parent d0ca183f49
commit 3571892fcd
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
keyserver/internal/internal.go
View file

@ -136,8 +136,12 @@ func (a *KeyInternalAPI) claimRemoteKeys(
util.GetLogger(ctx).WithField("num_servers", len(domainToDeviceKeys)).Info("Claiming remote keys from servers") util.GetLogger(ctx).WithField("num_servers", len(domainToDeviceKeys)).Info("Claiming remote keys from servers")
wg.Add(len(domainToDeviceKeys)) wg.Add(len(domainToDeviceKeys))
util.GetLogger(ctx).Infof("Domain to device keys: %+v", domainToDeviceKeys)
for d, k := range domainToDeviceKeys { for d, k := range domainToDeviceKeys {
go func(domain string, keysToClaim map[string]map[string]string) { go func(domain string, keysToClaim map[string]map[string]string) {
util.GetLogger(ctx).Infof("Keys to claim from %s: %+v", domain, keysToClaim)
fedCtx, cancel := context.WithTimeout(ctx, timeout) fedCtx, cancel := context.WithTimeout(ctx, timeout)
defer cancel() defer cancel()
defer wg.Done() defer wg.Done()