hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2024-12-26 15:08:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Process EDUs in parallel

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

8
federationapi/routing/send.go
View file

@ -263,7 +263,12 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
pdus = nil // nolint:ineffassign pdus = nil // nolint:ineffassign
var wg sync.WaitGroup var wg sync.WaitGroup
wg.Add(len(perRoom)) wg.Add(len(perRoom) + 1)
go func() {
defer wg.Done()
t.processEDUs(ctx)
}()
for _, q := range perRoom { for _, q := range perRoom {
go func(q chan *gomatrixserverlib.Event) { go func(q chan *gomatrixserverlib.Event) {
@ -335,7 +340,6 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
perRoom[k] = nil perRoom[k] = nil
} }
t.processEDUs(ctx)
if c := len(results); c > 0 { if c := len(results); c > 0 {
util.GetLogger(ctx).Infof("Processed %d PDUs from transaction %q", c, t.TransactionID) util.GetLogger(ctx).Infof("Processed %d PDUs from transaction %q", c, t.TransactionID)
} }