mirror/galene
1
Fork 0
mirror of https://github.com/jech/galene.git synced 2024-11-22 16:45:58 +01:00
Code Activity

Increate receiver report timeout to 8s.

Browse source 
The previous value caused statistics to occasionally timeout spuriously.
This commit is contained in:
Juliusz Chroboczek 2020-05-07 10:26:38 +02:00
parent f78030c482
commit e205596775
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
group.go
View file

@ -77,6 +77,8 @@ type bitrate struct {
microseconds uint64 microseconds uint64
} }
const receiverReportTimeout = 8000000
func (br *bitrate) Set(bitrate uint64, now uint64) { func (br *bitrate) Set(bitrate uint64, now uint64) {
// this is racy -- a reader might read the // this is racy -- a reader might read the
// data between the two writes. This shouldn't // data between the two writes. This shouldn't
@ -87,7 +89,7 @@ func (br *bitrate) Set(bitrate uint64, now uint64) {
func (br *bitrate) Get(now uint64) uint64 { func (br *bitrate) Get(now uint64) uint64 {
ts := atomic.LoadUint64(&br.microseconds) ts := atomic.LoadUint64(&br.microseconds)
if now < ts || now > ts+4000000 { if now < ts || now > ts+receiverReportTimeout {
return ^uint64(0) return ^uint64(0)
} }
return atomic.LoadUint64(&br.bitrate) return atomic.LoadUint64(&br.bitrate)
@ -107,7 +109,7 @@ func (s *receiverStats) Set(loss uint8, jitter uint32, now uint64) {
func (s *receiverStats) Get(now uint64) (uint8, uint32) { func (s *receiverStats) Get(now uint64) (uint8, uint32) {
ts := atomic.LoadUint64(&s.microseconds) ts := atomic.LoadUint64(&s.microseconds)
if now < ts || now > ts+4000000 { if now < ts || now > ts+receiverReportTimeout {
return 0, 0 return 0, 0
} }
return uint8(atomic.LoadUint32(&s.loss)), atomic.LoadUint32(&s.jitter) return uint8(atomic.LoadUint32(&s.loss)), atomic.LoadUint32(&s.jitter)