This commit is contained in:
aozhiwei 2023-08-10 23:34:48 +08:00
parent 2f1f77a36d
commit 581b9e6eab

View File

@ -85,12 +85,14 @@ func (this *WSPListener_) socketRead(conn net.Conn) {
for { for {
prevOffset = offset prevOffset = offset
this.decodePacket(&recvBuf, &offset, recvBufLen) this.decodePacket(&recvBuf, &offset, recvBufLen)
if prevOffset > offset || offset > recvBufLen { if prevOffset >= offset || offset >= recvBufLen {
break break
} }
} }
if offset > 0 && offset < recvBufLen { if offset > 0 && offset < recvBufLen {
copy(recvBuf[:],
recvBuf[offset:recvBufLen - offset])
} }
recvBufLen -= offset recvBufLen -= offset