github/kcp-go
4
0
Fork 0
mirror of https://github.com/xtaci/kcp-go.git synced 2026-10-21 08:58:37 +00:00
Code Issues Releases Wiki Activity

add loc

Browse Source
This commit is contained in:
xtaci
2020-10-09 22:38:31 +08:00
parent ce66a98f95
commit bdaf81e88e
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sess.go
+2
View File
@@ -814,12 +814,14 @@ func (l *Listener) packetInput(data []byte, addr net.Addr) {
convRecovered := false convRecovered := false
fecFlag := binary.LittleEndian.Uint16(data[4:]) fecFlag := binary.LittleEndian.Uint16(data[4:])
if fecFlag == typeData || fecFlag == typeParity { // 16bit kcp cmd [81-84] and frg [0-255] will not overlap with FEC type 0x00f1 0x00f2 if fecFlag == typeData || fecFlag == typeParity { // 16bit kcp cmd [81-84] and frg [0-255] will not overlap with FEC type 0x00f1 0x00f2
// packet with FEC
if fecFlag == typeData && len(data) >= fecHeaderSizePlus2+IKCP_OVERHEAD { if fecFlag == typeData && len(data) >= fecHeaderSizePlus2+IKCP_OVERHEAD {
conv = binary.LittleEndian.Uint32(data[fecHeaderSizePlus2:]) conv = binary.LittleEndian.Uint32(data[fecHeaderSizePlus2:])
sn = binary.LittleEndian.Uint32(data[fecHeaderSizePlus2+IKCP_SN_OFFSET:]) sn = binary.LittleEndian.Uint32(data[fecHeaderSizePlus2+IKCP_SN_OFFSET:])
convRecovered = true convRecovered = true
} }
} else { } else {
// packet without FEC
conv = binary.LittleEndian.Uint32(data) conv = binary.LittleEndian.Uint32(data)
sn = binary.LittleEndian.Uint32(data[IKCP_SN_OFFSET:]) sn = binary.LittleEndian.Uint32(data[IKCP_SN_OFFSET:])
convRecovered = true convRecovered = true