X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=bin%2Fworker.php;h=1251057b0f07525cfefdcf1f4454bd561c2172fb;hb=4c6940583af429d251192abef1792831a57637c5;hp=1b70a2095544a2d26b15160b230ddb9f733c4f21;hpb=097620b62799c96d610d73410ec07a6b8cdf82f0;p=friendica.git diff --git a/bin/worker.php b/bin/worker.php index 1b70a20955..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()); @@ -72,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); -Worker::endProcess(); +DI::process()->delete($process);