mirror of
https://github.com/hoernschen/dendrite.git
synced 2024-12-27 07:28:27 +00:00
Try that again
This commit is contained in:
parent
0308cebc6a
commit
2a911aa892
1 changed files with 1 additions and 1 deletions
|
@ -91,11 +91,11 @@ func (r *Inputer) Start() error {
|
||||||
_ = msg.Term()
|
_ = msg.Term()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer eventIDsQueued.Delete(eventID)
|
|
||||||
|
|
||||||
roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Inc()
|
roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Inc()
|
||||||
worker := r.workerForRoom(roomID)
|
worker := r.workerForRoom(roomID)
|
||||||
worker.Act(nil, func() {
|
worker.Act(nil, func() {
|
||||||
|
defer eventIDsQueued.Delete(eventID)
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), MaximumProcessingTime)
|
ctx, cancel := context.WithTimeout(context.Background(), MaximumProcessingTime)
|
||||||
defer cancel()
|
defer cancel()
|
||||||
defer roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Dec()
|
defer roomserverInputBackpressure.With(prometheus.Labels{"room_id": roomID}).Dec()
|
||||||
|
|
Loading…
Reference in a new issue