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

feat(mux): Add verbose logging for out-of-order packet handling

Browse Source
This commit is contained in:
zarazaex69
2026-04-09 19:30:17 +03:00
parent 498e956202
commit 3f0cfc4c45
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/mux/mux.go
View File

@@ -67,8 +67,10 @@ func (m *Multiplexer) OpenStream() uint16 {
if _, exists := m.streams[sid]; !exists {
m.streams[sid] = &Stream{
ID: sid,
recvBuf: make([]byte, 0),
ID: sid,
recvBuf: make([]byte, 0),
nextSeq: 0,
outOfOrder: make(map[uint32][]byte),
}
return sid
}
@@ -231,6 +233,7 @@ func (m *Multiplexer) HandleFrame(frame []byte) {
stream.recvBuf = append(stream.recvBuf, nextData...)
delete(stream.outOfOrder, stream.nextSeq)
stream.nextSeq++
logger.Verbose("Applied out-of-order packet sid=%d seq=%d", sid, stream.nextSeq-1)
} else {
break
}
@@ -247,7 +250,10 @@ func (m *Multiplexer) HandleFrame(frame []byte) {
} else if seq > stream.nextSeq {
if len(stream.outOfOrder) < 100 {
stream.outOfOrder[seq] = append([]byte(nil), data...)
logger.Verbose("Buffered out-of-order packet sid=%d seq=%d (expected %d)", sid, seq, stream.nextSeq)
}
} else {
logger.Verbose("Dropped duplicate packet sid=%d seq=%d (expected %d)", sid, seq, stream.nextSeq)
}
}