From ef41906e49b59672e98ce8256616b7f9672d3020 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Fri, 2 Jul 2021 10:53:20 +0100
Subject: [PATCH] Release on waitgroup

---
 federationapi/routing/send.go | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/federationapi/routing/send.go b/federationapi/routing/send.go
index 25822f8be..a4c88745c 100644
--- a/federationapi/routing/send.go
+++ b/federationapi/routing/send.go
@@ -304,8 +304,17 @@ func (t *inputWorker) run() {
 		if task == nil {
 			continue
 		}
+		func() {
+			defer task.wg.Done()
+			select {
+			case <-task.ctx.Done():
+				task.err = context.DeadlineExceeded
+				return
+			default:
+				task.err = task.t.processEvent(task.ctx, task.event)
+			}
+		}()
 		//evStart := time.Now()
-		task.err = task.t.processEvent(task.ctx, task.event)
 		/*
 			if task.err = task.t.processEvent(task.ctx, task.event); task.err != nil {
 				err := task.err