Class: Puma::Configuration

# File 'lib/puma/configuration.rb', line 363

def self.temp_path
  require 'tmpdir'

  t = (Time.now.to_f * 1000).to_i
  "#{Dir.tmpdir}/puma-status-#{t}-#{$$}"
end

# File 'lib/puma/configuration.rb', line 199

attr_reader :plugins, :events, :hooks

# File 'lib/puma/configuration.rb', line 199

attr_reader :plugins, :events, :hooks

# File 'lib/puma/configuration.rb', line 199

attr_reader :plugins, :events, :hooks

# File 'lib/puma/configuration.rb', line 281

def clamp
  load unless @loaded
  set_conditional_default_options
  @_options.finalize_values
  @clamped = true
  warn_hooks
  options
end

# File 'lib/puma/configuration.rb', line 262

def config_files
  raise NotLoadedError, "ensure load is called before accessing config_files" unless @loaded

  files = @_options.all_of(:config_files)

  return [] if files == ['-']
  return files if files.any?

  first_default_file = %W(config/puma/#{@_options[:environment]}.rb config/puma.rb).find do |f|
    File.exist?(f)
  end

  [first_default_file]
end

# File 'lib/puma/configuration.rb', line 207

def configure
  yield @user_dsl, @file_dsl, @default_dsl
ensure
  @user_dsl._offer_plugins
  @file_dsl._offer_plugins
  @default_dsl._offer_plugins
end

# File 'lib/puma/configuration.rb', line 329

def environment
  options[:environment]
end

# File 'lib/puma/configuration.rb', line 359

def final_options
  options.final_options
end

# File 'lib/puma/configuration.rb', line 221

def flatten
  dup.flatten!
end

# File 'lib/puma/configuration.rb', line 225

def flatten!
  @_options = @_options.flatten
  self
end

# File 'lib/puma/configuration.rb', line 215

def initialize_copy(other)
  @conf        = nil
  @cli_options = nil
  @_options     = @_options.dup
end

# File 'lib/puma/configuration.rb', line 256

def load
  @loaded = true
  config_files.each { |config_file| @file_dsl._load_from(config_file) }
  @_options
end

# File 'lib/puma/configuration.rb', line 333

def load_plugin(name)
  @plugins.create name
end

# File 'lib/puma/configuration.rb', line 410

def load_rackup
  raise "Missing rackup file '#{rackup}'" unless File.exist?(rackup)

  rack_app, rack_options = rack_builder.parse_file(rackup)
  rack_options = rack_options || {}

  options.file_options.merge!(rack_options)

  config_ru_binds = []
  rack_options.each do |k, v|
    config_ru_binds << v if k.to_s.start_with?("bind")
  end

  options.file_options[:binds] = config_ru_binds unless config_ru_binds.empty?

  rack_app
end

# File 'lib/puma/configuration.rb', line 201

def options
  raise NotClampedError, "ensure clamp is called before accessing options" unless @clamped

  @_options
end

# File 'lib/puma/configuration.rb', line 230

def puma_default_options(env = ENV)
  defaults = DEFAULTS.dup
  puma_options_from_env(env).each { |k,v| defaults[k] = v if v }
  defaults
end

# File 'lib/puma/configuration.rb', line 236

def puma_options_from_env(env = ENV)
  min = env['PUMA_MIN_THREADS'] || env['MIN_THREADS']
  max = env['PUMA_MAX_THREADS'] || env['MAX_THREADS']
  persistent_timeout = env['PUMA_PERSISTENT_TIMEOUT']
  workers = if env['WEB_CONCURRENCY'] == 'auto'
    require_processor_counter
    ::Concurrent.available_processor_count
  else
    env['WEB_CONCURRENCY']
  end

  {
    min_threads: min && min != "" && Integer(min),
    max_threads: max && max != "" && Integer(max),
    persistent_timeout: persistent_timeout && persistent_timeout != "" && Integer(persistent_timeout),
    workers: workers && workers != "" && Integer(workers),
    environment: env['APP_ENV'] || env['RACK_ENV'] || env['RAILS_ENV'],
  }
end

# File 'lib/puma/configuration.rb', line 390

def rack_builder
  # Load bundler now if we can so that we can pickup rack from
  # a Gemfile
  if @puma_bundler_pruned
    begin
      require 'bundler/setup'
    rescue LoadError
    end
  end

  begin
    require 'rack'
    require 'rack/builder'
    ::Rack::Builder
  rescue LoadError
    require_relative 'rack/builder'
    Puma::Rack::Builder
  end
end

# File 'lib/puma/configuration.rb', line 309

def rackup
  options[:rackup]
end

# File 'lib/puma/configuration.rb', line 378

def require_processor_counter
  require 'concurrent/utility/processor_counter'
rescue LoadError
  warn <<~MESSAGE
    WEB_CONCURRENCY=auto requires the "concurrent-ruby" gem to be installed.
    Please add "concurrent-ruby" to your Gemfile.
  MESSAGE
  raise
end

# File 'lib/puma/configuration.rb', line 340

def run_hooks(key, arg, log_writer, hook_data = nil)
  log_writer.debug "Running #{key} hooks"

  options.all_of(key).each do |hook_options|
    begin
      block = hook_options[:block]
      if id = hook_options[:id]
        hook_data[id] ||= Hash.new
        block.call arg, hook_data[id]
      else
        block.call arg
      end
    rescue => e
      log_writer.log "WARNING hook #{key} failed with exception (#{e.class}) #{e.message}"
      log_writer.debug e.backtrace.join("\n")
    end
  end
end

# File 'lib/puma/configuration.rb', line 428

def set_conditional_default_options
  @_options.default_options[:preload_app] = !@_options[:prune_bundler] &&
    (@_options[:workers] > 1) && Puma.forkable?
end

# File 'lib/puma/configuration.rb', line 433

def warn_hooks
  return if options[:workers] > 0
  return if options[:silence_fork_callback_warning]

  log_writer = LogWriter.stdio
  @hooks.each_key do |hook|
    options.all_of(hook).each do |hook_options|
      next unless hook_options[:cluster_only]

      log_writer.log(<<~MSG.tr("\n", " "))
        Warning: The code in the `#{hook}` block will not execute
        in the current Puma configuration. The `#{hook}` block only
        executes in Puma's cluster mode. To fix this, either remove the
        `#{hook}` call or increase Puma's worker count above zero.
      MSG
    end
  end
end