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
|
package gcc
import (
"fmt"
"time"
"github.com/pion/interceptor/internal/cc"
)
type arrivalGroup struct {
packets []cc.Acknowledgment
departure time.Time
arrival time.Time
}
func (g *arrivalGroup) add(a cc.Acknowledgment) {
g.packets = append(g.packets, a)
g.arrival = a.Arrival
g.departure = a.Departure
}
func (g arrivalGroup) String() string {
s := "ARRIVALGROUP:\n"
s += fmt.Sprintf("\tARRIVAL:\t%v\n", int64(float64(g.arrival.UnixNano())/1e+6))
s += fmt.Sprintf("\tDEPARTURE:\t%v\n", int64(float64(g.departure.UnixNano())/1e+6))
s += fmt.Sprintf("\tPACKETS:\n%v\n", g.packets)
return s
}
|
