From 1a30f43cb00f477627dbbc6309bd4f756c7abc60 Mon Sep 17 00:00:00 2001 From: Nonoo Date: Thu, 29 Oct 2020 17:05:40 +0100 Subject: [PATCH] Fine tune buffer lengths --- audiostream.go | 2 +- txseqbuf.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/audiostream.go b/audiostream.go index 6fb3a96..85cd5f8 100644 --- a/audiostream.go +++ b/audiostream.go @@ -8,7 +8,7 @@ import ( ) const audioTimeoutDuration = 3 * time.Second -const audioRxSeqBufLength = 120 * time.Millisecond +const audioRxSeqBufLength = 300 * time.Millisecond type audioStream struct { common streamCommon diff --git a/txseqbuf.go b/txseqbuf.go index 176e1aa..1f536b2 100644 --- a/txseqbuf.go +++ b/txseqbuf.go @@ -2,7 +2,7 @@ package main import "time" -const txSeqBufLength = 500 * time.Millisecond +const txSeqBufLength = 300 * time.Millisecond type txSeqBufStruct struct { entries []seqBufEntry @@ -18,7 +18,7 @@ func (s *txSeqBufStruct) add(seq seqNum, p []byte) { } func (s *txSeqBufStruct) purgeOldEntries() { - for len(s.entries) > 0 && time.Since(s.entries[0].addedAt) > txSeqBufLength { + for len(s.entries) > 0 && time.Since(s.entries[0].addedAt) > txSeqBufLength*2 { s.entries = s.entries[1:] } }