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