From 8ab5ad2fb53977595a3787365124d12f64d4c636 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 22 Mar 2022 14:56:45 +0000 Subject: [PATCH] Fix mutex unlock --- 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 47844e0f6..076e18d90 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -79,7 +79,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) { }) w := v.(*worker) w.Lock() - defer w.Lock() + defer w.Unlock() if !loaded || w.subscription == nil { consumer := r.Cfg.Matrix.JetStream.Prefixed("RoomInput" + jetstream.Tokenise(w.roomID)) subject := r.Cfg.Matrix.JetStream.Prefixed(jetstream.InputRoomEventSubj(w.roomID))