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

Address comments from #1998 (#2006)

Browse Source
This commit is contained in:
David Zhao
2023-08-27 22:50:36 -07:00
committed by GitHub
parent 35f5629910
commit 64bcef28aa
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/rtc/room.go
View File

@@ -1331,7 +1331,7 @@ func BroadcastDataPacketForRoom(r types.Room, source types.LocalParticipant, dp
utils.ParallelExec(destParticipants, dataForwardLoadBalanceThreshold, 1, func(op types.LocalParticipant) {
err := op.SendDataPacket(dp, dpData)
if err != nil && !errors.Is(err, io.ErrClosedPipe) && !errors.Is(err, psrpc.Canceled) &&
errors.Is(err, psrpc.ErrStreamClosed) {
!errors.Is(err, psrpc.ErrStreamClosed) {
op.GetLogger().Infow("send data packet error", "error", err)
}
})

2
pkg/sfu/buffer/rtpstats.go
View File

@@ -838,7 +838,7 @@ func (r *RTPStats) maybeAdjustFirstPacketTime(ets uint64) {
"extStartTS", r.timestamp.GetExtendedStart(),
)
if r.firstTime.Sub(firstTime) > firstPacketTimeAdjustThreshold {
r.logger.Debugw("first packet time adjustment too big, ignoring",
r.logger.Infow("first packet time adjustment too big, ignoring",
"startTime", r.startTime.String(),
"nowTime", now.String(),
"before", r.firstTime.String(),