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

Release on waitgroup

Browse source
This commit is contained in:
Neil Alexander 2021-07-02 10:53:20 +01:00
parent d5e01df56f
commit ef41906e49
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
federationapi/routing/send.go
View file

@ -304,8 +304,17 @@ func (t *inputWorker) run() {
if task == nil { if task == nil {
continue continue
} }
func() {
defer task.wg.Done()
select {
case <-task.ctx.Done():
task.err = context.DeadlineExceeded
return
default:
task.err = task.t.processEvent(task.ctx, task.event)
}
}()
//evStart := time.Now() //evStart := time.Now()
task.err = task.t.processEvent(task.ctx, task.event)
/* /*
if task.err = task.t.processEvent(task.ctx, task.event); task.err != nil { if task.err = task.t.processEvent(task.ctx, task.event); task.err != nil {
err := task.err err := task.err