File test_puma_server.rb has 841 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require_relative "helper"
require "puma/events"
require "net/http"

class TestPumaServer < Minitest::Test

Class TestPumaServer has 80 methods (exceeds 20 allowed). Consider refactoring.

Open

class TestPumaServer < Minitest::Test
  parallelize_me! unless JRUBY_HEAD

  def setup
    @host = "127.0.0.1"

Method parse has a Cognitive Complexity of 67 (exceeds 5 allowed). Consider refactoring.

Open

    def parse(binds, logger, log_msg = 'Listening')
      binds.each do |str|
        uri = URI.parse str
        case uri.scheme
        when "tcp"

• Read up
  Read up

Method run has a Cognitive Complexity of 62 (exceeds 5 allowed). Consider refactoring.

Open

    def run
      @status = :run

      output_header "cluster"

• Read up
  Read up

Class DSL has 60 methods (exceeds 20 allowed). Consider refactoring.

Open

  class DSL
    include ConfigDefault

    def initialize(options, config)
      @config  = config

Method run has a Cognitive Complexity of 50 (exceeds 5 allowed). Consider refactoring.

Open

      def run
        title  = "puma: cluster worker #{index}: #{master}"
        title += " [#{@options[:tag]}]" if @options[:tag] && !@options[:tag].empty?
        $0 = title

• Read up
  Read up

File server.rb has 449 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'stringio'

require 'puma/thread_pool'
require 'puma/const'
require 'puma/events'

Method decode_chunk has a Cognitive Complexity of 44 (exceeds 5 allowed). Consider refactoring.

Open

    def decode_chunk(chunk)
      if @partial_part_left > 0
        if @partial_part_left <= chunk.size
          if @partial_part_left > 2
            write_chunk(chunk[0..(@partial_part_left-3)]) # skip the \r\n

• Read up
  Read up

Method hot_restart_does_not_drop_connections has a Cognitive Complexity of 42 (exceeds 5 allowed). Consider refactoring.

Open

  def hot_restart_does_not_drop_connections(num_threads: 1, total_requests: 500)
    skipped = true
    skip_on :jruby, suffix: <<-MSG
 - file descriptors are not preserved on exec on JRuby; connection reset errors are expected during restarts
    MSG

• Read up
  Read up

Method str_headers has a Cognitive Complexity of 36 (exceeds 5 allowed). Consider refactoring.

Open

    def str_headers(env, status, headers, res_info, lines)
      line_ending = LINE_END
      colon = COLON

      http_11 = env[HTTP_VERSION] == HTTP_11

• Read up
  Read up

Class TestBinder has 40 methods (exceeds 20 allowed). Consider refactoring.

Open

class TestBinder < TestBinderBase
  parallelize_me!

  def test_synthesize_binds_from_activated_fds_no_sockets
    binds = ['tcp://0.0.0.0:3000']

Method process_client has a Cognitive Complexity of 35 (exceeds 5 allowed). Consider refactoring.

Open

    def process_client(client, buffer)
      # Advertise this server into the thread
      Thread.current[ThreadLocalKey] = self

      clean_thread_locals = @options[:clean_thread_locals]

• Read up
  Read up

Method handle_request has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

    def handle_request(client, lines)
      env = client.env
      io = client.io

      return false if closed_socket?(io)

• Read up
  Read up

File launcher.rb has 378 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'puma/events'
require 'puma/detect'
require 'puma/cluster'
require 'puma/single'
require 'puma/const'

File cluster.rb has 370 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'puma/runner'
require 'puma/util'
require 'puma/plugin'
require 'puma/cluster/worker_handle'
require 'puma/cluster/worker'

Class Launcher has 37 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Launcher
    KEYS_NOT_TO_PERSIST_IN_STATE = [
       :logger, :lowlevel_error_handler,
       :before_worker_shutdown, :before_worker_boot, :before_worker_fork,
       :after_worker_boot, :before_fork, :on_restart

File test_integration_cluster.rb has 363 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require_relative "helper"
require_relative "helpers/integration"

class TestIntegrationCluster < TestIntegration
  parallelize_me! if ::Puma.mri?

File client.rb has 363 lines of code (exceeds 250 allowed). Consider refactoring.

Open

class IO
  # We need to use this for a jruby work around on both 1.8 and 1.9.
  # So this either creates the constant (on 1.8), or harmlessly
  # reopens it (on 1.9).
  module WaitReadable

Class TestIntegrationCluster has 36 methods (exceeds 20 allowed). Consider refactoring.

Open

class TestIntegrationCluster < TestIntegration
  parallelize_me! if ::Puma.mri?

  def workers ; 2 ; end

Method context has a Cognitive Complexity of 31 (exceeds 5 allowed). Consider refactoring.

Open

      def context
        ctx = MiniSSL::Context.new

        if defined?(JRUBY_VERSION)
          unless params['keystore']

• Read up
  Read up