Semaphore::acquire() - Code Metrics - slince/process - Measure and Improve Code Quality continuously with Scrutinizer

Semaphore::acquire() A
last analyzed 2017-08-23 03:59 UTC

↳ Parent: Semaphore

Complexity

Conditions	4
Paths	5

Size

Total Lines	16
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	16
c	0
b	0
f	0
rs	9.2
cc	4
eloc	10
nc	5
nop	1

<?php
/**
 * Process Library
 * @author Tao <[email protected]>
 */
namespace Slince\Process\SystemV;

use Slince\Process\Exception\InvalidArgumentException;
use Slince\Process\Exception\RuntimeException;

class Semaphore
{
    use IpcKeyTrait;

    /**
     * Whether the semaphore is locked
     * @var boolean
     */
    protected $locked;

    /**
     * The resource that can be used to access the System V semaphore
     * @var resource
     */
    protected $semId;

    public function __construct($pathname = __FILE__, $maxAcquireNum = 1, $permission = 0666)
    {
        $ipcKey = $this->generateIpcKey($pathname);
        if (!($this->semId = sem_get($ipcKey, $maxAcquireNum, $permission))) {
            throw new RuntimeException("Cannot get semaphore identifier");
        }
    }

    /**
     * Acquires the lock
     * @param bool $blocking
     * @return bool
     */
    public function acquire($blocking = true)
    {
        //non-blocking requires php version greater than 5.6.1
        if (!$blocking) {
            if (version_compare(PHP_VERSION, '5.6.1') < 0) {
                throw new InvalidArgumentException("Semaphore requires php version greater than 5.6.1 when using blocking");
            }
            $result = sem_acquire($this->semId, !$blocking);
        } else {
            $result = sem_acquire($this->semId);
        }
        if ($result) {
            $this->locked = true;
        }
        return $result;
    }

    /**
     * Release the lock
     * @return bool
     */
    public function release()
    {
        if ($this->locked && sem_release($this->semId)) {
            $this->locked = false;
            return true;
        }
        return false;
    }

    /**
     * Destroy semaphore
     * @return void
     */
    public function destroy()
    {
        sem_remove($this->semId);
    }
}


1			<?php
2			/**
3			* Process Library
4			* @author Tao <[email protected]>
5			*/
6			namespace Slince\Process\SystemV;
7
8			use Slince\Process\Exception\InvalidArgumentException;
9			use Slince\Process\Exception\RuntimeException;
10
11			class Semaphore
12			{
13			use IpcKeyTrait;
14
15			/**
16			* Whether the semaphore is locked
17			* @var boolean
18			*/
19			protected $locked;
20
21			/**
22			* The resource that can be used to access the System V semaphore
23			* @var resource
24			*/
25			protected $semId;
26
27			public function __construct($pathname = __FILE__, $maxAcquireNum = 1, $permission = 0666)
28			{
29			$ipcKey = $this->generateIpcKey($pathname);
30			if (!($this->semId = sem_get($ipcKey, $maxAcquireNum, $permission))) {
31			throw new RuntimeException("Cannot get semaphore identifier");
32			}
33			}
34
35			/**
36			* Acquires the lock
37			* @param bool $blocking
38			* @return bool
39			*/
40			public function acquire($blocking = true)
41			{
42			//non-blocking requires php version greater than 5.6.1
43			if (!$blocking) {
44			if (version_compare(PHP_VERSION, '5.6.1') < 0) {
45			throw new InvalidArgumentException("Semaphore requires php version greater than 5.6.1 when using blocking");
46			}
47			$result = sem_acquire($this->semId, !$blocking);
48			} else {
49			$result = sem_acquire($this->semId);
50			}
51			if ($result) {
52			$this->locked = true;
53			}
54			return $result;
55			}
56
57			/**
58			* Release the lock
59			* @return bool
60			*/
61			public function release()
62			{
63			if ($this->locked && sem_release($this->semId)) {
64			$this->locked = false;
65			return true;
66			}
67			return false;
68			}
69
70			/**
71			* Destroy semaphore
72			* @return void
73			*/
74			public function destroy()
75			{
76			sem_remove($this->semId);
77			}
78			}
79

slince / process

Semaphore::acquire() A last analyzed 2017-08-23 03:59 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Semaphore::acquire() A
last analyzed 2017-08-23 03:59 UTC