Commit c6ed666

committed

fix readPacket when buffered

1 parent fb06250 commit c6ed666Copy full SHA for c6ed666

File tree

+10

-4

lines changed

+10

-4

lines changed

Lines changed: 10 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -241,10 +241,16 @@ private function readPacket()`
`241`	`241`	`{`
`242`	`242`	`if ($packet = fread($this->_sock, self::HEADER_LEN)) {`
`243`	`243`	`$resp = $this->decodePacketHeader($packet);`
`244`		`- if ($len = $resp['contentLength'] + $resp['paddingLength']) {`
`245`		`- $resp['content'] = substr(fread($this->_sock, $len), 0, $resp['contentLength']);`
`246`		`- } else {`
`247`		`- $resp['content'] = '';`
	`244`	`+ $resp['content'] = '';`
	`245`	`+ if ($resp['contentLength']) {`
	`246`	`+ $len = $resp['contentLength'];`
	`247`	`+ while ($len && $buf=fread($this->_sock, $len)) {`
	`248`	`+ $len -= strlen($buf);`
	`249`	`+ $resp['content'] .= $buf;`
	`250`	`+ }`
	`251`	`+ }`
	`252`	`+ if ($resp['paddingLength']) {`
	`253`	`+ $buf=fread($this->_sock, $resp['paddingLength']);`
`248`	`254`	`}`
`249`	`255`	`return $resp;`
`250`	`256`	`} else {`

Comments

(0)