class RemoteLock

# File lib/remote_lock.rb, line 10
def initialize(adapter, prefix = nil)
  raise "Invalid Adapter" unless Adapters::Base.valid?(adapter)
  @adapter = adapter
  @prefix = prefix
end

# File lib/remote_lock.rb, line 29
def acquire_lock(key, options = {})
  options = DEFAULT_OPTIONS.merge(options)
  1.upto(options[:retries]) do |attempt|
    success = @adapter.store(key_for(key), options[:expiry])
    return if success
    break if attempt == options[:retries]
    Kernel.sleep(2 ** (attempt + rand - 1) * options[:initial_wait])
  end
  raise RemoteLock::Error, "Couldn't acquire lock for: #{key}"
end

# File lib/remote_lock.rb, line 44
def acquired?(key)
  @adapter.has_key?(key_for(key))
end

# File lib/remote_lock.rb, line 40
def release_lock(key)
  @adapter.delete(key_for(key))
end

# File lib/remote_lock.rb, line 16
def synchronize(key, options={})
  if acquired?(key)
    yield
  else
    acquire_lock(key, options)
    begin
      yield
    ensure
      release_lock(key)
    end
  end
end

# File lib/remote_lock.rb, line 50
def key_for(string)
  [@prefix, "lock", string].compact.join('|')
end