summaryrefslogtreecommitdiff
path: root/lib/queuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@prodromou.name>2008-09-04 14:40:31 -0400
committerEvan Prodromou <evan@prodromou.name>2008-09-04 14:40:31 -0400
commitaed0fff4ea668de83405a4457fe238cf36c78d8f (patch)
tree21c3c184e49c4599bbd7e96f18225d831a56cd66 /lib/queuehandler.php
parent95d9920d7861fb4a070a2ac2ebe19deb7432c5ab (diff)
scripts daemonize themselves
darcs-hash:20080904184031-84dde-eba2061f3aa898d0c791ffeb70837f759778c567.gz
Diffstat (limited to 'lib/queuehandler.php')
-rw-r--r--lib/queuehandler.php19
1 files changed, 17 insertions, 2 deletions
diff --git a/lib/queuehandler.php b/lib/queuehandler.php
index 3115ea38d..d673f7f94 100644
--- a/lib/queuehandler.php
+++ b/lib/queuehandler.php
@@ -19,7 +19,11 @@
define('CLAIM_TIMEOUT', 1200);
-class QueueHandler {
+if (!defined('LACONICA')) { exit(1); }
+
+require_once(INSTALLDIR.'/lib/daemon.php');
+
+class QueueHandler extends Daemon {
var $_id = 'generic';
@@ -32,6 +36,10 @@ class QueueHandler {
function class_name() {
return ucfirst($this->transport()) . 'Handler';
}
+
+ function name() {
+ return strtolower($this->class_name().'.'.$this->get_id());
+ }
function get_id() {
return $this->_id;
@@ -55,7 +63,10 @@ class QueueHandler {
return true;
}
- function handle_queue() {
+ function run() {
+ if (!$this->start()) {
+ return false;
+ }
$this->log(LOG_INFO, 'checking for queued notices');
$transport = $this->transport();
do {
@@ -87,6 +98,10 @@ class QueueHandler {
$this->idle(5);
}
} while (true);
+ if (!$this->finish()) {
+ return false;
+ }
+ return true;
}
function idle($timeout=0) {