mirror of
https://github.com/livekit/livekit.git
synced 2026-05-14 11:55:14 +00:00
Log RTP stream start time and more details when adjusting first packet time. (#1983)
Trying to understand first packet time jumps on migration.
This commit is contained in:
@@ -402,6 +402,14 @@ func (r *RTPStats) Update(rtph *rtp.Header, payloadSize int, paddingSize int, pa
|
||||
extStartSNOverridden: r.extStartSN,
|
||||
}
|
||||
}
|
||||
|
||||
r.logger.Debugw(
|
||||
"rtp stream start",
|
||||
"startTime", r.startTime.String(),
|
||||
"firstTime", r.firstTime.String(),
|
||||
"startSN", r.extStartSN,
|
||||
"startTS", r.extStartTS,
|
||||
)
|
||||
}
|
||||
|
||||
if r.resyncOnNextPacket {
|
||||
@@ -529,7 +537,7 @@ func (r *RTPStats) maybeAdjustStart(rtph *rtp.Header, pktSize uint64, hdrSize ui
|
||||
r.tsCycles++
|
||||
}
|
||||
r.logger.Infow(
|
||||
"adjusting starting sequence number",
|
||||
"adjusting start",
|
||||
"snBefore", snBeforeAdjust,
|
||||
"snAfter", r.extStartSN,
|
||||
"snCyles", r.cycles,
|
||||
@@ -817,8 +825,13 @@ func (r *RTPStats) maybeAdjustFirstPacketTime(ts uint32) {
|
||||
if firstTime.Before(r.firstTime) {
|
||||
r.logger.Debugw(
|
||||
"adjusting first packet time",
|
||||
"startTime", r.startTime.String(),
|
||||
"nowTime", now.String(),
|
||||
"before", r.firstTime.String(),
|
||||
"after", firstTime.String(),
|
||||
"adjustment", r.firstTime.Sub(firstTime),
|
||||
"nowTS", ts,
|
||||
"extStartTS", r.extStartTS,
|
||||
)
|
||||
if r.firstTime.Sub(firstTime) > firstPacketTimeAdjustThreshold {
|
||||
r.logger.Infow("first packet time adjustment too big, ignoring",
|
||||
|
||||
Reference in New Issue
Block a user