dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-03-30 15:35:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

log adjustment for first packet (#1965)

Browse Source
This commit is contained in:
Raja Subramanian
2023-08-14 23:50:01 +05:30
committed by GitHub
parent 83111eee48
commit 77c8e82473
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/sfu/buffer/rtpstats.go
View File

@@ -794,13 +794,19 @@ func (r *RTPStats) maybeAdjustFirstPacketTime(ts uint32) {
samplesDuration := time.Duration(float64(samplesDiff) / float64(r.params.ClockRate) * float64(time.Second))
firstTime := time.Now().Add(-samplesDuration)
if firstTime.Before(r.firstTime) {
r.logger.Infow(
r.logger.Debugw(
"adjusting first packet time",
"before", r.firstTime.String(),
"after", firstTime.String(),
)
if r.firstTime.Sub(firstTime) > firstPacketTimeAdjustThreshold {
r.logger.Infow("first packet time adjustment too big, ignoring", "adjustment", r.firstTime.Sub(firstTime))
r.logger.Infow("first packet time adjustment too big, ignoring",
"adjustment", r.firstTime.Sub(firstTime),
"before", r.firstTime.String(),
"after", firstTime.String(),
"ts", ts,
"extStartTS", r.extStartTS,
)
} else {
r.firstTime = firstTime
}