mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
test/ruby/envutil.rb: compare RSS to check memory leak
* test/ruby/envutil.rb (Test::Test#assert_no_memory_leak): compare also RSS if available. * test/ruby/memory_status.rb (Memory::Status.parse): read string form of an instance. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@45298 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
6864969967
commit
e20cd8ee49
2 changed files with 27 additions and 7 deletions
|
@ -391,6 +391,7 @@ eom
|
|||
end
|
||||
|
||||
def assert_no_memory_leak(args, prepare, code, message=nil, limit: 1.5, **opt)
|
||||
require_relative 'memory_status'
|
||||
token = "\e[7;1m#{$$.to_s}:#{Time.now.strftime('%s.%L')}:#{rand(0x10000).to_s(16)}:\e[m"
|
||||
token_dump = token.dump
|
||||
token_re = Regexp.quote(token)
|
||||
|
@ -403,16 +404,22 @@ eom
|
|||
]
|
||||
args.unshift(envs) if envs
|
||||
cmd = [
|
||||
'END {STDERR.puts '"#{token_dump}"'"FINAL=#{Memory::Status.new.size}"}',
|
||||
'END {STDERR.puts '"#{token_dump}"'"FINAL=#{Memory::Status.new}"}',
|
||||
prepare,
|
||||
'STDERR.puts('"#{token_dump}"'"START=#{$initial_size = Memory::Status.new.size}")',
|
||||
'STDERR.puts('"#{token_dump}"'"START=#{$initial_size = Memory::Status.new}")',
|
||||
code,
|
||||
'GC.start',
|
||||
].join("\n")
|
||||
_, err, status = EnvUtil.invoke_ruby(args, cmd, true, true, **opt)
|
||||
before = err.sub!(/^#{token_re}START=(\d+)\n/, '') && $1.to_i
|
||||
after = err.sub!(/^#{token_re}FINAL=(\d+)\n/, '') && $1.to_i
|
||||
before = err.sub!(/^#{token_re}START=(\{.*\})\n/, '') && Memory::Status.parse($1)
|
||||
after = err.sub!(/^#{token_re}FINAL=(\{.*\})\n/, '') && Memory::Status.parse($1)
|
||||
assert_equal([true, ""], [status.success?, err], message)
|
||||
assert_operator(after.fdiv(before), :<, limit, message)
|
||||
([:size, :rss] & after.members).each do |n|
|
||||
b = before[n]
|
||||
a = after[n]
|
||||
next unless a > 0 and b > 0
|
||||
assert_operator(a.fdiv(b), :<, limit, message(message) {"#{n}: #{b} => #{a}"})
|
||||
end
|
||||
end
|
||||
|
||||
def assert_is_minus_zero(f)
|
||||
|
|
|
@ -1,5 +1,3 @@
|
|||
require_relative "envutil"
|
||||
|
||||
module Memory
|
||||
keys = []
|
||||
vals = []
|
||||
|
@ -110,5 +108,20 @@ module Memory
|
|||
def initialize
|
||||
_update
|
||||
end
|
||||
|
||||
def to_s
|
||||
status = each_pair.map {|n,v|
|
||||
"#{n}:#{v}"
|
||||
}
|
||||
"{#{status.join(",")}}"
|
||||
end
|
||||
|
||||
def self.parse(str)
|
||||
status = allocate
|
||||
str.scan(/(?:\A\{|\G,)(#{members.join('|')}):(\d+)(?=,|\}\z)/) do
|
||||
status[$1] = $2.to_i
|
||||
end
|
||||
status
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Add table
Reference in a new issue