X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FCron.php;h=1901766d3ac1d4d341f69322388c902ae8704b44;hb=bf8fb215a9cc554b5ec5b774168a52fb56fa43e6;hp=cd6c2d39ecd75b05df90e8e16c48deae596a9562;hpb=41e07a9ae28b9742de9a32b5a43a87ae9a5ffc32;p=friendica.git diff --git a/src/Worker/Cron.php b/src/Worker/Cron.php index cd6c2d39ec..1901766d3a 100644 --- a/src/Worker/Cron.php +++ b/src/Worker/Cron.php @@ -25,6 +25,7 @@ use Friendica\Core\Hook; use Friendica\Core\Logger; use Friendica\Core\Worker; use Friendica\DI; +use Friendica\Model\Tag; class Cron { @@ -54,13 +55,16 @@ class Cron } // Fork the cron jobs in separate parts to avoid problems when one of them is crashing - Hook::fork($a->queue['priority'], 'cron'); + Hook::fork(PRIORITY_MEDIUM, 'cron'); // Poll contacts - Worker::add(PRIORITY_HIGH, 'PollContacts'); + Worker::add(PRIORITY_MEDIUM, 'PollContacts'); // Update contact information - Worker::add(PRIORITY_LOW, 'UpdatePublicContacts'); + Worker::add(PRIORITY_LOW, 'UpdateContacts'); + + // Update server information + Worker::add(PRIORITY_LOW, 'UpdateGServers'); // run the process to update server directories in the background Worker::add(PRIORITY_LOW, 'UpdateServerDirectories'); @@ -71,19 +75,20 @@ class Cron // Call possible post update functions Worker::add(PRIORITY_LOW, 'PostUpdate'); - // Repair entries in the database - Worker::add(PRIORITY_LOW, 'RepairDatabase'); - // Hourly cron calls if (DI::config()->get('system', 'last_cron_hourly', 0) + 3600 < time()) { + // Update trending tags cache for the community page + Tag::setLocalTrendingHashtags(24, 20); + Tag::setGlobalTrendingHashtags(24, 20); + // Search for new contacts in the directory if (DI::config()->get('system', 'synchronize_directory')) { Worker::add(PRIORITY_LOW, 'PullDirectory'); } // Delete all done workerqueue entries - Worker::add(PRIORITY_LOW, 'ClearWorkerqueue'); + Worker::add(PRIORITY_LOW, 'CleanWorkerQueue'); // Clear cache entries Worker::add(PRIORITY_LOW, 'ClearCache'); @@ -91,8 +96,8 @@ class Cron DI::config()->set('system', 'last_cron_hourly', time()); } - // Daily cron calls - if (DI::config()->get('system', 'last_cron_daily', 0) + 86400 < time()) { + // Daily maintenance cron calls + if (Worker::isInMaintenanceWindow(true)) { Worker::add(PRIORITY_LOW, 'UpdateContactBirthdays'); @@ -101,20 +106,25 @@ class Cron // update nodeinfo data Worker::add(PRIORITY_LOW, 'NodeInfo'); - Worker::add(PRIORITY_LOW, 'UpdateGServers'); + // Repair entries in the database + Worker::add(PRIORITY_LOW, 'RepairDatabase'); Worker::add(PRIORITY_LOW, 'Expire'); - Worker::add(PRIORITY_MEDIUM, 'DBClean'); + Worker::add(PRIORITY_LOW, 'ExpirePosts'); Worker::add(PRIORITY_LOW, 'ExpireConversations'); Worker::add(PRIORITY_LOW, 'CleanItemUri'); + Worker::add(PRIORITY_LOW, 'RemoveUnusedContacts'); + + Worker::add(PRIORITY_LOW, 'RemoveUnusedAvatars'); + // check upstream version? Worker::add(PRIORITY_LOW, 'CheckVersion'); - Worker::add(PRIORITY_LOW, 'CheckdeletedContacts'); + Worker::add(PRIORITY_LOW, 'CheckDeletedContacts'); if (DI::config()->get('system', 'optimize_tables')) { Worker::add(PRIORITY_LOW, 'OptimizeTables');