mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
* lib/timeout.rb (Timeout::timeout): made sensitive to location on the
stack. [ruby-core:15458] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@15464 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
d0166b55ea
commit
133a98c63d
2 changed files with 25 additions and 3 deletions
|
@ -1,3 +1,8 @@
|
|||
Thu Feb 14 01:43:16 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||
|
||||
* lib/timeout.rb (Timeout::timeout): made sensitive to location on the
|
||||
stack. [ruby-core:15458]
|
||||
|
||||
Thu Feb 14 00:49:53 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||
|
||||
* common.mk (INSTRUBY_ARGS): pass mode to install. [ruby-dev:33766]
|
||||
|
|
|
@ -32,8 +32,13 @@ module Timeout
|
|||
##
|
||||
# Raised by Timeout#timeout when the block times out.
|
||||
|
||||
class Error<Interrupt
|
||||
class Error < Interrupt
|
||||
end
|
||||
class ExitException < ::Exception # :nodoc:
|
||||
end
|
||||
|
||||
THIS_FILE = /\A#{Regexp.quote(__FILE__)}:/o
|
||||
CALLER_OFFSET = ((c = caller[0]) && THIS_FILE =~ c) ? 1 : 0
|
||||
|
||||
##
|
||||
# Executes the method's block. If the block execution terminates before +sec+
|
||||
|
@ -44,9 +49,10 @@ module Timeout
|
|||
# Timeout' into your classes so they have a #timeout method, as well as a
|
||||
# module method, so you can call it directly as Timeout.timeout().
|
||||
|
||||
def timeout(sec, exception=Error)
|
||||
def timeout(sec, klass = nil)
|
||||
return yield if sec == nil or sec.zero?
|
||||
raise ThreadError, "timeout within critical session" if Thread.critical
|
||||
exception = klass || Class.new(ExitException)
|
||||
begin
|
||||
x = Thread.current
|
||||
y = Thread.start {
|
||||
|
@ -55,6 +61,17 @@ module Timeout
|
|||
}
|
||||
yield sec
|
||||
# return true
|
||||
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
|
||||
ensure
|
||||
y.kill if y and y.alive?
|
||||
end
|
||||
|
@ -72,7 +89,7 @@ end
|
|||
# Defined for backwards compatibility with earlier versions of timeout.rb, see
|
||||
# Timeout#timeout.
|
||||
|
||||
def timeout(n, e=Timeout::Error, &block) # :nodoc:
|
||||
def timeout(n, e = nil, &block) # :nodoc:
|
||||
Timeout::timeout(n, e, &block)
|
||||
end
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue