eliseuamaro/gnu-social
1
0
Fork 0
forked from GNUsocial/gnu-social
Code Issues Pull Requests Releases Wiki Activity

slightly better timing

Browse Source
This commit is contained in:
Evan Prodromou 2009-07-09 11:40:01 -04:00
parent d7611009b1
commit 1daad01f36
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/stompqueuemanager.php
View File

@ -117,9 +117,12 @@ class StompQueueManager
} }
unset($frame); unset($frame);
}
$handler->idle(0); $handler->idle(QUEUE_HANDLER_HIT_IDLE);
} else {
$handler->idle(QUEUE_HANDLER_MISS_IDLE);
}
} }
$this->con->unsubscribe($this->_queueName($queue)); $this->con->unsubscribe($this->_queueName($queue));

9
lib/xmppqueuehandler.php
View File

@ -21,6 +21,8 @@ if (!defined('LACONICA')) { exit(1); }
require_once(INSTALLDIR.'/lib/queuehandler.php'); require_once(INSTALLDIR.'/lib/queuehandler.php');
define('PING_INTERVAL', 120);
/** /**
* Common superclass for all XMPP-using queue handlers. They all need to * Common superclass for all XMPP-using queue handlers. They all need to
* service their message queues on idle, and forward any incoming messages * service their message queues on idle, and forward any incoming messages
@ -31,6 +33,7 @@ require_once(INSTALLDIR.'/lib/queuehandler.php');
class XmppQueueHandler extends QueueHandler class XmppQueueHandler extends QueueHandler
{ {
var $pingid = 0; var $pingid = 0;
var $lastping = null;
function start() function start()
{ {
@ -64,7 +67,11 @@ class XmppQueueHandler extends QueueHandler
if ($this->conn) { if ($this->conn) {
$this->log(LOG_DEBUG, "Servicing the XMPP queue."); $this->log(LOG_DEBUG, "Servicing the XMPP queue.");
$this->conn->processTime($timeout); $this->conn->processTime($timeout);
$this->sendPing(); $now = time();
if (empty($this->lastping) || $now - $this->lastping > PING_INTERVAL) {
$this->sendPing();
$this->lastping = $now;
}
} }
} catch (XMPPHP_Exception $e) { } catch (XMPPHP_Exception $e) {
$this->log(LOG_ERR, "Got an XMPPHP_Exception: " . $e->getMessage()); $this->log(LOG_ERR, "Got an XMPPHP_Exception: " . $e->getMessage());