function RedisStore::saveRead

Overrides SharedLockStoreInterface::saveRead

File

vendor/symfony/lock/Store/RedisStore.php, line 93

Class

RedisStore: RedisStore is a PersistingStoreInterface implementation using Redis as store engine.

Namespace

Code

public function saveRead(Key $key) : void {
    $script = '
            local key = KEYS[1]
            local uniqueToken = ARGV[2]
            local ttl = tonumber(ARGV[3])

            -- asserts the KEY is compatible with current version (old Symfony <5.2 BC)
            if redis.call("TYPE", key).ok == "string" then
                return false
            end

            ' . $this->getNowCode() . '

            -- Remove expired values
            redis.call("ZREMRANGEBYSCORE", key, "-inf", now)

            -- lock not already acquired and a WRITE lock exists?
            if not redis.call("ZSCORE", key, uniqueToken) and redis.call("ZSCORE", key, "__write__") then
                return false
            end

            redis.call("ZADD", key, now + ttl, uniqueToken)
            redis.call("ZREM", key, "__write__")

            -- Extend the TTL of the key
            local maxExpiration = redis.call("ZREVRANGE", key, 0, 0, "WITHSCORES")[2]
            redis.call("PEXPIREAT", key, maxExpiration)

            return true
        ';
    $key->reduceLifetime($this->initialTtl);
    if (!$this->evaluate($script, (string) $key, [
        microtime(true),
        $this->getUniqueToken($key),
        (int) ceil($this->initialTtl * 1000),
    ])) {
        throw new LockConflictedException();
    }
    $this->checkNotExpired($key);
}