socket: fix handling frames split over >2 chunks

tulir · tulir · commit 2a1c029c242f · 2025-02-12T16:35:11.000+02:00
Fixes #718
diff --git a/socket/framesocket.go b/socket/framesocket.go
@@ -199,7 +199,7 @@ func (fs *FrameSocket) processData(msg []byte) {
 				msg = nil
 			}
 		} else {
-			if len(fs.incoming)+len(msg) >= fs.incomingLength {
+			if fs.receivedLength+len(msg) >= fs.incomingLength {
 				copy(fs.incoming[fs.receivedLength:], msg[:fs.incomingLength-fs.receivedLength])
 				msg = msg[fs.incomingLength-fs.receivedLength:]
 				fs.frameComplete()

Original file line number	Diff line number	Diff line change
`@@ -199,7 +199,7 @@ func (fs *FrameSocket) processData(msg []byte) {`
`199`	`199`	`msg = nil`
`200`	`200`	`}`
`201`	`201`	`} else {`
`202`		`- if len(fs.incoming)+len(msg) >= fs.incomingLength {`
	`202`	`+ if fs.receivedLength+len(msg) >= fs.incomingLength {`
`203`	`203`	`copy(fs.incoming[fs.receivedLength:], msg[:fs.incomingLength-fs.receivedLength])`
`204`	`204`	`msg = msg[fs.incomingLength-fs.receivedLength:]`
`205`	`205`	`fs.frameComplete()`