more optimising when confronted with dead servers

[friendica.git] / include / queue.php

diff --git a/include/queue.php b/include/queue.php
index b7fb478b4e3aab2329c52a6d7148c5487b0431d0..837ae31d77dffbc4f0582f55447033cb750e2a52 100644 (file)
--- a/include/queue.php
+++ b/include/queue.php
@@ -1,7 +1,7 @@
 <?php
 
 
-function update_queue_item($id) {
+function update_queue_time($id) {
        logger('queue: requeue item ' . $id);
        q("UPDATE `queue` SET `last` = '%s' WHERE `id` = %d LIMIT 1",
                dbesc(datetime_convert()),
@@ -33,6 +33,7 @@ function remove_queue_item($id) {
 
        $a->set_baseurl(get_config('system','url'));
 
+       logger('queue: start');
 
        $r = q("SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue` 
                LEFT JOIN `contact` ON `queue`.`cid` = `contact`.`id` 
@@ -45,7 +46,7 @@ function remove_queue_item($id) {
                q("DELETE FROM `queue` WHERE `created` < UTC_TIMESTAMP() - INTERVAL 3 DAY");
        }
                
-       $r = q("SELECT `id` FROM `queue` WHERE 1 ");
+       $r = q("SELECT `id` FROM `queue` WHERE `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ");
 
        if(! count($r))
                killme();
@@ -62,7 +63,7 @@ function remove_queue_item($id) {
                        continue;
 
                $c = q("SELECT * FROM `contact` WHERE `id` = %d LIMIT 1",
-                       intval($q_item['cid'])
+                       intval($qi[0]['cid'])
                );
                if(! count($c)) {
                        remove_queue_item($q_item['id']);