Class: Homebrew::Bundle::ParallelInstaller Private

Inherits:
Object
  • Object
show all
Defined in:
bundle/parallel_installer.rb

This class is part of a private API. This class may only be used in the Homebrew/brew repository. Third parties should avoid using this class if possible, as it may be removed or changed without warning.

Instance Method Summary collapse

Constructor Details

#initialize(entries, jobs:, no_upgrade:, verbose:, force:, quiet:) ⇒ void

This method is part of a private API. This method may only be used in the Homebrew/brew repository. Third parties should avoid using this method if possible, as it may be removed or changed without warning.

Parameters:



23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'bundle/parallel_installer.rb', line 23

def initialize(entries, jobs:, no_upgrade:, verbose:, force:, quiet:)
  @entries = entries
  @jobs = jobs
  @no_upgrade = no_upgrade
  @verbose = verbose
  @force = force
  @quiet = quiet
  @pool = T.let(Concurrent::FixedThreadPool.new(jobs), Concurrent::FixedThreadPool)
  @output_mutex = T.let(Monitor.new, Monitor)
  # Cask installs may trigger interactive sudo prompts that write
  # directly to the terminal.  Serialize them so Password: prompts
  # don't interleave with status output from other workers.
  @cask_install_mutex = T.let(Mutex.new, Mutex)
end

Instance Method Details

#run! ⇒ Array<(Integer, Integer)>

This method is part of a private API. This method may only be used in the Homebrew/brew repository. Third parties should avoid using this method if possible, as it may be removed or changed without warning.

Returns:



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'bundle/parallel_installer.rb', line 39

def run!
  success = 0
  failure = 0

  tap_entries, pending_entries = @entries.partition { |entry| entry.cls == Homebrew::Bundle::Tap }
  tap_entries.each_slice(@jobs) do |batch|
    tap_success, tap_failure = install_entries_parallel!(batch)
    success += tap_success
    failure += tap_failure
  end
  ::Tap.clear_cache if tap_entries.present?

  prepare_attestation_verification!(pending_entries)
  dependency_map = build_dependency_map(pending_entries)
  completed = T.let(Set.new, T::Set[String])
  until pending_entries.empty?
    ready_entries = pending_entries.select do |entry|
      dependency_map.fetch(entry.name, Set.new).all? { |dependency| completed.include?(dependency) }
    end

    if ready_entries.empty?
      pending_entries.each do |entry|
        installed = install_entry!(entry)
        completed << entry.name
        if installed
          success += 1
        else
          failure += 1
        end
      end
      break
    end

    batch = ready_entries.take(@jobs)
    batch_success, batch_failure = install_entries_parallel!(batch)
    success += batch_success
    failure += batch_failure

    pending_entries -= batch
    completed.merge(batch.map(&:name))
  end

  [success, failure]
ensure
  @pool.shutdown
  @pool.wait_for_termination
end