Metabor\Semaphore\LockAdapterMutex

Complexity

Total Complexity

9

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	releaseLock()	0	13	3
A	isAcquired()	0	4	1
A	acquireLock()	0	8	2
A	isLocked()	0	4	1
A	__destruct()	0	4	1

<?php

namespace Metabor\Semaphore;

use MetaborStd\Semaphore\LockAdapterInterface;
use MetaborStd\Semaphore\MutexInterface;

class LockAdapterMutex implements MutexInterface
{
    /**
     * @var LockAdapterInterface
     */
    private $lockAdapter;

    /**
     * @var string
     */
    private $resourceName;

    /**
     * @var bool
     */
    private $acquired = false;

    /**
     * @param LockAdapterInterface $lockAdapter
     * @param string               $resourceName
     */
    public function __construct(LockAdapterInterface $lockAdapter, $resourceName)
    {
        $this->lockAdapter = $lockAdapter;
        $this->resourceName = $resourceName;
    }

    /**
     * @see \MetaborStd\Semaphore\MutexInterface::releaseLock()
     */
    public function releaseLock()
    {
        if ($this->acquired) {
            $result = $this->lockAdapter->releaseLock($this->resourceName);
            if ($result) {
                $this->acquired = false;
            }

            return $result;
        } else {
            return false;
        }
    }

    /**
     * @see \MetaborStd\Semaphore\MutexInterface::isAcquired()
     */
    public function isAcquired()
    {
        return $this->acquired;
    }

    /**
     * @see \MetaborStd\Semaphore\MutexInterface::acquireLock()
     */
    public function acquireLock()
    {
        if (!$this->acquired) {
            $this->acquired = $this->lockAdapter->acquireLock($this->resourceName);
        }

        return $this->acquired;
    }

    /**
     * @see \MetaborStd\Semaphore\MutexInterface::isLocked()
     */
    public function isLocked()
    {
        return $this->lockAdapter->isLocked($this->resourceName);
    }

    /**
     * release lock if mutex instance is destroyed.
     */
    public function __destruct()
    {
        $this->releaseLock();
    }
}