diff options
author | Evan Prodromou <evan@prodromou.name> | 2008-09-04 14:40:31 -0400 |
---|---|---|
committer | Evan Prodromou <evan@prodromou.name> | 2008-09-04 14:40:31 -0400 |
commit | aed0fff4ea668de83405a4457fe238cf36c78d8f (patch) | |
tree | 21c3c184e49c4599bbd7e96f18225d831a56cd66 /lib/queuehandler.php | |
parent | 95d9920d7861fb4a070a2ac2ebe19deb7432c5ab (diff) |
scripts daemonize themselves
darcs-hash:20080904184031-84dde-eba2061f3aa898d0c791ffeb70837f759778c567.gz
Diffstat (limited to 'lib/queuehandler.php')
-rw-r--r-- | lib/queuehandler.php | 19 |
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) { |