From 76ae387a0467f7cf9fdb9f883e77bf5ad7db848c Mon Sep 17 00:00:00 2001 From: zarazaex69 Date: Fri, 10 Apr 2026 14:56:39 +0300 Subject: [PATCH] perf(peer): Increase buffer threshold and adjust backpressure timing Co-authored-by: qtozdec <56160254+qtozdec@users.noreply.github.com> --- internal/telemost/peer.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/telemost/peer.go b/internal/telemost/peer.go index 2ce9c3a..e36e86e 100644 --- a/internal/telemost/peer.go +++ b/internal/telemost/peer.go @@ -725,15 +725,15 @@ func (p *Peer) processSendQueue(workerID int) { start := time.Now() - for p.dc.BufferedAmount() > 16*1024 { - time.Sleep(5 * time.Millisecond) - if time.Since(start) > 5*time.Second { + for p.dc.BufferedAmount() > 4*1024*1024 { + time.Sleep(10 * time.Millisecond) + if time.Since(start) > 10*time.Second { log.Printf("[WORKER-%d] Buffer wait timeout, dropping packet size=%d", workerID, len(data)) break } } - if time.Since(start) > 5*time.Second { + if time.Since(start) > 10*time.Second { continue }