class Bundler::ParallelInstaller
Attributes
size[R]
Public Class Methods
call(*args, **kwargs)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 65 def self.call(*args, **kwargs) new(*args, **kwargs).call end
new(installer, all_specs, size, standalone, force, skip: nil)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 71 def initialize(installer, all_specs, size, standalone, force, skip: nil) @installer = installer @size = size @standalone = standalone @force = force @specs = all_specs.map {|s| SpecInstallation.new(s) } @specs.each do |spec_install| spec_install.state = :installed if skip.include?(spec_install.name) end if skip @spec_set = all_specs @rake = @specs.find {|s| s.name == "rake" unless s.installed? } end
Public Instance Methods
call()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 84 def call if @rake do_install(@rake, 0) Gem::Specification.reset end if @size > 1 install_with_worker else install_serially end handle_error if failed_specs.any? @specs ensure worker_pool&.stop end
Private Instance Methods
do_install(spec_install, worker_num)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 127 def do_install(spec_install, worker_num) Plugin.hook(Plugin::Events::GEM_BEFORE_INSTALL, spec_install) gem_installer = Bundler::GemInstaller.new( spec_install.spec, @installer, @standalone, worker_num, @force ) success, message = gem_installer.install_from_spec if success spec_install.state = :installed spec_install.post_install_message = message unless message.nil? else spec_install.error = "#{message}\n\n#{require_tree_for_spec(spec_install.spec)}" spec_install.state = :failed end Plugin.hook(Plugin::Events::GEM_AFTER_INSTALL, spec_install) spec_install end
enqueue_specs()
click to toggle source
Keys in the remains hash represent uninstalled gems specs. We enqueue all gem specs that do not have any dependencies. Later we call this lambda again to install specs that depended on previously installed specifications. We continue until all specs are installed.
# File bundler/installer/parallel_installer.rb, line 187 def enqueue_specs installed_specs = {} @specs.each do |spec| next unless spec.installed? installed_specs[spec.name] = true end @specs.each do |spec| if spec.ready_to_enqueue? && spec.dependencies_installed?(installed_specs) spec.state = :enqueued worker_pool.enq spec end end end
failed_specs()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 104 def failed_specs @specs.select(&:failed?) end
finished_installing?()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 154 def finished_installing? @specs.all? do |spec| return true if spec.failed? spec.installed? end end
handle_error()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 161 def handle_error errors = failed_specs.map(&:error) if exception = errors.find {|e| e.is_a?(Bundler::BundlerError) } raise exception end raise Bundler::InstallError, errors.join("\n\n") end
install_serially()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 113 def install_serially until finished_installing? raise "failed to find a spec to enqueue while installing serially" unless spec_install = @specs.find(&:ready_to_enqueue?) spec_install.state = :enqueued do_install(spec_install, 0) end end
install_with_worker()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 108 def install_with_worker enqueue_specs process_specs until finished_installing? end
process_specs()
click to toggle source
Dequeue a spec and save its post-install message and then enqueue the remaining specs. Some specs might’ve had to wait til this spec was installed to be processed so the call to ‘enqueue_specs` is important after every dequeue.
# File bundler/installer/parallel_installer.rb, line 149 def process_specs worker_pool.deq enqueue_specs end
require_tree_for_spec(spec)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 169 def require_tree_for_spec(spec) tree = @spec_set.what_required(spec) t = String.new("In #{File.basename(SharedHelpers.default_gemfile)}:\n") tree.each_with_index do |s, depth| t << " " * depth.succ << s.name unless tree.last == s t << %( was resolved to #{s.version}, which depends on) end t << %(\n) end t end
worker_pool()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 121 def worker_pool @worker_pool ||= Bundler::Worker.new @size, "Parallel Installer", lambda {|spec_install, worker_num| do_install(spec_install, worker_num) } end