X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=bin%2Fworker.php;h=a742132480b923adc203faded953d028660a768d;hb=902f3d9bc63d89b0e91870ba407c6b55ecf03a70;hp=833e5b00207ef06b84026611f8ce602dfba0de9c;hpb=cc5e5be931bc21e44d0cb26778e8cc15be924e41;p=friendica.git diff --git a/bin/worker.php b/bin/worker.php index 833e5b0020..a742132480 100755 --- a/bin/worker.php +++ b/bin/worker.php @@ -1,7 +1,7 @@ #!/usr/bin/env php addRules(include __DIR__ . '/../static/dependencies.config $dice = $dice->addRule(LoggerInterface::class,['constructParams' => ['worker']]); DI::init($dice); -$a = DI::app(); +\Friendica\Core\Logger\Handler\ErrorHandler::register($dice->create(\Psr\Log\LoggerInterface::class)); + +DI::mode()->setExecutor(Mode::WORKER); // Check the database structure and possibly fixes it -Update::check($a->getBasePath(), true, DI::mode()); +Update::check(DI::basePath(), true); // Quit when in maintenance if (!DI::mode()->has(App\Mode::MAINTENANCEDISABLED)) { return; } -DI::baseUrl()->saveByURL(DI::config()->get('system', 'url')); - $spawn = array_key_exists('s', $options) || array_key_exists('spawn', $options); if ($spawn) { @@ -77,8 +78,10 @@ if ($spawn) { $run_cron = !array_key_exists('n', $options) && !array_key_exists('no_cron', $options); -Worker::processQueue($run_cron); +$process = DI::process()->create(getmypid(), basename(__FILE__)); + +Worker::processQueue($run_cron, $process); -Worker::unclaimProcess(); +Worker::unclaimProcess($process); -Worker::endProcess(); +DI::process()->delete($process);