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

Missed a spot

Browse source
This commit is contained in:
0x1a8510f2 2022-09-12 15:42:11 +01:00
parent 5253a99bce
commit 6645e02ad6
No known key found for this signature in database
GPG key ID: 1C692E355D76775D
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
syncapi/streams/stream_pdu.go
View file

@ -44,7 +44,7 @@ type PDUStreamProvider struct {
} }
func (p *PDUStreamProvider) worker() { func (p *PDUStreamProvider) worker() {
defer p.workers.Dec() defer p.workers.Add(-1)
for { for {
select { select {
case f := <-p.tasks: case f := <-p.tasks:
@ -57,7 +57,7 @@ func (p *PDUStreamProvider) worker() {
func (p *PDUStreamProvider) queue(f func()) { func (p *PDUStreamProvider) queue(f func()) {
if p.workers.Load() < PDU_STREAM_WORKERS { if p.workers.Load() < PDU_STREAM_WORKERS {
p.workers.Inc() p.workers.Add(1)
go p.worker() go p.worker()
} }
p.tasks <- f p.tasks <- f