Class: Bundler::RubyGemsGemInstaller
| Relationships & Source Files | |
| Extension / Inclusion / Inheritance Descendants | |
|
Subclasses:
|
|
| Super Chains via Extension / Inclusion / Inheritance | |
|
Class Chain:
self,
Gem::Installer
|
|
|
Instance Chain:
self,
Gem::Installer
|
|
| Inherits: |
Gem::Installer
|
| Defined in: | lib/bundler/rubygems_gem_installer.rb |
Constant Summary
-
MAX_JOBS_PER_GEM =
# File 'lib/bundler/rubygems_gem_installer.rb', line 10
Cap how many jobserver slots a single gem's
makemay grab so that one gem with many recipes doesn't starve the others sharing the pool. Beyond a handful of jobs the extra parallelism rarely pays off in practice.3
Instance Method Summary
- #build_extensions
- #build_jobs
- #check_executable_overwrite(filename)
- #ensure_writable_dir(dir)
- #gem_checksum
- #generate_bin_script(filename, bindir)
- #generate_plugins
- #install
- #pre_install_checks
- #spec
- #warn_skipped_extensions
- #warn_skipped_plugins
- #connect_to_jobserver private
- #prepare_extension_build(extension_dir) private
- #strict_rm_rf(dir) private
Instance Method Details
#build_extensions
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 140
def build_extensions @jobserver_tokens = +"" @jobserver_read_io, @jobserver_write_io = connect_to_jobserver extension_cache_path = [:bundler_extension_cache_path] extension_dir = spec.extension_dir unless extension_cache_path && extension_dir prepare_extension_build(extension_dir) return super end build_complete = SharedHelpers.filesystem_access(extension_cache_path.join("gem.build_complete"), :read, &:file?) if build_complete && ![:force] SharedHelpers.filesystem_access(File.dirname(extension_dir)) do |p| FileUtils.mkpath p end SharedHelpers.filesystem_access(extension_cache_path) do FileUtils.cp_r extension_cache_path, extension_dir end else prepare_extension_build(extension_dir) super SharedHelpers.filesystem_access(extension_cache_path.parent, &:mkpath) SharedHelpers.filesystem_access(extension_cache_path) do FileUtils.cp_r extension_dir, extension_cache_path end end ensure unless @jobserver_tokens.empty? @jobserver_write_io.write(@jobserver_tokens) @jobserver_write_io.flush end end
#build_jobs
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 131
def build_jobs @jobserver_read_io&.read_nonblock(MAX_JOBS_PER_GEM, @jobserver_tokens) acquired_jobs = @jobserver_tokens.empty? ? nil : @jobserver_tokens.size acquired_jobs || Bundler.settings[:jobs] || super rescue IO::WaitReadable, EOFError 1 end
#check_executable_overwrite(filename)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 12
def check_executable_overwrite(filename) # Bundler needs to install gems regardless of binstub overwriting end
#connect_to_jobserver (private)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 188
def connect_to_jobserver return unless ENV["MAKEFLAGS"] # We append our own --jobserver-auth, so read the last one. Otherwise a # parent jobserver's descriptors (e.g. `bundle install` run under # `make -j`) would be picked up instead of the pool ParallelInstaller created. read_fd, write_fd = ENV["MAKEFLAGS"].scan(/--jobserver-auth=(\d),(\d)/).last return unless read_fd && write_fd # Pass explicit modes. On POSIX, IO.new detects the descriptor's access # mode, but on Windows it can't, so the write end would default to read # mode and raise "IOError: not opened for writing" when releasing slots. [IO.new(read_fd.to_i, "r", autoclose: false), IO.new(write_fd.to_i, "w", autoclose: false)] end
#ensure_writable_dir(dir)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 77
def ensure_writable_dir(dir) super rescue Gem::FilePermissionError # Ignore permission checks in RubyGems. Instead, go on, and try to write # for real. We properly handle permission errors when they happen. nil end
#gem_checksum
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 182
def gem_checksum Checksum.from_gem_package(@package) end
#generate_bin_script(filename, bindir)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 112
def generate_bin_script(filename, bindir) bin_script_path = File.join bindir, formatted_program_filename(filename) Gem.open_file_with_lock(bin_script_path) do require "fileutils" FileUtils.rm_f bin_script_path # prior install may have been --no-wrappers File.open(bin_script_path, "wb", 0o755) do |file| file.write app_script_text(filename) file.chmod([:prog_mode] || 0o755) end end verbose bin_script_path generate_windows_script filename, bindir end
#generate_plugins
[ GitHub ]#install
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 16
def install pre_install_checks run_pre_install_hooks spec.loaded_from = spec_file # Completely remove any previous gem files strict_rm_rf gem_dir strict_rm_rf spec.extension_dir SharedHelpers.filesystem_access(gem_dir, :create) do FileUtils.mkdir_p gem_dir end SharedHelpers.filesystem_access(gem_dir, :write) do extract_files end if [:build_extension] == false warn_skipped_extensions elsif spec.extensions.any? build_extensions end write_build_info_file run_post_build_hooks SharedHelpers.filesystem_access(bin_dir, :write) do generate_bin end if [:install_plugin] == false remove_stale_plugins warn_skipped_plugins else generate_plugins end write_spec SharedHelpers.filesystem_access("#{gem_home}/cache", :write) do write_cache_file end say spec. unless spec..nil? run_post_install_hooks spec end
#pre_install_checks
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 68
def pre_install_checks super rescue Gem::FilePermissionError # Ignore permission checks in RubyGems. Instead, go on, and try to write # for real. We properly handle permission errors when they happen. nil end
#prepare_extension_build(extension_dir) (private)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 203
def prepare_extension_build(extension_dir) SharedHelpers.filesystem_access(extension_dir, :create) do FileUtils.mkdir_p extension_dir end end
#spec
[ GitHub ]#strict_rm_rf(dir) (private)
[ GitHub ]# File 'lib/bundler/rubygems_gem_installer.rb', line 209
def strict_rm_rf(dir) return unless File.exist?(dir) return if Dir.empty?(dir) parent = File.dirname(dir) parent_st = File.stat(parent) if parent_st.world_writable? && !parent_st.sticky? raise InsecureInstallPathError.new(spec.full_name, dir) end begin FileUtils.remove_entry_secure(dir) rescue StandardError => e raise unless File.exist?(dir) raise DirectoryRemovalError.new(e, "Could not delete previous installation of `#{dir}`") end end