Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/mautic.corals.io/vendor/malkusch/lock/classes/mutex/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace malkusch\lock\mutex;

use malkusch\lock\exception\LockAcquireException;
use malkusch\lock\exception\LockReleaseException;

/**
 * System V IPC based mutex implementation.
 *
 * @author Markus Malkusch <[email protected]>
 * @link bitcoin:1P5FAZ4QhXCuwYPnLZdk3PJsqePbu1UDDA Donations
 * @license WTFPL
 */
class SemaphoreMutex extends LockMutex
{

    /**
     * @var resource The semaphore id.
     */
    private $semaphore;
    
    /**
     * Sets the semaphore id.
     *
     * Use {@link sem_get()} to create the semaphore id.
     *
     * Example:
     * <code>
     * $semaphore = sem_get(ftok(__FILE__, "a"));
     * $mutex     = new SemaphoreMutex($semaphore);
     * </code>
     *
     * @param resource semaphore The semaphore id.
     * @throws \InvalidArgumentException The semaphore id is not a valid resource.
     */
    public function __construct($semaphore)
    {
        if (!is_resource($semaphore)) {
            throw new \InvalidArgumentException("The semaphore id is not a valid resource.");
        }
        $this->semaphore = $semaphore;
    }
    
    /**
     * @internal
     */
    protected function lock()
    {
        if (!sem_acquire($this->semaphore)) {
            throw new LockAcquireException("Failed to acquire the Semaphore.");
        }
    }

    /**
     * @internal
     */
    protected function unlock()
    {
        if (!sem_release($this->semaphore)) {
            throw new LockReleaseException("Failed to release the Semaphore.");
        }
    }
}