summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authornobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2012-12-07 05:04:02 +0000
committernobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2012-12-07 05:04:02 +0000
commit08f0db2c68a9e306f3a637e9d32d9e7b8b1f2e92 (patch)
treef62afb5ed192f0bd674762fb6063c4a224649b9f
parent9dd64b6053685a4db7d4e60d16b0fc090384dae0 (diff)
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
-rw-r--r--ChangeLog6
-rw-r--r--lib/timeout.rb26
-rw-r--r--test/test_timeout.rb3
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 <nobu@ruby-lang.org>
+
+ * 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 <zachary@zacharyscott.net>
* 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