Gecko [ v3.cesa.co.za ]

Name	Size	Permission	Date
cli	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
compact_index_client	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
fetcher	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
installer	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
man	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
plugin	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
resolver	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
settings	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
source	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
templates	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
ui	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
vendor	[ DIR ]	drwxr-xr-x	2025-06-05 11:22
build_metadata.rb	1.22 KB	-rw-r--r--	2022-04-12 11:11
capistrano.rb	883 B	-rw-r--r--	2022-04-12 11:11
cli.rb	38.73 KB	-rw-r--r--	2022-04-12 11:11
compact_index_client.rb	3.36 KB	-rw-r--r--	2022-04-12 11:11
constants.rb	212 B	-rw-r--r--	2022-04-12 11:11
current_ruby.rb	2.14 KB	-rw-r--r--	2022-04-12 11:11
definition.rb	28.7 KB	-rw-r--r--	2022-04-12 11:11
dep_proxy.rb	961 B	-rw-r--r--	2022-04-12 11:11
dependency.rb	4.69 KB	-rw-r--r--	2022-04-12 11:11
deployment.rb	3.19 KB	-rw-r--r--	2022-04-12 11:11
deprecate.rb	876 B	-rw-r--r--	2022-04-12 11:11
digest.rb	2.17 KB	-rw-r--r--	2022-04-12 11:11
dsl.rb	20.03 KB	-rw-r--r--	2022-04-12 11:11
endpoint_specification.rb	3.86 KB	-rw-r--r--	2022-04-12 11:11
env.rb	5.02 KB	-rw-r--r--	2022-04-12 11:11
environment_preserver.rb	1.94 KB	-rw-r--r--	2022-04-12 11:11
errors.rb	5.21 KB	-rw-r--r--	2022-04-12 11:11
feature_flag.rb	1.94 KB	-rw-r--r--	2022-04-12 11:11
fetcher.rb	10.94 KB	-rw-r--r--	2022-04-12 11:11
friendly_errors.rb	3.63 KB	-rw-r--r--	2022-04-12 11:11
gem_helper.rb	6.93 KB	-rw-r--r--	2022-04-12 11:11
gem_helpers.rb	3.85 KB	-rw-r--r--	2022-04-12 11:11
gem_tasks.rb	138 B	-rw-r--r--	2022-04-12 11:11
gem_version_promoter.rb	6.54 KB	-rw-r--r--	2022-04-12 11:11
graph.rb	4.99 KB	-rw-r--r--	2022-04-12 11:11
index.rb	5.21 KB	-rw-r--r--	2022-04-12 11:11
injector.rb	9.87 KB	-rw-r--r--	2022-04-12 11:11
inline.rb	2.79 KB	-rw-r--r--	2022-04-12 11:11
installer.rb	11.2 KB	-rw-r--r--	2022-04-12 11:11
lazy_specification.rb	4.94 KB	-rw-r--r--	2022-04-12 11:11
lockfile_generator.rb	2.16 KB	-rw-r--r--	2022-04-12 11:11
lockfile_parser.rb	6.89 KB	-rw-r--r--	2022-04-12 11:11
match_platform.rb	660 B	-rw-r--r--	2022-04-12 11:11
mirror.rb	5.82 KB	-rw-r--r--	2022-04-12 11:11
plugin.rb	11.13 KB	-rw-r--r--	2022-04-12 11:11
process_lock.rb	658 B	-rw-r--r--	2022-04-12 11:11
remote_specification.rb	3.97 KB	-rw-r--r--	2022-04-12 11:11
resolver.rb	14.58 KB	-rw-r--r--	2022-04-12 11:11
retry.rb	1.61 KB	-rw-r--r--	2022-04-12 11:11
ruby_dsl.rb	761 B	-rw-r--r--	2022-04-12 11:11
ruby_version.rb	4.41 KB	-rw-r--r--	2022-04-12 11:11
rubygems_ext.rb	6.56 KB	-rw-r--r--	2022-04-12 11:11
rubygems_gem_installer.rb	5.2 KB	-rw-r--r--	2022-04-12 11:11
rubygems_integration.rb	16.66 KB	-rw-r--r--	2022-04-12 11:11
runtime.rb	10.43 KB	-rw-r--r--	2022-04-12 11:11
self_manager.rb	4.76 KB	-rw-r--r--	2022-04-12 11:11
settings.rb	13.42 KB	-rw-r--r--	2022-04-12 11:11
setup.rb	776 B	-rw-r--r--	2022-04-12 11:11
shared_helpers.rb	10.84 KB	-rw-r--r--	2022-04-12 11:11
similarity_detector.rb	1.84 KB	-rw-r--r--	2022-04-12 11:11
source.rb	3.12 KB	-rw-r--r--	2022-04-12 11:11
source_list.rb	5.96 KB	-rw-r--r--	2022-04-12 11:11
source_map.rb	1.78 KB	-rw-r--r--	2022-04-12 11:11
spec_set.rb	4.57 KB	-rw-r--r--	2022-04-12 11:11
stub_specification.rb	2.87 KB	-rw-r--r--	2022-04-12 11:11
ui.rb	255 B	-rw-r--r--	2022-04-12 11:11
uri_credentials_filter.rb	1.28 KB	-rw-r--r--	2022-04-12 11:11
vendored_fileutils.rb	101 B	-rw-r--r--	2022-04-12 11:11
vendored_molinillo.rb	101 B	-rw-r--r--	2022-04-12 11:11
vendored_persistent.rb	1.44 KB	-rw-r--r--	2022-04-12 11:11
vendored_thor.rb	180 B	-rw-r--r--	2022-04-12 11:11
vendored_tmpdir.rb	95 B	-rw-r--r--	2022-04-12 11:11
vendored_tsort.rb	93 B	-rw-r--r--	2022-04-12 11:11
vendored_uri.rb	89 B	-rw-r--r--	2022-04-12 11:11
version.rb	179 B	-rw-r--r--	2022-04-12 11:11
version_ranges.rb	3.8 KB	-rw-r--r--	2022-04-12 11:11
vlad.rb	468 B	-rw-r--r--	2022-04-12 11:11
worker.rb	2.89 KB	-rw-r--r--	2022-04-12 11:11
yaml_serializer.rb	2.36 KB	-rw-r--r--	2022-04-12 11:11

Rename

# frozen_string_literal: true

module Bundler
  class Worker
    POISON = Object.new

class WrappedException < StandardError
      attr_reader :exception
      def initialize(exn)
        @exception = exn
      end
    end

# @return [String] the name of the worker
    attr_reader :name

# Creates a worker pool of specified size
    #
    # @param size [Integer] Size of pool
    # @param name [String] name the name of the worker
    # @param func [Proc] job to run in inside the worker pool
    def initialize(size, name, func)
      @name = name
      @request_queue = Thread::Queue.new
      @response_queue = Thread::Queue.new
      @func = func
      @size = size
      @threads = nil
      @previous_interrupt_handler = nil
    end

# Enqueue a request to be executed in the worker pool
    #
    # @param obj [String] mostly it is name of spec that should be downloaded
    def enq(obj)
      create_threads unless @threads
      @request_queue.enq obj
    end

# Retrieves results of job function being executed in worker pool
    def deq
      result = @response_queue.deq
      raise result.exception if result.is_a?(WrappedException)
      result
    end

def stop
      stop_threads
    end

private

def process_queue(i)
      loop do
        obj = @request_queue.deq
        break if obj.equal? POISON
        @response_queue.enq apply_func(obj, i)
      end
    end

def apply_func(obj, i)
      @func.call(obj, i)
    rescue Exception => e # rubocop:disable Lint/RescueException
      WrappedException.new(e)
    end

# Stop the worker threads by sending a poison object down the request queue
    # so as worker threads after retrieving it, shut themselves down
    def stop_threads
      return unless @threads

@threads.each { @request_queue.enq POISON }
      @threads.each(&:join)

remove_interrupt_handler

@threads = nil
    end

def abort_threads
      Bundler.ui.debug("\n#{caller.join("\n")}")
      @threads.each(&:exit)
      exit 1
    end

def create_threads
      creation_errors = []

@threads = Array.new(@size) do |i|
        begin
          Thread.start { process_queue(i) }.tap do |thread|
            thread.name = "#{name} Worker ##{i}" if thread.respond_to?(:name=)
          end
        rescue ThreadError => e
          creation_errors << e
          nil
        end
      end.compact

add_interrupt_handler unless @threads.empty?

return if creation_errors.empty?

message = "Failed to create threads for the #{name} worker: #{creation_errors.map(&:to_s).uniq.join(", ")}"
      raise ThreadCreationError, message if @threads.empty?
      Bundler.ui.info message
    end

def add_interrupt_handler
      @previous_interrupt_handler = trap("INT") { abort_threads }
    end

def remove_interrupt_handler
      return unless @previous_interrupt_handler

trap "INT", @previous_interrupt_handler
    end
  end
end