X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=bin%2Fworker.php;h=084ad28979b667dacbfa8bd4600c764e27a8148f;hb=d21da2dc0aa3b40c0c0a21e1317a0a9f961b5f6c;hp=46638a9ef3ad3b3a3bbe30d40ab9221e0a51c982;hpb=2a431b580f2e8f6a596e84175932e793678cde63;p=friendica.git diff --git a/bin/worker.php b/bin/worker.php index 46638a9ef3..084ad28979 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); @@ -80,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::unclaimProcess(); +Worker::processQueue($run_cron, $process); -DI::process()->end(); +Worker::unclaimProcess($process); + +DI::process()->delete($process);