lib/redis/objects/locks.rb in redis-objects-0.6.1 vs lib/redis/objects/locks.rb in redis-objects-0.7.0
- old
+ new
@@ -15,11 +15,11 @@
# Define a new lock. It will function like a model attribute,
# so it can be used alongside ActiveRecord/DataMapper, etc.
def lock(name, options={})
options[:timeout] ||= 5 # seconds
lock_name = "#{name}_lock"
- @redis_objects[lock_name.to_sym] = options.merge(:type => :lock)
+ redis_objects[lock_name.to_sym] = options.merge(:type => :lock)
klass_name = '::' + self.name
if options[:global]
instance_eval <<-EndMethods
def #{lock_name}(&block)
@#{lock_name} ||= Redis::Lock.new(redis_field_key(:#{lock_name}), #{klass_name}.redis, #{klass_name}.redis_objects[:#{lock_name}])
@@ -44,23 +44,23 @@
# that was specified when the lock was defined.
def obtain_lock(name, id, &block)
verify_lock_defined!(name)
raise ArgumentError, "Missing block to #{self.name}.obtain_lock" unless block_given?
lock_name = "#{name}_lock"
- Redis::Lock.new(redis_field_key(lock_name, id), redis, @redis_objects[lock_name.to_sym]).lock(&block)
+ Redis::Lock.new(redis_field_key(lock_name, id), redis, redis_objects[lock_name.to_sym]).lock(&block)
end
# Clear the lock. Use with care - usually only in an Admin page to clear
# stale locks (a stale lock should only happen if a server crashes.)
def clear_lock(name, id)
verify_lock_defined!(name)
redis.del(redis_field_key("#{name}_lock", id))
end
private
-
+
def verify_lock_defined!(name)
- unless @redis_objects.has_key?("#{name}_lock".to_sym)
+ unless redis_objects.has_key?("#{name}_lock".to_sym)
raise Redis::Objects::UndefinedLock, "Undefined lock :#{name} for class #{self.name}"
end
end
end
end