From 2a911aa8922a7037012e332023fabe91a33d2a42 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Mon, 24 Jan 2022 12:56:14 +0000 Subject: [PATCH] Try that again --- roomserver/internal/input/input.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index 7d58b80b..07c6ed7e 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -91,11 +91,11 @@ func (r *Inputer) Start() error { _ = msg.Term() return } - defer eventIDsQueued.Delete(eventID) roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Inc() worker := r.workerForRoom(roomID) worker.Act(nil, func() { + defer eventIDsQueued.Delete(eventID) ctx, cancel := context.WithTimeout(context.Background(), MaximumProcessingTime) defer cancel() defer roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Dec()