tourstream / typo3-redis-lock-strategy

     *

     * @return boolean TRUE on sucess, FALSE otherwise

     */

    private function init()

    {

        $script = '

            if not redis.call("EXISTS", KEYS[1], KEYS[2]) then

                return redis.call("RPUSH", KEYS[2], ARGV[1]) and redis.call("EXPIRE", KEYS[2], ARGV[2])

            else

                return 0

            fi

        ';

        return (bool) $this->redis->eval($script, [$this->name, $this->mutex, $this->value, $this->ttl], 2);

    }

    /**

     * Try to get the lock

     *

     * @return boolean TRUE on success, FALSE otherwise

     */

    private function unlockAndSignal()

    {

        $script = '

            if redis.call("GET", KEYS[1]) == ARGV[1] and redis.call("DEL", KEYS[1]) then

                return redis.call("RPUSH", KEYS[2], ARGV[1]) and redis.call("EXPIRE", KEYS[2], ARGV[2])

            else

                return 0

            end

        ';

        return (bool) $this->redis->eval($script, [$this->name, $this->mutex, $this->value, $this->ttl], 2);

    }

}