dmank\gearman\event\subscriber\MemoryLimit

Complexity

Total Complexity

15

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

56%

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getSubscribedEvents()	0	7	1
A	onBeforeRun()	0	11	3
A	onAfterRun()	0	8	2
A	memoryLimitAlmostExceeded()	0	7	2
A	returnBytes()	0	16	4
A	informLogger()	0	12	2

<?php

namespace dmank\gearman\event\subscriber;

use dmank\gearman\event\WorkerEvent;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class MemoryLimit implements EventSubscriberInterface
{
    private $maxMemoryLimit;

    /**
     * @var LoggerInterface
     */
    private $logger;

    public function __construct($maxMemoryLimit = -1, LoggerInterface $logger = null)
    {
        $this->maxMemoryLimit = $maxMemoryLimit;
        $this->logger = $logger;
    }

    public static function getSubscribedEvents()
    {
        return array(
            WorkerEvent::EVENT_AFTER_RUN => array('onAfterRun'),
            WorkerEvent::EVENT_BEFORE_RUN => array('onBeforeRun')
        );
    }

    public function onBeforeRun(WorkerEvent $event)

The parameter $event is not used and could be removed.

    {
        if (!is_null($this->logger) && $this->maxMemoryLimit != '-1') {
            $this->logger->notice(
                sprintf(
                    'i will stop the worker when the memory limit of %s is exceeded.',
                    $this->maxMemoryLimit
                )
            );
        }
    }

    public function onAfterRun(WorkerEvent $event)
    {
        if ($this->memoryLimitAlmostExceeded()) {
            $this->informLogger();

            $event->getWorkerInstance()->destroyWorker();
        }
    }

    /**
     * @return bool
     */
    private function memoryLimitAlmostExceeded()
    {
        return (
            $this->maxMemoryLimit != '-1' &&
            memory_get_usage(true) * 1.2 > $this->returnBytes($this->maxMemoryLimit)
        );
    }

    /**
     * @param $value
     * @return int
     */
    private function returnBytes($value)
    {
        $value = trim($value);
        $last = strtolower($value{strlen($value) - 1});

        switch ($last) {
            case 'g':

There must be a comment when fall-through is intentional in a non-empty case body

                $value *= 1024;
            case 'm':

There must be a comment when fall-through is intentional in a non-empty case body

                $value *= 1024;
            case 'k':
                $value *= 1024;
        }

        return $value;
    }

    private function informLogger()
    {
        if (!is_null($this->logger)) {
            $this->logger->notice(
                sprintf(
                    'Memory limit almost exceeded. Max limit is %s, used %s so far.',
                    $this->maxMemoryLimit,
                    round((memory_get_usage(true) * 1.2) / 1048576, 2) . 'M'
                )
            );
        }
    }
}