TimerTrait::addTimerProcess() - Code Metrics - Inspection of "support global timer" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f0c027...250233 )

by Biao

created 2020-08-05 11:05 UTC

TimerTrait::addTimerProcess() B

↳ Parent: TimerTrait

Complexity

Conditions	7
Paths	3

Size

Total Lines	44
Code Lines	24

Duplication

Lines	0
Ratio	0 %

Importance

Changes	5
Bugs	1	Features	1

Metric	Value
cc	7
eloc	24
c	5
b	1
f	1
nc	3
nop	3
dl	0
loc	44
rs	8.6026

<?php


namespace Hhxsv5\LaravelS\Swoole\Timer;

use Swoole\Http\Server;
use Swoole\Process;
use Swoole\Timer;

trait TimerTrait

{
    private $timerPidFile = 'laravels-timer-process.pid';


    public function addTimerProcess(Server $swoole, array $config, array $laravelConfig)

    {
        if (empty($config['enable']) || empty($config['jobs'])) {
            return false;
        }

        // Add backup cron job.
        $config['jobs'][] = BackupCronJob::class;
        if (!empty($config['global'])) {
            // Add auxiliary jobs for global timer.
            $config['jobs'][] = RenewGlobalTimerLockCronJob::class;
            $config['jobs'][] = CheckGlobalTimerAliveCronJob::class;
        }

        $callback = function (Process $process) use ($swoole, $config, $laravelConfig) {
            $pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->timerPidFile;
            file_put_contents($pidfile, $process->pid);
            $this->setProcessTitle(sprintf('%s laravels: timer process', $config['process_prefix']));
                   setProcessTitle(sprintf('%s laravels: timer process', $config['process_prefix']));
            $this->initLaravel($laravelConfig, $swoole);
                   initLaravel($laravelConfig, $swoole);

            // Implement global timer by Cache lock.
            if (!empty($config['global'])) {
                CronJob::setGlobalTimerLockKey($config['lock_key']);
                // Close all cron job if not get the lock
                CronJob::setEnable(CronJob::getGlobalTimerLock());
            }

            $timerIds = $this->registerTimers($config['jobs']);

            Process::signal(SIGUSR1, function ($signo) use ($config, $timerIds, $process) {
            Process::signal(SIGUSR1, function (/** @scrutinizer ignore-unused */ $signo) use ($config, $timerIds, $process) {
                foreach ($timerIds as $timerId) {
                    if (Timer::exists($timerId)) {
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
                        Timer::clear($timerId);
                    }
                }
                Timer::after($config['max_wait_time'] * 1000, function () use ($process) {

                    $process->exit(0);
                });
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
            });
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
        };

        $process = new Process($callback, false, 0);
        $swoole->addProcess($process);
        return $process;
    }

    public function registerTimers(array $jobs)

    {
        $timerIds = [];
        foreach ($jobs as $jobClass) {
            if (is_array($jobClass) && isset($jobClass[0])) {
                $job = new $jobClass[0](isset($jobClass[1]) ? $jobClass[1] : []);
            } else {
                $job = new $jobClass();
            }
            if (!($job instanceof CronJob)) {
                throw new \InvalidArgumentException(sprintf(

                        '%s must extend the abstract class %s',

                        get_class($job),

                        CronJob::class

                    )

                );
            }
            if (empty($job->interval())) {
                throw new \InvalidArgumentException(sprintf('The interval of %s cannot be empty', get_class($job)));
            }
            $runJob = function () use ($job) {
                $runCallback = function () use ($job) {
                    $this->callWithCatchException(function () use ($job) {
                           callWithCatchException(function () use ($job) {
                        if (($job instanceof CheckGlobalTimerAliveCronJob) || $job::isEnable()) {
                            $job->run();
                        }
                    });
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
                };
                class_exists('Swoole\Coroutine') ? \Swoole\Coroutine::create($runCallback) : $runCallback();
            };

            $timerId = Timer::tick($job->interval(), $runJob);
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
$object = $a->getObject();
            $timerIds[] = $timerId;
            $job->setTimerId($timerId);
            if ($job->isImmediate()) {
                Timer::after(1, $runJob);
            }
        }
        return $timerIds;
    }
}

hhxsv5 / laravel-s

Push — master ( f0c027...250233 )

TimerTrait::addTimerProcess() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like