dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-13 07:55:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use sampling only for closed pipe errors (#928)

Browse Source
This commit is contained in:
Raja Subramanian
2022-08-17 13:58:03 +05:30
committed by GitHub
parent f819dcb63d
commit c9d16ea98c
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/downtrack.go
+9 -5
View File
@@ -153,8 +153,8 @@ type DownTrack struct {
deltaStatsSnapshotId uint32
// Debug info
pktsDropped atomic.Uint32
writeErrors atomic.Uint32
pktsDropped atomic.Uint32
writeIOErrors atomic.Uint32
isNACKThrottled atomic.Bool
@@ -475,9 +475,13 @@ func (d *DownTrack) WriteRTP(extPkt *buffer.ExtPacket, layer int32) error {
_, err = d.writeStream.WriteRTP(hdr, payload)
if err != nil {
d.pktsDropped.Inc()
writeErrors := d.writeErrors.Inc()
if (writeErrors % 100) == 1 {
d.logger.Errorw("write rtp packet failed", err, "count", writeErrors)
if errors.Is(err, io.ErrClosedPipe) {
writeIOErrors := d.writeIOErrors.Inc()
if (writeIOErrors % 100) == 1 {
d.logger.Errorw("write rtp packet failed", err, "count", writeIOErrors)
}
} else {
d.logger.Errorw("write rtp packet failed", err)
}
return err
}