Queue.php is now moved as well

This commit is contained in:
Michael 2017-11-19 16:35:45 +00:00
parent 501514bd54
commit 98686e9091
4 changed files with 190 additions and 195 deletions

View file

@ -58,13 +58,13 @@ class Expire {
logger('expire: start');
Worker::add(array('priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true),
'expire', 'delete');
'Expire', 'delete');
$r = dba::p("SELECT `uid`, `username` FROM `user` WHERE `expire` != 0");
while ($row = dba::fetch($r)) {
logger('Calling expiry for user '.$row['uid'].' ('.$row['username'].')', LOGGER_DEBUG);
Worker::add(array('priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true),
'expire', (int)$row['uid']);
'Expire', (int)$row['uid']);
}
dba::close($r);
@ -74,7 +74,7 @@ class Expire {
foreach ($a->hooks['expire'] as $hook) {
logger("Calling expire hook for '" . $hook[1] . "'", LOGGER_DEBUG);
Worker::add(array('priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true),
'expire', 'hook', $hook[1]);
'Expire', 'hook', $hook[1]);
}
}