From 6645e02ad6ac38220b83fc18e6d6d51944915a7b Mon Sep 17 00:00:00 2001
From: 0x1a8510f2 <admin@0x1a8510f2.space>
Date: Mon, 12 Sep 2022 15:42:11 +0100
Subject: [PATCH] Missed a spot

---
 syncapi/streams/stream_pdu.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go
index 8656747f4..9bbedde89 100644
--- a/syncapi/streams/stream_pdu.go
+++ b/syncapi/streams/stream_pdu.go
@@ -44,7 +44,7 @@ type PDUStreamProvider struct {
 }
 
 func (p *PDUStreamProvider) worker() {
-	defer p.workers.Dec()
+	defer p.workers.Add(-1)
 	for {
 		select {
 		case f := <-p.tasks:
@@ -57,7 +57,7 @@ func (p *PDUStreamProvider) worker() {
 
 func (p *PDUStreamProvider) queue(f func()) {
 	if p.workers.Load() < PDU_STREAM_WORKERS {
-		p.workers.Inc()
+		p.workers.Add(1)
 		go p.worker()
 	}
 	p.tasks <- f