diff options
| author | fabrixxm <fabrix.xm@gmail.com> | 2011-09-05 21:05:24 +0200 |
|---|---|---|
| committer | fabrixxm <fabrix.xm@gmail.com> | 2011-09-05 21:05:24 +0200 |
| commit | 2f5a34ad1791f01cacb3b86c11501f0e11c67df4 (patch) | |
| tree | dd9242b14387c833346f4172e3f190659db56ff7 /include/queue.php | |
| parent | 5ec4a4e6deb5d28cbfab54093f8b4180912738d4 (diff) | |
| parent | 08e54234e30c10e3130b7d71caba9fd43e3593e3 (diff) | |
| download | volse-hubzilla-2f5a34ad1791f01cacb3b86c11501f0e11c67df4.tar.gz volse-hubzilla-2f5a34ad1791f01cacb3b86c11501f0e11c67df4.tar.bz2 volse-hubzilla-2f5a34ad1791f01cacb3b86c11501f0e11c67df4.zip | |
Merge branch 'newui' of github.com:fabrixxm/friendika into newui
Diffstat (limited to 'include/queue.php')
| -rw-r--r-- | include/queue.php | 32 |
1 files changed, 22 insertions, 10 deletions
diff --git a/include/queue.php b/include/queue.php index f1bcf2e9f..5119a65d8 100644 --- a/include/queue.php +++ b/include/queue.php @@ -3,18 +3,18 @@ require_once("boot.php"); require_once('include/queue_fn.php'); function queue_run($argv, $argc){ - global $a, $db; + global $a, $db; - if(is_null($a)){ - $a = new App; - } + 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); - }; + 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"); @@ -38,6 +38,18 @@ function queue_run($argv, $argc){ logger('queue: start'); + $interval = ((get_config('system','delivery_interval') === false) ? 2 : intval(get_config('system','delivery_interval'))); + + $r = q("select * from deliverq where 1"); + if(count($r)) { + foreach($r as $rr) { + logger('queue: deliverq'); + proc_run('php','include/delivery.php',$rr['cmd'],$rr['item'],$rr['contact']); + if($interval) + @time_sleep_until(microtime(true) + (float) $interval); + } + } + $r = q("SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue` LEFT JOIN `contact` ON `queue`.`cid` = `contact`.`id` WHERE `queue`.`created` < UTC_TIMESTAMP() - INTERVAL 3 DAY"); |