2008-01-07 10:32:07 -05:00
|
|
|
require 'test/unit'
|
|
|
|
require 'timeout'
|
|
|
|
require 'thread'
|
|
|
|
|
|
|
|
class TestTimeout < Test::Unit::TestCase
|
|
|
|
def test_queue
|
|
|
|
q = Queue.new
|
|
|
|
assert_raise(Timeout::Error, "[ruby-dev:32935]") {
|
2014-01-06 22:41:24 -05:00
|
|
|
timeout(0.01) { q.pop }
|
2008-01-07 10:32:07 -05:00
|
|
|
}
|
|
|
|
end
|
|
|
|
|
2009-04-28 06:10:05 -04:00
|
|
|
def test_timeout
|
2014-01-06 22:41:24 -05:00
|
|
|
flag = true
|
2009-04-28 06:10:05 -04:00
|
|
|
Thread.start {
|
2014-05-27 04:00:19 -04:00
|
|
|
sleep 1
|
2014-01-06 22:41:24 -05:00
|
|
|
flag = false
|
2009-04-28 06:10:05 -04:00
|
|
|
}
|
2014-05-27 04:00:19 -04:00
|
|
|
assert_raise(Timeout::Error, "[ruby-dev:38319]") do
|
|
|
|
Timeout.timeout(0.1) {
|
2014-01-06 22:41:24 -05:00
|
|
|
Thread.pass while flag
|
2009-04-28 06:10:05 -04:00
|
|
|
}
|
|
|
|
end
|
2014-05-27 04:00:19 -04:00
|
|
|
assert flag, "[ruby-dev:38319]"
|
2009-04-28 06:10:05 -04:00
|
|
|
end
|
2010-04-19 05:58:09 -04:00
|
|
|
|
|
|
|
def test_cannot_convert_into_time_interval
|
|
|
|
bug3168 = '[ruby-dev:41010]'
|
|
|
|
def (n = Object.new).zero?; false; end
|
|
|
|
assert_raise(TypeError, bug3168) {Timeout.timeout(n) { sleep 0.1 }}
|
|
|
|
end
|
2013-08-26 02:27:48 -04:00
|
|
|
|
|
|
|
def test_skip_rescue
|
|
|
|
bug8730 = '[Bug #8730]'
|
|
|
|
e = nil
|
2013-08-27 04:18:50 -04:00
|
|
|
assert_raise_with_message(Timeout::Error, /execution expired/, bug8730) do
|
2014-01-06 22:41:24 -05:00
|
|
|
timeout 0.01 do
|
2013-08-26 02:27:48 -04:00
|
|
|
begin
|
|
|
|
sleep 3
|
|
|
|
rescue Exception => e
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
assert_nil(e, bug8730)
|
|
|
|
end
|
2013-08-27 04:18:50 -04:00
|
|
|
|
|
|
|
def test_rescue_exit
|
|
|
|
exc = Class.new(RuntimeError)
|
|
|
|
e = nil
|
|
|
|
assert_nothing_raised(exc) do
|
2014-01-06 22:41:24 -05:00
|
|
|
timeout 0.01, exc do
|
2013-08-27 04:18:50 -04:00
|
|
|
begin
|
|
|
|
sleep 3
|
|
|
|
rescue exc => e
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
assert_raise_with_message(exc, /execution expired/) {raise e if e}
|
|
|
|
end
|
2014-01-06 22:42:37 -05:00
|
|
|
|
|
|
|
def test_custom_exception
|
|
|
|
bug9354 = '[ruby-core:59511] [Bug #9354]'
|
|
|
|
err = Class.new(StandardError) do
|
|
|
|
def initialize(msg) super end
|
|
|
|
end
|
|
|
|
assert_nothing_raised(ArgumentError, bug9354) do
|
|
|
|
assert_equal(:ok, timeout(100, err) {:ok})
|
|
|
|
end
|
|
|
|
end
|
2014-01-06 22:43:08 -05:00
|
|
|
|
|
|
|
def test_exit_exception
|
|
|
|
assert_raise_with_message(Timeout::ExitException, "boon") do
|
|
|
|
Timeout.timeout(10, Timeout::ExitException) do
|
|
|
|
raise Timeout::ExitException, "boon"
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
2014-01-07 23:12:39 -05:00
|
|
|
|
|
|
|
def test_enumerator_next
|
|
|
|
bug9380 = '[ruby-dev:47872] [Bug #9380]: timeout in Enumerator#next'
|
|
|
|
e = (o=Object.new).to_enum
|
|
|
|
def o.each
|
|
|
|
sleep
|
|
|
|
end
|
|
|
|
assert_raise_with_message(Timeout::Error, 'execution expired', bug9380) do
|
|
|
|
Timeout.timeout(0.01) {e.next}
|
|
|
|
end
|
|
|
|
end
|
2009-04-28 06:10:05 -04:00
|
|
|
end
|