1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
package gcc
import (
"time"
"github.com/pion/interceptor/internal/cc"
)
type arrivalGroupAccumulator struct {
interDepartureThreshold time.Duration
interArrivalThreshold time.Duration
interGroupDelayVariationTreshold time.Duration
}
func newArrivalGroupAccumulator() *arrivalGroupAccumulator {
return &arrivalGroupAccumulator{
interDepartureThreshold: 5 * time.Millisecond,
interArrivalThreshold: 5 * time.Millisecond,
interGroupDelayVariationTreshold: 0,
}
}
func (a *arrivalGroupAccumulator) run(in <-chan []cc.Acknowledgment, agWriter func(arrivalGroup)) {
init := false
group := arrivalGroup{}
for acks := range in {
for _, next := range acks {
if !init {
group.add(next)
init = true
continue
}
if next.Arrival.Before(group.arrival) {
// ignore out of order arrivals
continue
}
if next.Departure.After(group.departure) {
if interDepartureTimePkt(group, next) <= a.interDepartureThreshold {
group.add(next)
continue
}
if interArrivalTimePkt(group, next) <= a.interArrivalThreshold &&
interGroupDelayVariationPkt(group, next) < a.interGroupDelayVariationTreshold {
group.add(next)
continue
}
agWriter(group)
group = arrivalGroup{}
group.add(next)
}
}
}
}
func interArrivalTimePkt(a arrivalGroup, b cc.Acknowledgment) time.Duration {
return b.Arrival.Sub(a.arrival)
}
func interDepartureTimePkt(a arrivalGroup, b cc.Acknowledgment) time.Duration {
if len(a.packets) == 0 {
return 0
}
return b.Departure.Sub(a.packets[len(a.packets)-1].Departure)
}
func interGroupDelayVariationPkt(a arrivalGroup, b cc.Acknowledgment) time.Duration {
return b.Arrival.Sub(a.arrival) - b.Departure.Sub(a.departure)
}
|
