Skip to content

Commit 4141519

Browse files
authored
Check SSRC on SR (#754)
1 parent dd3b698 commit 4141519

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/synchronizer/track.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,7 @@ func (t *TrackSynchronizer) Initialize(pkt *rtp.Packet) {
148148
t.logger.Infow(
149149
"initialized track synchronizer",
150150
"state", t,
151+
"SSRC", t.track.SSRC(),
151152
"maxTsDiff", t.maxTsDiff,
152153
"maxDriftAdjustment", t.maxDriftAdjustment,
153154
"driftAdjustmentWindowPercent", t.driftAdjustmentWindowPercent,
@@ -422,6 +423,10 @@ func (t *TrackSynchronizer) getPTSWithRebase(pkt jitter.ExtPacket) (time.Duratio
422423

423424
// onSenderReport handles pts adjustments for a track
424425
func (t *TrackSynchronizer) onSenderReport(pkt *rtcp.SenderReport) {
426+
if pkt.SSRC != uint32(t.track.SSRC()) {
427+
return
428+
}
429+
425430
if t.rtcpSenderReportRebaseEnabled {
426431
t.onSenderReportWithRebase(pkt)
427432
} else {
@@ -784,6 +789,7 @@ func (w wrappedAugmentedSenderReportLogger) MarshalLogObject(e zapcore.ObjectEnc
784789
return nil
785790
}
786791

792+
e.AddUint32("SSRC", asr.SSRC)
787793
e.AddUint32("RTPTime", asr.RTPTime)
788794
e.AddTime("NTPTime", mediatransportutil.NtpTime(asr.NTPTime).Time())
789795
e.AddUint32("PacketCount", asr.PacketCount)

0 commit comments

Comments
 (0)