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

Send left over RTCP packets. (#1699)

Browse Source
This commit is contained in:
Raja Subramanian
2023-05-09 18:46:30 +05:30
committed by GitHub
parent cf2a078579
commit f543e3f8d0
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+15 -1
View File
@@ -1347,7 +1347,9 @@ func (p *ParticipantImpl) subscriberRTCPWorker() {
sd = append(sd, chunks...)
batchSize = batchSize + 1 + len(chunks)
if batchSize >= sdBatchSize {
pkts = append(pkts, &rtcp.SourceDescription{Chunks: sd})
if len(sd) != 0 {
pkts = append(pkts, &rtcp.SourceDescription{Chunks: sd})
}
if err := p.TransportManager.WriteSubscriberRTCP(pkts); err != nil {
if err == io.EOF || err == io.ErrClosedPipe {
return
@@ -1361,6 +1363,18 @@ func (p *ParticipantImpl) subscriberRTCPWorker() {
}
}
if len(pkts) != 0 || len(sd) != 0 {
if len(sd) != 0 {
pkts = append(pkts, &rtcp.SourceDescription{Chunks: sd})
}
if err := p.TransportManager.WriteSubscriberRTCP(pkts); err != nil {
if err == io.EOF || err == io.ErrClosedPipe {
return
}
p.params.Logger.Errorw("could not send down track reports", err)
}
}
time.Sleep(3 * time.Second)
}
}
pkg/sfu/buffer/rtpstats.go
+1 -1
View File
@@ -1107,7 +1107,7 @@ func (r *RTPStats) ToString() string {
str := fmt.Sprintf("t: %+v|%+v|%.2fs", p.StartTime.AsTime().Format(time.UnixDate), p.EndTime.AsTime().Format(time.UnixDate), p.Duration)
str += fmt.Sprintf(" sn: %d|%d", r.extStartSN, r.getExtHighestSN())
str += fmt.Sprintf(", sn: %d|%d", r.extStartSN, r.getExtHighestSN())
str += fmt.Sprintf(", ep: %d|%.2f/s", expectedPackets, expectedPacketRate)
str += fmt.Sprintf(", p: %d|%.2f/s", p.Packets, p.PacketRate)