GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

send a ping from the xmppdaemon

Browse Source
This commit is contained in:
Evan Prodromou 2009-07-09 09:31:10 -04:00
parent 8aef0e4271
commit d77a2ee6ad
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
scripts/xmppdaemon.php
View File

@ -60,7 +60,9 @@ class XMPPDaemon extends Daemon
$this->resource = common_config('xmpp', 'resource') . 'daemon'; $this->resource = common_config('xmpp', 'resource') . 'daemon';
} }
$this->log(LOG_INFO, "INITIALIZE XMPPDaemon {$this->user}@{$this->server}/{$this->resource}"); $this->jid = $this->user.'@'.$this->server.'/'.$this->resource;
$this->log(LOG_INFO, "INITIALIZE XMPPDaemon {$this->jid}");
} }
function connect() function connect()
@ -106,10 +108,25 @@ class XMPPDaemon extends Daemon
$this->log(LOG_DEBUG, "Beginning processing loop."); $this->log(LOG_DEBUG, "Beginning processing loop.");
$this->conn->process(); while ($this->conn->processTime(60)) {
$this->sendPing();
}
} }
} }
function sendPing()
{
if (!isset($this->pingid)) {
$this->pingid = 0;
} else {
$this->pingid++;
}
$this->log(LOG_DEBUG, "Sending ping #{$this->pingid}");
$this->conn->send("<iq from='{$this->jid}' to='{$this->server}' id='ping_{$this->pingid}' type='get'><ping xmlns='urn:xmpp:ping'/></iq>");
}
function handle_reconnect(&$pl) function handle_reconnect(&$pl)
{ {
$this->log(LOG_DEBUG, "Got reconnection callback."); $this->log(LOG_DEBUG, "Got reconnection callback.");