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