X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FCron.php;h=b9a8c0f2ecf34258bb828a834ea662caeb733477;hb=066ad8c01b25b7101ad6fb36878d85c97db51a6f;hp=9510063337f5da31756ed3a5c1613976c7256a28;hpb=e511790d629c6057a52a0adb3aca8fc517501a1c;p=friendica.git diff --git a/src/Worker/Cron.php b/src/Worker/Cron.php index 9510063337..b9a8c0f2ec 100644 --- a/src/Worker/Cron.php +++ b/src/Worker/Cron.php @@ -8,14 +8,13 @@ use Friendica\BaseObject; use Friendica\Core\Addon; use Friendica\Core\Config; use Friendica\Core\Hook; +use Friendica\Core\Logger; use Friendica\Core\Protocol; use Friendica\Core\Worker; use Friendica\Database\DBA; use Friendica\Model\Contact; use Friendica\Util\DateTimeFormat; -require_once 'include/dba.php'; - class Cron { public static function execute($parameter = '', $generation = 0) @@ -38,12 +37,12 @@ class Cron if ($last) { $next = $last + ($poll_interval * 60); if ($next > time()) { - logger('cron intervall not reached'); + Logger::log('cron intervall not reached'); return; } } - logger('cron: start'); + Logger::log('cron: start'); // Fork the cron jobs in separate parts to avoid problems when one of them is crashing Hook::fork($a->queue['priority'], "cron"); @@ -124,7 +123,7 @@ class Cron // Poll contacts self::pollContacts($parameter, $generation); - logger('cron: end'); + Logger::log('cron: end'); Config::set('system', 'last_cron', time()); @@ -134,25 +133,24 @@ class Cron /** * @brief Poll contacts for unreceived messages * - * @todo Currently it seems as if the following parameter aren't used at all ... + * @todo Currently it seems as if the following parameter aren't used at all ... * - * @param string $parameter Parameter (force, restart, ...) for the contact polling + * @param string $parameter Parameter (force, restart, ...) for the contact polling * @param integer $generation + * @throws \Friendica\Network\HTTPException\InternalServerErrorException */ private static function pollContacts($parameter, $generation) { $manual_id = 0; $generation = 0; $force = false; - $restart = false; if ($parameter == 'force') { $force = true; } if ($parameter == 'restart') { - $restart = true; $generation = intval($generation); if (!$generation) { - killme(); + exit(); } } @@ -167,8 +165,6 @@ class Cron Addon::reload(); - $d = DateTimeFormat::utcNow(); - // Only poll from those with suitable relationships, // and which have a polling address and ignore Diaspora since // we are unable to match those posts with a Diaspora GUID and prevent duplicates. @@ -287,7 +283,7 @@ class Cron $priority = PRIORITY_LOW; } - logger("Polling " . $contact["network"] . " " . $contact["id"] . " " . $contact['priority'] . " " . $contact["nick"] . " " . $contact["name"]); + Logger::log("Polling " . $contact["network"] . " " . $contact["id"] . " " . $contact['priority'] . " " . $contact["nick"] . " " . $contact["name"]); Worker::add(['priority' => $priority, 'dont_fork' => true], 'OnePoll', (int)$contact['id']); }