diff --git a/XMPPHP/XMLStream.php b/XMPPHP/XMLStream.php index 1f32c1a..a39e12e 100644 --- a/XMPPHP/XMLStream.php +++ b/XMPPHP/XMLStream.php @@ -457,7 +457,15 @@ class XMPPHP_XMLStream { } else if ($updated > 0) { $buff = ''; do { - $part = stream_socket_recvfrom($this->socket, 4096); + if ($buff != '') { + //disable blocking for now because fread() will + // block until the 4k are full if we already + // read a part of the packet + stream_set_blocking($this->socket, 0); + } + $part = fread($this->socket, 4096); + stream_set_blocking($this->socket, 1); + if (!$part) { if($this->reconnect) { $this->doReconnect();