GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-05-28 16:09:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(vp8channel): change verbose info logs to debug level

Browse Source
This commit is contained in:
zarazaex69
2026-05-07 21:42:16 +03:00
parent 65510da410
commit 474ee8f34b
2 changed files with 7 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/transport/vp8channel/kcp.go
View File

@@ -1,5 +1,5 @@
/*
ЯНДЕКС ИНЖЕНЕР ЧИТАЮЩИЙ ЭТО
ЯНДЕКС РАБ ИЛИ КТО ТЫ НАУЙ СУКА КАРОЧЕ ХУЙЛО КЕБАНОГЕ ИЗ ЯНДЕКС ЧИТАЮЩИЙ ЭТО
МЫ ОСЕМЕНИМ ВТОЮ МАМАШКУ МЕРТВУЮ
*/
// Package vp8channel provides byte transport over VP8 video frames using KCP.

36
internal/transport/vp8channel/transport.go
View File

@@ -474,7 +474,7 @@ func (p *streamTransport) readVP8Track(track *webrtc.TrackRemote) {
for {
n, _, err := track.Read(buf)
if err != nil {
logger.Infof("vp8channel: readVP8Track exit err=%v rtpPkts=%d frames=%d unmarshalErr=%d depackErr=%d",
logger.Debugf("vp8channel: readVP8Track exit err=%v rtpPkts=%d frames=%d unmarshalErr=%d depackErr=%d",
err, rtpCount, frameCount, unmarshalErr, depackErr)
return
}
@@ -486,32 +486,15 @@ func (p *streamTransport) readVP8Track(track *webrtc.TrackRemote) {
}
rtpCount++
if rtpCount == 1 || rtpCount == 10 || rtpCount == 100 {
logger.Infof("vp8channel: rtp#%d seq=%d marker=%v payloadLen=%d payloadFirst=%x",
rtpCount, pkt.SequenceNumber, pkt.Marker, len(pkt.Payload),
func() []byte {
if len(pkt.Payload) > 8 {
return pkt.Payload[:8]
}
return pkt.Payload
}())
}
logger.Debugf("vp8channel: rtp seq=%d marker=%v payloadLen=%d", pkt.SequenceNumber, pkt.Marker, len(pkt.Payload))
var vp8Pkt codecs.VP8Packet
vp8Payload, derr := vp8Pkt.Unmarshal(pkt.Payload)
if derr != nil {
depackErr++
if depackErr <= 3 {
logger.Infof("vp8channel: VP8 depack error #%d: %v payloadFirst=%x", depackErr, derr,
func() []byte {
if len(pkt.Payload) > 8 {
return pkt.Payload[:8]
}
return pkt.Payload
}())
}
} else if rtpCount <= 3 {
logger.Infof("vp8channel: vp8pkt S=%d marker=%v payloadLen=%d", vp8Pkt.S, pkt.Marker, len(vp8Payload))
logger.Debugf("vp8channel: VP8 depack error #%d: %v", depackErr, derr)
} else {
logger.Debugf("vp8channel: vp8pkt S=%d marker=%v payloadLen=%d", vp8Pkt.S, pkt.Marker, len(vp8Payload))
}
frame := state.processRTPPacket(pkt)
@@ -520,14 +503,7 @@ func (p *streamTransport) readVP8Track(track *webrtc.TrackRemote) {
}
frameCount++
if frameCount <= 10 {
preview := frame
if len(preview) > 16 {
preview = preview[:16]
}
logger.Infof("vp8channel: frame #%d rtpPkts=%d len=%d first=%x",
frameCount, rtpCount, len(frame), preview)
}
logger.Debugf("vp8channel: frame #%d len=%d", frameCount, len(frame))
p.handleIncomingFrame(frame)
}