aboutsummaryrefslogtreecommitdiffstats
path: root/include/queue.php
diff options
context:
space:
mode:
authorFabio Comuni <fabrix.xm@gmail.com>2011-01-28 14:04:18 +0100
committerFabio Comuni <fabrix.xm@gmail.com>2011-01-28 14:04:18 +0100
commitef33ca67501559fba72281f0d1f32fc6ef43704d (patch)
tree0b2de9873bc07cad0265241d0277a0f661898781 /include/queue.php
parent517d6812dabfbb93b34045048e8894fb54d220a7 (diff)
downloadvolse-hubzilla-ef33ca67501559fba72281f0d1f32fc6ef43704d.tar.gz
volse-hubzilla-ef33ca67501559fba72281f0d1f32fc6ef43704d.tar.bz2
volse-hubzilla-ef33ca67501559fba72281f0d1f32fc6ef43704d.zip
modded scripts to be runned in cli so they can be included and executed in main program
Diffstat (limited to 'include/queue.php')
-rw-r--r--include/queue.php31
1 files changed, 20 insertions, 11 deletions
diff --git a/include/queue.php b/include/queue.php
index fae93e328..d4fc7dbd6 100644
--- a/include/queue.php
+++ b/include/queue.php
@@ -1,5 +1,5 @@
<?php
-
+require_once("boot.php");
function update_queue_time($id) {
logger('queue: requeue item ' . $id);
@@ -16,14 +16,19 @@ function remove_queue_item($id) {
);
}
- require_once("boot.php");
-
- $a = new App;
+function queue_run($argv, $argc){
+ global $a, $db;
- @include(".htconfig.php");
- require_once("dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
+ if(is_null($a)){
+ $a = new App;
+ }
+
+ if(is_null($db)){
+ @include(".htconfig.php");
+ require_once("dba.php");
+ $db = new dba($db_host, $db_user, $db_pass, $db_data);
+ unset($db_host, $db_user, $db_pass, $db_data);
+ };
require_once("session.php");
@@ -51,7 +56,7 @@ function remove_queue_item($id) {
$r = q("SELECT `id` FROM `queue` WHERE `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ");
if(! count($r)){
- killme(); return;
+ return;
}
// delivery loop
@@ -118,7 +123,11 @@ function remove_queue_item($id) {
}
}
- killme();
+ return;
- // NOTREACHED
+}
+if (array_search(__file__,get_included_files())===0){
+ queue_run($argv,$argc);
+ killme();
+}