dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-03-30 19:55:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log when dropping data packet by slow reader (#3429)

Browse Source
This commit is contained in:
cnderrauber
2025-02-13 15:26:22 +08:00
committed by GitHub
parent 7e4df818ee
commit 148a2af151
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/rtc/transportmanager.go
View File

@@ -134,6 +134,8 @@ type TransportManager struct {
signalingRTT, udpRTT uint32
onICEConfigChanged func(iceConfig *livekit.ICEConfig)
droppedBySlowReaderCount atomic.Uint32
}
func NewTransportManager(params TransportManagerParams) (*TransportManager, error) {
@@ -301,7 +303,10 @@ func (t *TransportManager) SendDataPacket(kind livekit.DataPacket_Kind, encoded
if err != nil {
if !utils.ErrorIsOneOf(err, io.ErrClosedPipe, sctp.ErrStreamClosed, ErrTransportFailure, ErrDataChannelBufferFull, context.DeadlineExceeded) {
if errors.Is(err, datachannel.ErrDataDroppedBySlowReader) {
t.params.Logger.Debugw("slow data reader", "error", err)
droppedBySlowReaderCount := t.droppedBySlowReaderCount.Inc()
if (droppedBySlowReaderCount-1)%100 == 0 {
t.params.Logger.Infow("drop data packet by slow reader", "error", err, "kind", kind, "count", droppedBySlowReaderCount)
}
} else {
t.params.Logger.Warnw("send data packet error", err)
}