X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=mod%2Fworker.php;h=2995775db1b18e05a12ad099994d838f96e3ae75;hb=41663c7592abe55a958632c3a48265e0a8544d2b;hp=7b2acad6cdc10dcf6b464ef319e6d6a3221f0fb2;hpb=d9bdba491a59e9f35752f4508d0fef7a085263b7;p=friendica.git diff --git a/mod/worker.php b/mod/worker.php index 7b2acad6cd..2995775db1 100644 --- a/mod/worker.php +++ b/mod/worker.php @@ -5,9 +5,13 @@ */ use Friendica\Core\Config; +use Friendica\Core\Logger; use Friendica\Core\Worker; +use Friendica\Database\DBA; +use Friendica\Util\DateTimeFormat; -function worker_init(){ +function worker_init() +{ if (!Config::get("system", "frontend_worker")) { return; @@ -30,19 +34,20 @@ function worker_init(){ Worker::startProcess(); - logger("Front end worker started: ".getmypid()); + Logger::log("Front end worker started: ".getmypid()); Worker::callWorker(); - if ($r = Worker::workerProcess()) { + $passing_slow = false; + if ($r = Worker::workerProcess($passing_slow)) { // On most configurations this parameter wouldn't have any effect. // But since it doesn't destroy anything, we just try to get more execution time in any way. set_time_limit(0); $fields = ['executed' => DateTimeFormat::utcNow(), 'pid' => getmypid(), 'done' => false]; $condition = ['id' => $r[0]["id"], 'pid' => 0]; - if (dba::update('workerqueue', $fields, $condition)) { + if (DBA::update('workerqueue', $fields, $condition)) { Worker::execute($r[0]); } } @@ -53,7 +58,7 @@ function worker_init(){ Worker::endProcess(); - logger("Front end worker ended: ".getmypid()); + Logger::log("Front end worker ended: ".getmypid()); - killme(); + exit(); }