diogo/xmpphp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

we can receive messages of any length now, even > 4096 bytes

Browse Source
This commit is contained in:
Christian Weiske 2010-02-25 02:53:13 +08:00 committed by Drarok
parent 582b0a0770
commit b9a9fb85d7
1 changed files with 63 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
XMPPHP/XMLStream.php
View File

@ -288,9 +288,12 @@ class XMPPHP_XMLStream {
/**
* Connect to XMPP Host
*
* @param integer $timeout
* @param integer $timeout Timeout in seconds
* @param boolean $persistent
* @param boolean $sendinit
* @param boolean $sendinit Send XMPP starting sequence after connect
* automatically
*
* @throws XMPPHP_Exception When the connection fails
*/
public function connect($timeout = 30, $persistent = false, $sendinit = true) {
$this->sent_disconnect = false;
@ -330,6 +333,10 @@ class XMPPHP_XMLStream {
/**
* Reconnect XMPP Host
*
* @throws XMPPHP_Exception When the connection fails
* @uses $reconnectTimeout
* @see setReconnectTimeout()
*/
public function doReconnect() {
if(!$this->is_server) {
@ -368,6 +375,41 @@ class XMPPHP_XMLStream {
return $this->disconnected;
}
/**
* Checks if the given string is closed with the same tag as it is
* opened. We try to be as fast as possible here.
*
* @param string $buff Read buffer of __process()
*
* @return boolean true if the buffer seems to be complete
*/
protected function bufferComplete($buff)
{
if (substr($buff, -1) != '>') {
return false;
}
//we always have a space since the namespace needs to be
//declared. could be a tab, though
$start = substr($buff, 1, strpos($buff, ' ', 2) - 1);
$stop = substr($buff, -strlen($start) - 3);
if ($start == '?xml') {
//starting with an xml tag. this means a stream is being
// opened, which is not much of data, so no fear it's
// not complete
return true;
}
if (substr($stop, -2) == '/>') {
//one tag, i.e. <success />
return true;
}
if ('</' . $start . '>' == $stop) {
return true;
}
return false;
}
/**
* Core reading tool
*
@ -410,9 +452,10 @@ class XMPPHP_XMLStream {
return false;
}
} else if ($updated > 0) {
# XXX: Is this big enough?
$buff = @fread($this->socket, 4096);
if(!$buff) {
$buff = '';
do {
$part = stream_socket_recvfrom($this->socket, 4096);
if (!$part) {
if($this->reconnect) {
$this->doReconnect();
} else {
@ -421,7 +464,10 @@ class XMPPHP_XMLStream {
return false;
}
}
$this->log->log("RECV: $buff", XMPPHP_Log::LEVEL_VERBOSE);
$this->log->log("RECV: $part", XMPPHP_Log::LEVEL_VERBOSE);
$buff .= $part;
} while (!$this->bufferComplete($buff));
xml_parse($this->parser, $buff, false);
if ($return_when_received) {
return true;
@ -491,7 +537,10 @@ class XMPPHP_XMLStream {
$maximum = $timeout == -1
? NULL
: time() - $start;
$this->__process($maximum, true);
$ret = $this->__process($maximum, true);
if (!$ret) {
break;
}
}
if (array_key_exists($event_key, $this->until_payload)) {