aboutsummaryrefslogtreecommitdiff
path: root/federationsender/consumers
diff options
context:
space:
mode:
authorKegsay <kegan@matrix.org>2021-03-23 11:33:36 +0000
committerGitHub <noreply@github.com>2021-03-23 11:33:36 +0000
commita1b7e4ef3f9231ce6933cd2f5e7e93525e840293 (patch)
tree582e9fde57e0d531ffd1d1221c2fa44b2e5e622d /federationsender/consumers
parent01267a34b94a4253731a2e148e7a2d0450316869 (diff)
log less for failed key querys, add counters for incoming pdus/edus (#1801)
* log less for failed key querys, add counters for incoming pdus/edus * use labels * Blacklist flakey test * Fix metrics
Diffstat (limited to 'federationsender/consumers')
-rw-r--r--federationsender/consumers/eduserver.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/federationsender/consumers/eduserver.go b/federationsender/consumers/eduserver.go
index 639cd731..9a1ec1e2 100644
--- a/federationsender/consumers/eduserver.go
+++ b/federationsender/consumers/eduserver.go
@@ -212,8 +212,7 @@ func (t *OutputEDUConsumer) onReceiptEvent(msg *sarama.ConsumerMessage) error {
return nil
}
if receiptServerName != t.ServerName {
- log.WithField("other_server", receiptServerName).Info("Suppressing receipt notif: originated elsewhere")
- return nil
+ return nil // don't log, very spammy as it logs for each remote receipt
}
joined, err := t.db.GetJoinedHosts(context.TODO(), receipt.RoomID)