class Bundler::ParallelInstaller
Attributes
size[R]
Public Class Methods
call(*args)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 66 def self.call(*args) new(*args).call end
new(installer, all_specs, size, standalone, force)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 72 def initialize(installer, all_specs, size, standalone, force) @installer = installer @size = size @standalone = standalone @force = force @specs = all_specs.map {|s| SpecInstallation.new(s) } @spec_set = all_specs @rake = @specs.find {|s| s.name == "rake" } end
Public Instance Methods
call()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 82 def call if @rake do_install(@rake, 0) Gem::Specification.reset end if @size > 1 install_with_worker else install_serially end check_for_unmet_dependencies handle_error if failed_specs.any? @specs ensure worker_pool && worker_pool.stop end
check_for_unmet_dependencies()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 102 def check_for_unmet_dependencies unmet_dependencies = @specs.map do |s| [ s, s.dependencies.reject {|dep| @specs.any? {|spec| dep.matches_spec?(spec.spec) } }, ] end.reject {|a| a.last.empty? } return if unmet_dependencies.empty? warning = [] warning << "Your lockfile doesn't include a valid resolution." warning << "You can fix this by regenerating your lockfile or manually editing the bad locked gems to a version that satisfies all dependencies." warning << "The unmet dependencies are:" unmet_dependencies.each do |spec, unmet_spec_dependencies| unmet_spec_dependencies.each do |unmet_spec_dependency| found = @specs.find {|s| s.name == unmet_spec_dependency.name && !unmet_spec_dependency.matches_spec?(s.spec) } warning << "* #{unmet_spec_dependency}, dependency of #{spec.full_name}, unsatisfied by #{found.full_name}" end end Bundler.ui.warn(warning.join("\n")) end
Private Instance Methods
do_install(spec_install, worker_num)
click to toggle source
# File bundler/installer/parallel_installer.rb, line 151 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 211 def enqueue_specs @specs.select(&:ready_to_enqueue?).each do |spec| if spec.dependencies_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 128 def failed_specs @specs.select(&:failed?) end
finished_installing?()
click to toggle source
# File bundler/installer/parallel_installer.rb, line 178 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 185 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 137 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 132 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 173 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 193 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 145 def worker_pool @worker_pool ||= Bundler::Worker.new @size, "Parallel Installer", lambda {|spec_install, worker_num| do_install(spec_install, worker_num) } end