Contents

#
# Testing OpenWFE
#
# John Mettraux at openwfe.org
#

require 'test/unit'
require 'openwfe/worklist/storelocks'
require 'openwfe/worklist/storeparticipant'

include OpenWFE


class MockItem
    attr_reader :fei
    def initialize (fei)
        @fei = fei
    end
    def flow_expression_id
        @fei
    end
end

class StoreLockTest < Test::Unit::TestCase

    #def setup
    #end

    #def teardown
    #end

    def test_0

        store = StoreWithLocks.new(HashParticipant)

        wi0 = MockItem.new("fei")

        store.store.push(wi0)

        wi1 = store.get_and_lock("locker_a", "fei")

        assert_not_nil wi1
        assert_equal wi0.object_id, wi1.object_id

        assert_raise RuntimeError do
            wi2 = store.get_and_lock("locker_b", "fei")
        end

        assert_equal store.get_locker("fei"), "locker_a"

        assert_raise RuntimeError do
            store.release "locker_b", "fei"
        end

        store.release "locker_a", "fei"

        assert_nil store.get_locker("fei")
    end

    def test_1

        store = StoreWithLocks.new(
            HashParticipant,
            nil,
            :lock_max_age => "100")

        wi0 = MockItem.new("fei")

        store.store.push(wi0)

        wi1 = store.get_and_lock("locker_a", "fei")

        assert_not_nil wi1

        sleep 1

        assert_nil store.get_locker("fei")
    end

end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
openwferu-0.9.11	test/slock_test.rb
openwferu-0.9.12	test/slock_test.rb
openwferu-0.9.12.863	test/slock_test.rb
openwferu-0.9.13	test/slock_test.rb
openwferu-0.9.14	test/slock_test.rb
openwferu-0.9.15	test/slock_test.rb
openwferu-0.9.16	test/slock_test.rb
openwferu-0.9.17	test/slock_test.rb