1
mirror of https://github.com/XTLS/Xray-core.git synced 2025-12-12 12:42:26 +04:00

XTLS Vision: Fix IsCompleteRecord() (#5365)

Fixes https://github.com/XTLS/Xray-core/pull/5179
This commit is contained in:
风扇滑翔翼
2025-12-02 21:01:44 +08:00
committed by GitHub
parent 36cb0f00bd
commit 93312d29e5

View File

@@ -395,64 +395,53 @@ func (w *VisionWriter) WriteMultiBuffer(mb buf.MultiBuffer) error {
// IsCompleteRecord Is complete tls data record
func IsCompleteRecord(buffer buf.MultiBuffer) bool {
mb2 := make(buf.MultiBuffer, 0, len(buffer))
for _, buffer1 := range buffer {
buffer2 := buf.New()
buffer2.Write(buffer1.Bytes())
mb2 = append(mb2, buffer2)
b := make([]byte, buffer.Len())
if buffer.Copy(b) != int(buffer.Len()) {
panic("impossible bytes allocation")
}
isComplete := true
var headerLen int32 = 5
var recordLen int32
for _, buffer2 := range mb2 {
for buffer2.Len() > 0 {
var headerLen int = 5
var recordLen int
totalLen := len(b)
i := 0
for i < totalLen {
// record header: 0x17 0x3 0x3 + 2 bytes length
if headerLen > 0 {
data, _ := buffer2.ReadByte()
data := b[i]
i++
switch headerLen {
case 5:
if data != 0x17 {
isComplete = false
break
return false
}
case 4:
if data != 0x03 {
isComplete = false
break
return false
}
case 3:
if data != 0x03 {
isComplete = false
break
return false
}
case 2:
recordLen = int32(data) << 8
recordLen = int(data) << 8
case 1:
recordLen = recordLen | int32(data)
recordLen = recordLen | int(data)
}
headerLen--
} else if recordLen > 0 {
var len = recordLen
if buffer2.Len() < recordLen{
len = buffer2.Len()
}
buffer2.Advance(len)
recordLen -= len
if recordLen == 0 {
remaining := totalLen - i
if remaining < recordLen {
return false
} else {
i += recordLen
recordLen = 0
headerLen = 5
}
} else {
isComplete = false
return false
}
}
if !isComplete {
break
}
}
for _, buffer2 := range mb2 {
buffer2.Release()
buffer2 = nil
}
if headerLen == 5 && recordLen == 0 && isComplete {
if headerLen == 5 && recordLen == 0 {
return true
}
return false