mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-03 20:23:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix mutex unlock

Browse source
This commit is contained in:
Neil Alexander 2022-03-22 14:56:45 +00:00
parent 1364d85985
commit 8ab5ad2fb5
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
roomserver/internal/input/input.go
View file

@ -79,7 +79,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) {
}) })
w := v.(*worker) w := v.(*worker)
w.Lock() w.Lock()
defer w.Lock() defer w.Unlock()
if !loaded || w.subscription == nil { if !loaded || w.subscription == nil {
consumer := r.Cfg.Matrix.JetStream.Prefixed("RoomInput" + jetstream.Tokenise(w.roomID)) consumer := r.Cfg.Matrix.JetStream.Prefixed("RoomInput" + jetstream.Tokenise(w.roomID))
subject := r.Cfg.Matrix.JetStream.Prefixed(jetstream.InputRoomEventSubj(w.roomID)) subject := r.Cfg.Matrix.JetStream.Prefixed(jetstream.InputRoomEventSubj(w.roomID))