mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
default.mspec: limit cores
* spec/default.mspec (MSpecScript::JobServer#cores): limit max number of processors, not to acquire tokens more than necessary. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@59103 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
2875337533
commit
9bf9d0ef42
3 changed files with 8 additions and 7 deletions
|
@ -24,15 +24,16 @@ class MSpecScript
|
||||||
end
|
end
|
||||||
|
|
||||||
module MSpecScript::JobServer
|
module MSpecScript::JobServer
|
||||||
def cores
|
def cores(max = 1)
|
||||||
if /(?:\A|\s)--jobserver-(?:auth|fds)=(\d+),(\d+)/ =~ ENV["MAKEFLAGS"]
|
if max > 1 and /(?:\A|\s)--jobserver-(?:auth|fds)=(\d+),(\d+)/ =~ ENV["MAKEFLAGS"]
|
||||||
cores = 0
|
cores = 1
|
||||||
begin
|
begin
|
||||||
r = IO.for_fd($1.to_i(10), "rb", autoclose: false)
|
r = IO.for_fd($1.to_i(10), "rb", autoclose: false)
|
||||||
w = IO.for_fd($2.to_i(10), "wb", autoclose: false)
|
w = IO.for_fd($2.to_i(10), "wb", autoclose: false)
|
||||||
jobtokens = r.read_nonblock(1024)
|
jobtokens = r.read_nonblock(max - 1)
|
||||||
cores = jobtokens.size
|
cores = jobtokens.size
|
||||||
if cores > 0
|
if cores > 0
|
||||||
|
cores += 1
|
||||||
jobserver = w
|
jobserver = w
|
||||||
w = nil
|
w = nil
|
||||||
at_exit {
|
at_exit {
|
||||||
|
|
|
@ -98,7 +98,7 @@ class MSpecMain < MSpecScript
|
||||||
end
|
end
|
||||||
|
|
||||||
output_files = []
|
output_files = []
|
||||||
processes = [cores, @files.size].min
|
processes = cores(@files.size)
|
||||||
children = processes.times.map { |i|
|
children = processes.times.map { |i|
|
||||||
name = tmp "mspec-multi-#{i}"
|
name = tmp "mspec-multi-#{i}"
|
||||||
output_files << name
|
output_files << name
|
||||||
|
|
|
@ -234,9 +234,9 @@ class MSpecScript
|
||||||
files patterns
|
files patterns
|
||||||
end
|
end
|
||||||
|
|
||||||
def cores
|
def cores(max = 1)
|
||||||
require 'etc'
|
require 'etc'
|
||||||
Etc.nprocessors
|
[Etc.nprocessors, max].min
|
||||||
end
|
end
|
||||||
|
|
||||||
def setup_env
|
def setup_env
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue