From 58dceb1a08f2b21681c4e8177c8713b62088c0ff Mon Sep 17 00:00:00 2001 From: Anant Prakash Date: Fri, 10 Aug 2018 04:39:56 +0530 Subject: [PATCH] Count EDUs in sendCounter --- .../dendrite/federationsender/queue/destinationqueue.go | 1 + 1 file changed, 1 insertion(+) diff --git a/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go b/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go index 64d721d4a..c0afe3be2 100644 --- a/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go +++ b/src/github.com/matrix-org/dendrite/federationsender/queue/destinationqueue.go @@ -125,6 +125,7 @@ func (oq *destinationQueue) next() *gomatrixserverlib.Transaction { t.EDUs = append(t.EDUs, *edu) } oq.pendingEDUs = nil + oq.sentCounter += len(t.EDUs) return &t }