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

Fix waitgroup

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

4
federationapi/routing/send.go
View file

@ -210,6 +210,8 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
//var resultsMutex sync.Mutex //var resultsMutex sync.Mutex
var wg sync.WaitGroup var wg sync.WaitGroup
wg.Add(1) // for processEDUs
for _, pdu := range t.PDUs { for _, pdu := range t.PDUs {
pduCountTotal.WithLabelValues("total").Inc() pduCountTotal.WithLabelValues("total").Inc()
var header struct { var header struct {
@ -276,8 +278,6 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
}) })
} }
wg.Wait()
go func() { go func() {
defer wg.Done() defer wg.Done()
t.processEDUs(ctx) t.processEDUs(ctx)