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:] } }