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

Ensure the actor runs again

Browse source
This commit is contained in:
Neil Alexander 2022-03-22 10:49:37 +00:00
parent 901b5f819f
commit 555752482c
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -120,6 +120,7 @@ func (w *worker) next() {
if len(msgs) != 1 { if len(msgs) != 1 {
return return
} }
defer w.Act(nil, w.next)
case context.DeadlineExceeded: case context.DeadlineExceeded:
logrus.Infof("Stream for room %q idle, shutting down", w.roomID) logrus.Infof("Stream for room %q idle, shutting down", w.roomID)
if err = w.subscription.Unsubscribe(); err != nil { if err = w.subscription.Unsubscribe(); err != nil {
@ -140,7 +141,6 @@ func (w *worker) next() {
} }
msg := msgs[0] msg := msgs[0]
var inputRoomEvent api.InputRoomEvent var inputRoomEvent api.InputRoomEvent
if err = json.Unmarshal(msg.Data, &inputRoomEvent); err != nil { if err = json.Unmarshal(msg.Data, &inputRoomEvent); err != nil {
_ = msg.Term() _ = msg.Term()
@ -174,8 +174,6 @@ func (w *worker) next() {
}).Warn("Roomserver failed to respond for sync event") }).Warn("Roomserver failed to respond for sync event")
} }
} }
w.Act(nil, w.next)
} }
// InputRoomEvents implements api.RoomserverInternalAPI // InputRoomEvents implements api.RoomserverInternalAPI