mirror of https://github.com/jech/galene.git
85 lines
1.9 KiB
Go
85 lines
1.9 KiB
Go
package rtpconn
|
|
|
|
import (
|
|
"sort"
|
|
"time"
|
|
|
|
"github.com/jech/galene/rtptime"
|
|
"github.com/jech/galene/stats"
|
|
)
|
|
|
|
func (c *webClient) GetStats() *stats.Client {
|
|
c.mu.Lock()
|
|
defer c.mu.Unlock()
|
|
|
|
cs := stats.Client{
|
|
Id: c.id,
|
|
}
|
|
|
|
for _, up := range c.up {
|
|
conns := stats.Conn{
|
|
Id: up.id,
|
|
}
|
|
tracks := up.getTracks()
|
|
for _, t := range tracks {
|
|
s := t.cache.GetStats(false)
|
|
var loss float64
|
|
if s.Expected > 0 {
|
|
loss = float64(s.Expected-s.Received) /
|
|
float64(s.Expected)
|
|
}
|
|
jitter := time.Duration(t.jitter.Jitter()) *
|
|
(time.Second / time.Duration(t.jitter.HZ()))
|
|
rate, _ := t.rate.Estimate()
|
|
conns.Tracks = append(conns.Tracks, stats.Track{
|
|
Bitrate: uint64(rate) * 8,
|
|
MaxBitrate: maxUpBitrate(t),
|
|
Loss: loss,
|
|
Jitter: stats.Duration(jitter),
|
|
})
|
|
}
|
|
cs.Up = append(cs.Up, conns)
|
|
}
|
|
sort.Slice(cs.Up, func(i, j int) bool {
|
|
return cs.Up[i].Id < cs.Up[j].Id
|
|
})
|
|
|
|
jiffies := rtptime.Jiffies()
|
|
for _, down := range c.down {
|
|
conns := stats.Conn{
|
|
Id: down.id,
|
|
}
|
|
for _, t := range down.tracks {
|
|
layer := t.getLayerInfo()
|
|
sid := layer.sid
|
|
maxSid := layer.maxSid
|
|
tid := layer.tid
|
|
maxTid := layer.maxTid
|
|
rate, _ := t.rate.Estimate()
|
|
maxRate, _, _ := t.GetMaxBitrate()
|
|
rtt := rtptime.ToDuration(t.getRTT(),
|
|
rtptime.JiffiesPerSec)
|
|
loss, jitter := t.stats.Get(jiffies)
|
|
j := time.Duration(jitter) * time.Second /
|
|
time.Duration(t.track.Codec().ClockRate)
|
|
conns.Tracks = append(conns.Tracks, stats.Track{
|
|
Tid: &tid,
|
|
MaxTid: &maxTid,
|
|
Sid: &sid,
|
|
MaxSid: &maxSid,
|
|
Bitrate: uint64(rate) * 8,
|
|
MaxBitrate: maxRate,
|
|
Loss: float64(loss) / 256.0,
|
|
Rtt: stats.Duration(rtt),
|
|
Jitter: stats.Duration(j),
|
|
})
|
|
}
|
|
cs.Down = append(cs.Down, conns)
|
|
}
|
|
sort.Slice(cs.Down, func(i, j int) bool {
|
|
return cs.Down[i].Id < cs.Down[j].Id
|
|
})
|
|
|
|
return &cs
|
|
}
|