Sha256: f6d5c6d9543f18c0ec960721132f2489e75c1da3f438bf3b148d32e326385405
Contents?: true
Size: 1.84 KB
Versions: 11
Compression:
Stored size: 1.84 KB
Contents
# vim:fileencoding=utf-8
require_relative 'base'
module Resque
module Scheduler
module Lock
class Resilient < Base
def acquire!
evalsha(:acquire, [key], [value]).to_i == 1
end
def locked?
evalsha(:locked, [key], [value]).to_i == 1
end
def timeout=(seconds)
if locked?
@timeout = seconds
@locked_sha = nil
@acquire_sha = nil
end
@timeout
end
private
def evalsha(script, keys, argv, refresh: false)
sha_method_name = "#{script}_sha"
Resque.redis.evalsha(
send(sha_method_name, refresh),
keys: keys,
argv: argv
)
rescue Redis::CommandError => e
if e.message =~ /NOSCRIPT/
refresh = true
retry
end
raise
end
def locked_sha(refresh = false)
@locked_sha = nil if refresh
@locked_sha ||=
Resque.data_store.redis.script(:load, <<-EOF.gsub(/^ {14}/, ''))
if redis.call('GET', KEYS[1]) == ARGV[1]
then
redis.call('EXPIRE', KEYS[1], #{timeout})
if redis.call('GET', KEYS[1]) == ARGV[1]
then
return 1
end
end
return 0
EOF
end
def acquire_sha(refresh = false)
@acquire_sha = nil if refresh
@acquire_sha ||=
Resque.data_store.redis.script(:load, <<-EOF.gsub(/^ {14}/, ''))
if redis.call('SETNX', KEYS[1], ARGV[1]) == 1
then
redis.call('EXPIRE', KEYS[1], #{timeout})
return 1
else
return 0
end
EOF
end
end
end
end
end
Version data entries
11 entries across 11 versions & 2 rubygems