Sha256: 851fea0657973c769e7328e109c3d77d73bd0819c352b51e9813ea41440ef0d1
Contents?: true
Size: 1.95 KB
Versions: 15
Compression:
Stored size: 1.95 KB
Contents
module Einhorn
module Compat
# In Ruby 2.1.0 (and possibly earlier), IO.pipe sets cloexec on
# the descriptors.
def self.pipe
readable, writeable = IO.pipe
cloexec!(readable, false)
cloexec!(writeable, false)
[readable, writeable]
end
def self.cloexec!(fd, enable)
original = fd.fcntl(Fcntl::F_GETFD)
if enable
new = original | Fcntl::FD_CLOEXEC
else
new = original & (-Fcntl::FD_CLOEXEC-1)
end
fd.fcntl(Fcntl::F_SETFD, new)
end
def self.cloexec?(fd)
fd.fcntl(Fcntl::F_GETFD) & Fcntl::FD_CLOEXEC
end
# Opts are ignored in Ruby 1.8
def self.exec(script, args, opts={})
cmd = [script, script]
begin
Kernel.exec(cmd, *(args + [opts]))
rescue TypeError
Kernel.exec(cmd, *args)
end
end
def self.unixserver_new(path)
server = UNIXServer.new(path)
cloexec!(server, false)
server
end
def self.accept_nonblock(server)
sock = server.accept_nonblock
cloexec!(sock, false)
sock
end
def self.processor_count
# jruby
if defined? Java::Java
return Java::Java.lang.Runtime.getRuntime.availableProcessors
end
# linux / friends
begin
return File.read('/proc/cpuinfo').scan(/^processor\s*:/).count
rescue Errno::ENOENT
end
# OS X
if RUBY_PLATFORM =~ /darwin/
return Integer(`sysctl -n hw.logicalcpu`)
end
# windows / friends
begin
require 'win32ole'
rescue LoadError
else
wmi = WIN32OLE.connect("winmgmts://")
wmi.ExecQuery("select * from Win32_ComputerSystem").each do |system|
begin
processors = system.NumberOfLogicalProcessors
rescue
processors = 0
end
return [system.NumberOfProcessors, processors].max
end
end
raise "Failed to detect number of CPUs"
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems