File Manager

X7ROOT File Manager

Current Path: /opt/alt/ruby32/share/gems/gems/bundler-2.4.19/lib/bundler

opt / alt / ruby32 / share / gems / gems / bundler-2.4.19 / lib / bundler /

ðŸ“ ..
ðŸ“„ build_metadata.rb(1.2 KB)
ðŸ“„ capistrano.rb(883 B)
ðŸ“ cli
ðŸ“„ cli.rb(41 KB)
ðŸ“ compact_index_client
ðŸ“„ compact_index_client.rb(3.36 KB)
ðŸ“„ constants.rb(224 B)
ðŸ“„ current_ruby.rb(2.43 KB)
ðŸ“„ definition.rb(32.33 KB)
ðŸ“„ dependency.rb(3.11 KB)
ðŸ“„ deployment.rb(3.19 KB)
ðŸ“„ deprecate.rb(876 B)
ðŸ“„ digest.rb(2.16 KB)
ðŸ“„ dsl.rb(19.97 KB)
ðŸ“„ endpoint_specification.rb(3.65 KB)
ðŸ“„ env.rb(5.01 KB)
ðŸ“„ environment_preserver.rb(1.94 KB)
ðŸ“„ errors.rb(5.17 KB)
ðŸ“„ feature_flag.rb(1.79 KB)
ðŸ“ fetcher
ðŸ“„ fetcher.rb(11.19 KB)
ðŸ“„ force_platform.rb(557 B)
ðŸ“„ friendly_errors.rb(3.75 KB)
ðŸ“„ gem_helper.rb(6.89 KB)
ðŸ“„ gem_helpers.rb(4.08 KB)
ðŸ“„ gem_tasks.rb(138 B)
ðŸ“„ gem_version_promoter.rb(4.76 KB)
ðŸ“„ graph.rb(4.99 KB)
ðŸ“„ index.rb(4.14 KB)
ðŸ“„ injector.rb(10.08 KB)
ðŸ“„ inline.rb(2.47 KB)
ðŸ“ installer
ðŸ“„ installer.rb(10.25 KB)
ðŸ“„ lazy_specification.rb(5.35 KB)
ðŸ“„ lockfile_generator.rb(2.18 KB)
ðŸ“„ lockfile_parser.rb(7.01 KB)
ðŸ“ man
ðŸ“„ match_metadata.rb(290 B)
ðŸ“„ match_platform.rb(583 B)
ðŸ“„ match_remote_metadata.rb(863 B)
ðŸ“„ mirror.rb(5.78 KB)
ðŸ“ plugin
ðŸ“„ plugin.rb(11.25 KB)
ðŸ“„ process_lock.rb(686 B)
ðŸ“„ remote_specification.rb(3.71 KB)
ðŸ“ resolver
ðŸ“„ resolver.rb(14.62 KB)
ðŸ“„ retry.rb(1.61 KB)
ðŸ“„ ruby_dsl.rb(961 B)
ðŸ“„ ruby_version.rb(4.17 KB)
ðŸ“„ rubygems_ext.rb(10.88 KB)
ðŸ“„ rubygems_gem_installer.rb(5.24 KB)
ðŸ“„ rubygems_integration.rb(15.82 KB)
ðŸ“„ runtime.rb(10.15 KB)
ðŸ“„ safe_marshal.rb(597 B)
ðŸ“„ self_manager.rb(4.76 KB)
ðŸ“ settings
ðŸ“„ settings.rb(13.19 KB)
ðŸ“„ setup.rb(963 B)
ðŸ“„ shared_helpers.rb(10.76 KB)
ðŸ“„ similarity_detector.rb(1.84 KB)
ðŸ“ source
ðŸ“„ source.rb(2.98 KB)
ðŸ“„ source_list.rb(6.18 KB)
ðŸ“„ source_map.rb(2.17 KB)
ðŸ“„ spec_set.rb(5.08 KB)
ðŸ“„ stub_specification.rb(2.79 KB)
ðŸ“ templates
ðŸ“ ui
ðŸ“„ ui.rb(255 B)
ðŸ“„ uri_credentials_filter.rb(1.28 KB)
ðŸ“„ uri_normalizer.rb(715 B)
ðŸ“ vendor
ðŸ“„ vendored_fileutils.rb(101 B)
ðŸ“„ vendored_persistent.rb(270 B)
ðŸ“„ vendored_pub_grub.rb(99 B)
ðŸ“„ vendored_thor.rb(180 B)
ðŸ“„ vendored_tsort.rb(93 B)
ðŸ“„ vendored_uri.rb(89 B)
ðŸ“„ version.rb(260 B)
ðŸ“„ vlad.rb(468 B)
ðŸ“„ worker.rb(2.85 KB)
ðŸ“„ yaml_serializer.rb(2.36 KB)

Editing: worker.rb

# 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|
        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.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

X7ROOT File Manager

Editing: worker.rb

Upload File

Create Folder