Method test_chunked_keep_alive_two_back_to_back has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def test_chunked_keep_alive_two_back_to_back
    body = nil
    content_length = nil
    server_run { |env|
      body = env['rack.input'].read

Method initialize has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def initialize(argv, log_writer = LogWriter.stdio, events = Events.new)
      @debug = false
      @argv = argv.dup
      @log_writer = log_writer
      @events = events

Method serialize_value has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def serialize_value(output, value)
        case value
        when Hash
          output << '{'
          value.each_with_index do |(k, v), index|

Method issue_cert has 9 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def issue_cert(dn, key, serial, not_before, not_after, extensions, issuer, issuer_key, digest)

Method test_horrible_queries has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def test_horrible_queries
    parser = Puma::HttpParser.new

    # then that large header names are caught
    10.times do |c|

Method new_socket has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def new_socket(host: nil, port: nil, path: nil, ctx: nil, session: nil)
      port  ||= @bind_port
      path  ||= @bind_path
      ip ||= (host || HOST.ip).gsub RE_HOST_TO_IP, ''  # in case a URI style IPv6 is passed

Method test_worker_index_is_with_in_options_limit has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def test_worker_index_is_with_in_options_limit
    skip_unless_signal_exist? :TERM

    cli_server "-C test/config/t3_conf.rb test/rackup/hello.ru"

• Read up
  Read up

Method term_closes_listeners has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def term_closes_listeners(unix: false)
    skip_unless_signal_exist? :TERM

    cli_server "-w #{workers} -t 0:6 -q test/rackup/sleep_step.ru", unix: unix
    threads = []

• Read up
  Read up

Method fast_write has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def fast_write(io, str)
    n = 0
    while true
      begin
        n = io.syswrite str

• Read up
  Read up

Method handler_opts has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def handler_opts(options)
      begin
        info = []
        server = Rack::Handler.get(options[:server]) || Rack::Handler.default(options)
        if server&.respond_to?(:valid_options)

• Read up
  Read up

Method cli_server has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def cli_server(argv,  # rubocop:disable Metrics/ParameterLists
      unix: false,      # uses a UNIXSocket for the server listener when true
      config: nil,      # string to use for config file
      no_bind: nil,     # bind is defined by args passed or config file
      merge_err: false, # merge STDERR into STDOUT

• Read up
  Read up

Method test_closed_listener has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def test_closed_listener
    skip_unless_signal_exist? :TERM

    cli_server "test/rackup/close_listeners.ru", merge_err: true
    connection = fast_connect

• Read up
  Read up

Method load has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def load(path)
      File.read(path).lines.each do |line|
        next if line.start_with? '#'
        k,v = line.split ':', 2
        next unless v && ALLOWED_FIELDS.include?(k)

• Read up
  Read up

Method wait_for_less_busy_worker has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def wait_for_less_busy_worker(delay_s)
      return unless delay_s && delay_s > 0

      # Ruby MRI does GVL, this can result
      # in processing contention when multiple threads

• Read up
  Read up

Method lowlevel_error has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def lowlevel_error(e, env, status=500)
      if handler = options[:lowlevel_error_handler]
        if handler.arity == 1
          return handler.call(e)
        elsif handler.arity == 2

• Read up
  Read up

Method test_closed_listener has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def test_closed_listener
    skip_unless_signal_exist? :TERM

    cli_server "test/rackup/close_listeners.ru", merge_err: true
    connection = fast_connect

Method initialize has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def initialize(io, env=nil)
      @io = io
      @to_io = io.to_io
      @io_buffer = IOBuffer.new
      @proto_env = env

Method with_server has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def with_server(**options, &app)
    @requests_count = 0 # number of requests processed
    @requests_running = 0 # current number of requests running
    @requests_max_running = 0 # max number of requests running in parallel
    @mutex = Mutex.new

Method test_drain_on_shutdown has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def test_drain_on_shutdown(drain=true)
    num_connections = 10

    wait = Queue.new
    server_run(drain_on_shutdown: drain, max_threads: 1) do

Method cli_server has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def cli_server(argv,  # rubocop:disable Metrics/ParameterLists
      unix: false,      # uses a UNIXSocket for the server listener when true
      config: nil,      # string to use for config file
      no_bind: nil,     # bind is defined by args passed or config file
      merge_err: false, # merge STDERR into STDOUT