From 08f0db2c68a9e306f3a637e9d32d9e7b8b1f2e92 Mon Sep 17 00:00:00 2001 From: nobu Date: Fri, 7 Dec 2012 05:04:02 +0000 Subject: [PATCH] timeout.rb: replace deferred exception after async_interrupt_timing * lib/timeout.rb (Timeout#timeout): since async_interrupt_timing re-raises a deferred exception, replace the timeout exception with Timeout::Error after it. [Bug #7503] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@38255 b2dd03c8-39d4-4d8f-98ff-823fe69b080e --- ChangeLog | 6 ++++++ lib/timeout.rb | 26 +++++++++++++------------- test/test_timeout.rb | 3 ++- 3 files changed, 21 insertions(+), 14 deletions(-) diff --git a/ChangeLog b/ChangeLog index e10c94034d..311380723e 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,9 @@ +Fri Dec 7 14:03:59 2012 Nobuyoshi Nakada + + * lib/timeout.rb (Timeout#timeout): since async_interrupt_timing + re-raises a deferred exception, replace the timeout exception with + Timeout::Error after it. [Bug #7503] + Fri Dec 7 13:07:00 2012 Zachary Scott * doc/forwardable.rd: Remove stale documentation file diff --git a/lib/timeout.rb b/lib/timeout.rb index ee20115754..127bccf924 100644 --- a/lib/timeout.rb +++ b/lib/timeout.rb @@ -50,8 +50,8 @@ module Timeout def timeout(sec, klass = nil, immediate: false) #:yield: +sec+ return yield(sec) if sec == nil or sec.zero? exception = klass || Class.new(ExitException) - Thread.async_interrupt_timing(exception => immediate ? :immediate : :on_blocking) do - begin + begin + Thread.async_interrupt_timing(exception => immediate ? :immediate : :on_blocking) do begin x = Thread.current y = Thread.start { @@ -70,18 +70,18 @@ module Timeout y.join # make sure y is dead. end end - rescue exception => e - rej = /\A#{Regexp.quote(__FILE__)}:#{__LINE__-4}\z/o - (bt = e.backtrace).reject! {|m| rej =~ m} - level = -caller(CALLER_OFFSET).size - while THIS_FILE =~ bt[level] - bt.delete_at(level) - level += 1 - end - raise if klass # if exception class is specified, it - # would be expected outside. - raise Error, e.message, e.backtrace end + rescue exception => e + rej = /\A#{Regexp.quote(__FILE__)}:#{__LINE__-4}\z/o + (bt = e.backtrace).reject! {|m| rej =~ m} + level = -caller(CALLER_OFFSET).size + while THIS_FILE =~ bt[level] + bt.delete_at(level) + level += 1 + end + raise if klass # if exception class is specified, it + # would be expected outside. + raise Error, e.message, e.backtrace end end diff --git a/test/test_timeout.rb b/test/test_timeout.rb index dcd6206737..e9984946e5 100644 --- a/test/test_timeout.rb +++ b/test/test_timeout.rb @@ -62,7 +62,8 @@ class TestTimeout < Test::Unit::TestCase } sleep 0.5 t.raise RuntimeError - assert_raise(RuntimeError) { + assert_raise(Timeout::Error) { + # deferred interrupt should raise t.join } ensure