From 9700f0b31c06975059a460367a088e82fb83926b Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Fri, 4 Dec 2020 16:24:36 +0000 Subject: [PATCH] Missing operators --- federationsender/queue/destinationqueue.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/federationsender/queue/destinationqueue.go b/federationsender/queue/destinationqueue.go index 7dbffbf0d..f3d41515c 100644 --- a/federationsender/queue/destinationqueue.go +++ b/federationsender/queue/destinationqueue.go @@ -246,10 +246,10 @@ func (oq *destinationQueue) backgroundSend() { // has exceeded a maximum allowable value. Clean up the in-memory // buffers at this point. The PDU clean-up is already on a defer. log.Warnf("Blacklisting %q due to exceeding backoff threshold", oq.destination) - for i := pendingPDUs { + for i := range pendingPDUs { pendingPDUs[i] = nil } - for i := pendingEDUs { + for i := range pendingEDUs { pendingEDUs[i] = nil } pendingPDUs = nil @@ -277,10 +277,10 @@ func (oq *destinationQueue) backgroundSend() { // If we successfully sent the transaction then clear out // the pending events and EDUs, and wipe our transaction ID. oq.statistics.Success() - for i := pendingPDUs { + for i := range pendingPDUs { pendingPDUs[i] = nil } - for i := pendingEDUs { + for i := range pendingEDUs { pendingEDUs[i] = nil } pendingPDUs = pendingPDUs[:0]