Skip to content

Commit

Permalink
timeout.rb: skip rescue
Browse files Browse the repository at this point in the history
* lib/timeout.rb (Timeout#timeout): should not be caught by rescue
  clause.  [Bug #8730]

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@42690 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
  • Loading branch information
nobu committed Aug 26, 2013
1 parent c075b15 commit 1a3bcf1
Show file tree
Hide file tree
Showing 3 changed files with 41 additions and 14 deletions.
5 changes: 5 additions & 0 deletions ChangeLog
@@ -1,3 +1,8 @@
Mon Aug 26 15:27:39 2013 Nobuyoshi Nakada <nobu@ruby-lang.org>

* lib/timeout.rb (Timeout#timeout): should not be caught by rescue
clause. [Bug #8730]

Mon Aug 26 14:44:26 2013 Koichi Sasada <ko1@atdot.net>

* array.c (rb_ary_splice): use RARRAY_PTR_USE() without WB because
Expand Down
36 changes: 22 additions & 14 deletions lib/timeout.rb
Expand Up @@ -26,6 +26,18 @@ module Timeout
class Error < RuntimeError
end
class ExitException < ::Exception # :nodoc:
attr_reader :klass, :thread

def initialize(*)
super
@thread = Thread.current
freeze
end

def exception(*)
throw(self, caller) if self.thread == Thread.current
self
end
end

# :stopdoc:
Expand All @@ -50,8 +62,7 @@ class ExitException < ::Exception # :nodoc:
# a module method, so you can call it directly as Timeout.timeout().
def timeout(sec, klass = nil) #:yield: +sec+
return yield(sec) if sec == nil or sec.zero?
exception = klass || Class.new(ExitException)
begin
bt = catch(ExitException.new) do |exception|
begin
x = Thread.current
y = Thread.start {
Expand All @@ -60,7 +71,8 @@ def timeout(sec, klass = nil) #:yield: +sec+
rescue => e
x.raise e
else
x.raise exception, "execution expired"
# no message, not to make new instance.
x.raise exception
end
}
return yield(sec)
Expand All @@ -70,18 +82,14 @@ def timeout(sec, klass = nil) #:yield: +sec+
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
rej = /\A#{Regexp.quote(__FILE__)}:#{__LINE__-4}\z/o
bt.reject! {|m| rej =~ m}
level = -caller(CALLER_OFFSET).size
while THIS_FILE =~ bt[level]
bt.delete_at(level)
end
raise((klass||Error), "execution expired", bt)
end

module_function :timeout
Expand Down
14 changes: 14 additions & 0 deletions test/test_timeout.rb
Expand Up @@ -29,4 +29,18 @@ def test_cannot_convert_into_time_interval
def (n = Object.new).zero?; false; end
assert_raise(TypeError, bug3168) {Timeout.timeout(n) { sleep 0.1 }}
end

def test_skip_rescue
bug8730 = '[Bug #8730]'
e = nil
assert_raise(Timeout::Error, bug8730) do
timeout 0.1 do
begin
sleep 3
rescue Exception => e
end
end
end
assert_nil(e, bug8730)
end
end

0 comments on commit 1a3bcf1

Please sign in to comment.