package/gortsplib
1
0
Fork 0
mirror of https://github.com/aler9/gortsplib synced 2025-10-06 15:46:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

rtcpreceiver: rename variable

Browse Source
This commit is contained in:
aler9
2022-11-05 17:26:52 +01:00
parent f20350d3d0
commit b1ed0a8abb
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/rtcpreceiver/rtcpreceiver.go
View File

@@ -39,7 +39,7 @@ type RTCPReceiver struct {
// data from rtcp packets
senderSSRC uint32
lastSenderReportRTP *uint32
lastSenderReportNTP *uint32
lastSenderReportTime time.Time
terminate chan struct{}
@@ -99,7 +99,7 @@ func (rr *RTCPReceiver) report(ts time.Time) rtcp.Packet {
rr.mutex.Lock()
defer rr.mutex.Unlock()
if rr.lastSenderReportRTP == nil || rr.lastSequenceNumber == nil {
if rr.lastSenderReportNTP == nil || rr.lastSequenceNumber == nil {
return nil
}
@@ -109,7 +109,8 @@ func (rr *RTCPReceiver) report(ts time.Time) rtcp.Packet {
{
SSRC: rr.senderSSRC,
LastSequenceNumber: uint32(rr.sequenceNumberCycles)<<16 | uint32(*rr.lastSequenceNumber),
LastSenderReport: *rr.lastSenderReportRTP,
// middle 32 bits out of 64 in the NTP timestamp of last sender report
LastSenderReport: *rr.lastSenderReportNTP,
// equivalent to taking the integer part after multiplying the
// loss fraction by 256
FractionLost: uint8(float64(rr.totalLostSinceReport*256) / float64(rr.totalSinceReport)),
@@ -201,7 +202,7 @@ func (rr *RTCPReceiver) ProcessPacketRTCP(ts time.Time, pkt rtcp.Packet) {
rr.senderSSRC = sr.SSRC
v := uint32(sr.NTPTime >> 16)
rr.lastSenderReportRTP = &v
rr.lastSenderReportNTP = &v
rr.lastSenderReportTime = ts
}
}