dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-05 17:20:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master' into raja_fr

Browse Source
This commit is contained in:
boks1971
2023-08-31 14:32:39 +05:30
parent c4da8dfd96 bc5b4d68af
commit 4df4be8fa7
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/buffer/buffer.go
+7 -6
View File
@@ -410,6 +410,12 @@ func (b *Buffer) SetRTT(rtt uint32) {
}
func (b *Buffer) calc(pkt []byte, arrivalTime time.Time) {
defer func() {
b.doNACKs()
b.doReports(arrivalTime)
}()
var rtpPacket rtp.Packet
if err := rtpPacket.Unmarshal(pkt); err != nil {
b.logger.Errorw("could not unmarshal RTP packet", err)
@@ -465,10 +471,6 @@ func (b *Buffer) calc(pkt []byte, arrivalTime time.Time) {
return
}
b.doNACKs()
b.doReports(arrivalTime)
ep := b.getExtPacket(&rtpPacket, arrivalTime, flowState)
if ep == nil {
return
@@ -670,8 +672,7 @@ func (b *Buffer) doNACKs() {
}
func (b *Buffer) doReports(arrivalTime time.Time) {
timeDiff := arrivalTime.Sub(b.lastReport)
if timeDiff < ReportDelta {
if time.Since(b.lastReport) < ReportDelta {
return
}