mirror of
https://github.com/puma/puma.git
synced 2022-11-09 13:48:40 -05:00
80 lines
1.8 KiB
Ruby
80 lines
1.8 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# Standard libraries
|
|
require 'socket'
|
|
require 'tempfile'
|
|
require 'time'
|
|
require 'etc'
|
|
require 'uri'
|
|
require 'stringio'
|
|
|
|
require 'thread'
|
|
|
|
# use require, see https://github.com/puma/puma/pull/2381
|
|
require 'puma/puma_http11'
|
|
|
|
require_relative 'puma/detect'
|
|
require_relative 'puma/json_serialization'
|
|
|
|
module Puma
|
|
# when Puma is loaded via `Puma::CLI`, all files are loaded via
|
|
# `require_relative`. The below are for non-standard loading
|
|
autoload :Const, "#{__dir__}/puma/const"
|
|
autoload :Server, "#{__dir__}/puma/server"
|
|
autoload :Launcher, "#{__dir__}/puma/launcher"
|
|
autoload :LogWriter, "#{__dir__}/puma/log_writer"
|
|
|
|
# at present, MiniSSL::Engine is only defined in extension code (puma_http11),
|
|
# not in minissl.rb
|
|
HAS_SSL = const_defined?(:MiniSSL, false) && MiniSSL.const_defined?(:Engine, false)
|
|
|
|
HAS_UNIX_SOCKET = Object.const_defined? :UNIXSocket
|
|
|
|
if HAS_SSL
|
|
require_relative 'puma/minissl'
|
|
else
|
|
module MiniSSL
|
|
# this class is defined so that it exists when Puma is compiled
|
|
# without ssl support, as Server and Reactor use it in rescue statements.
|
|
class SSLError < StandardError ; end
|
|
end
|
|
end
|
|
|
|
def self.ssl?
|
|
HAS_SSL
|
|
end
|
|
|
|
def self.abstract_unix_socket?
|
|
@abstract_unix ||=
|
|
if HAS_UNIX_SOCKET
|
|
begin
|
|
::UNIXServer.new("\0puma.temp.unix").close
|
|
true
|
|
rescue ArgumentError # darwin
|
|
false
|
|
end
|
|
else
|
|
false
|
|
end
|
|
end
|
|
|
|
# @!attribute [rw] stats_object=
|
|
def self.stats_object=(val)
|
|
@get_stats = val
|
|
end
|
|
|
|
# @!attribute [rw] stats_object
|
|
def self.stats
|
|
Puma::JSONSerialization.generate @get_stats.stats
|
|
end
|
|
|
|
# @!attribute [r] stats_hash
|
|
# @version 5.0.0
|
|
def self.stats_hash
|
|
@get_stats.stats
|
|
end
|
|
|
|
def self.set_thread_name(name)
|
|
Thread.current.name = "puma #{name}"
|
|
end
|
|
end
|