1
0
Fork 0
mirror of https://github.com/mperham/connection_pool synced 2023-03-27 23:22:21 -04:00
connection_pool/test/test_connection_pool_timed_stack.rb
2014-02-17 14:47:41 -08:00

121 lines
1.9 KiB
Ruby

Thread.abort_on_exception = true
require 'helper'
class TestConnectionPoolTimedStack < Minitest::Test
def setup
@stack = ConnectionPool::TimedStack.new { Object.new }
end
def test_empty_eh
assert_empty @stack
@stack.push Object.new
refute_empty @stack
end
def test_empty_eh_full
stack = ConnectionPool::TimedStack.new(1) { Object.new }
refute_empty stack
end
def test_length
assert_equal 0, @stack.length
@stack.push Object.new
assert_equal 1, @stack.length
end
def test_length_full
stack = ConnectionPool::TimedStack.new(1) { Object.new }
assert_equal 1, stack.length
end
def test_pop
object = Object.new
@stack.push object
popped = @stack.pop
assert_same object, popped
end
def test_pop_empty
e = assert_raises Timeout::Error do
@stack.pop 0
end
assert_equal 'Waited 0 sec', e.message
end
def test_pop_full
stack = ConnectionPool::TimedStack.new(1) { Object.new }
popped = stack.pop
refute_nil popped
assert_empty stack
end
def test_pop_wait
thread = Thread.start do
@stack.pop
end
Thread.pass while thread.status == 'run'
object = Object.new
@stack.push object
assert_same object, thread.value
end
def test_pop_shutdown
@stack.shutdown { }
assert_raises ConnectionPool::PoolShuttingDownError do
@stack.pop
end
end
def test_push
assert_empty @stack
@stack.push Object.new
refute_empty @stack
end
def test_push_shutdown
called = []
@stack.shutdown do |object|
called << object
end
@stack.push Object.new
refute_empty called
assert_empty @stack
end
def test_shutdown
@stack.push Object.new
called = []
@stack.shutdown do |object|
called << object
end
refute_empty called
assert_empty @stack
end
end