Contents

require 'minitest/autorun'
require "sdb_lock"

class LockTest < MiniTest::Test
  def setup
    @lock = SdbLock.new(
        'lock_test'
    )
    @lock.unlock("test")
  end

  # This test will take long time (16 secs in my environment).
  def test_try_lock
    shared_var = 0
    locked_count = 0

    threads = 10.times.map do
      Thread.new do
        Thread.pass
        locked = @lock.try_lock("test") { shared_var += 1 }
        locked_count += 1 if locked
      end
    end
    threads.each { |thread| thread.join }
    assert_equal(locked_count, shared_var)
  end

  def test_lock
    shared_var = 0
    threads = 10.times.map do
      Thread.new do
        Thread.pass
        @lock.lock("test") { shared_var += 1 }
      end
    end
    threads.each { |thread| thread.join }
    assert_equal(10, shared_var)
  end

  def test_additional_attributes
    additional_attributes = [
      {
        name: 'additional_attribute',
        value: 'test'
      }
    ]

    @lock.lock("test", additional_attributes)
    # Checking the values of an attribute are not always immediately available,
    # so sleep for a second.
    sleep(1)
    attributes = @lock.send(:item, "test")
    value = attributes.each do |a|
      break a.value if a.name == 'additional_attribute'
    end
    # Additional attributes were set
    assert_equal('test', value)

    @lock.unlock("test")
    # Checking the values of an attribute are not always immediately available,
    # so sleep for a second.
    sleep(1)
    attributes = @lock.send(:item, "test")
    # Additional attributes were unset
    assert_equal([], attributes)
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sdb_lock-0.1.1	test/test_lock.rb