X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=bin%2Fworker.php;h=1251057b0f07525cfefdcf1f4454bd561c2172fb;hb=b7cee324b0e4fe9048ffdee660cfc3a0f2dfd56a;hp=46eff1071a10fc3a050cc887ea8f8f7e272ab0c2;hpb=280458fb6541a5ae21b660e81f642d8f92df5663;p=friendica.git diff --git a/bin/worker.php b/bin/worker.php index 46eff1071a..1251057b0f 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); +\Friendica\Core\Logger\Handler\ErrorHandler::register($dice->create(\Psr\Log\LoggerInterface::class)); $a = DI::app(); +DI::mode()->setExecutor(Mode::WORKER); + // Check the database structure and possibly fixes it Update::check($a->getBasePath(), true, DI::mode()); @@ -73,8 +81,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); -DI::process()->end(); +DI::process()->delete($process);