Contents

require 'spec_helper'

# this is a remnant of the old Locker class, but a good test of what's expected
# from ZK::Client#locker
#
describe 'ZK::Client#locker' do
  include_context 'connection opts'

  before(:each) do
    @zk = ZK.new(*connection_args)
    @zk2 = ZK.new(*connection_args)
    @zk3 = ZK.new(*connection_args)
    @connections = [@zk, @zk2, @zk3]
    wait_until { @connections.all? { |c| c.connected? } }
    logger.debug { "all connections connected" }
    @path_to_lock = "/lock_tester"
  end

  after(:each) do
    @zk.close!
    @zk2.close!
    @zk3.close!
    wait_until { @connections.all? { |c| c.closed? } } 
  end

  it "should be able to acquire the lock if no one else is locking it" do
    @zk.locker(@path_to_lock).lock.should be_true
  end

  it "should not be able to acquire the lock if someone else is locking it" do
    @zk.locker(@path_to_lock).lock.should be_true
    @zk2.locker(@path_to_lock).lock.should be_false
  end

  it "should be able to acquire the lock after the first one releases it" do
    lock1 = @zk.locker(@path_to_lock)
    lock2 = @zk2.locker(@path_to_lock)
    
    lock1.lock.should be_true
    lock2.lock.should be_false
    lock1.unlock
    lock2.lock.should be_true
  end

  it "should be able to acquire the lock if the first locker goes away" do
    lock1 = @zk.locker(@path_to_lock)
    lock2 = @zk2.locker(@path_to_lock)

    lock1.lock.should be_true
    lock2.lock.should be_false
    @zk.close!
    lock2.lock.should be_true
  end

  it "should be able to handle multi part path locks" do
    @zk.locker("my/multi/part/path").lock.should be_true
  end

  it "should blocking lock" do
    array = []
    first_lock = @zk.locker("mylock")
    first_lock.lock.should be_true
    array << :first_lock

    thread = Thread.new do
      @zk.locker("mylock").with_lock do
        array << :second_lock
      end
      array.length.should == 2
    end

    array.length.should == 1
    first_lock.unlock
    thread.join(10)
    array.length.should == 2
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
zk-1.6.5	spec/zk/locker/locker_basic_spec.rb
zk-1.6.4	spec/zk/locker/locker_basic_spec.rb
zk-1.6.3	spec/zk/locker/locker_basic_spec.rb
zk-1.6.2	spec/zk/locker/locker_basic_spec.rb
zk-1.6.1	spec/zk/locker/locker_basic_spec.rb
zk-1.6.0	spec/zk/locker/locker_basic_spec.rb
zk-1.5.3	spec/zk/locker/locker_basic_spec.rb
zk-1.5.2	spec/zk/locker/locker_basic_spec.rb