Method run_supervisor has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def run_supervisor(dry_run: false)
      if dry_run
        $log.info "starting fluentd-#{Fluent::VERSION} as dry run mode", ruby: RUBY_VERSION
      end

Method socket_option_set has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def socket_option_set(sock, resolve_name: nil, nonblock: false, linger_timeout: nil, recv_timeout: nil, send_timeout: nil, receive_buffer_size: nil, send_keepalive_packet: nil)
        unless resolve_name.nil?
          sock.do_not_reverse_lookup = !resolve_name
        end
        if nonblock

Method build_object has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def build_object(opts)
        qs = opts[:query]
        if tag = qs['tag'.freeze].first
          # ?tag= to search an output plugin by match pattern
          if obj = @agent.plugin_info_by_tag(tag, opts)

• Read up
  Read up

Method with_io has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

        def with_io
          if @open_on_every_update
            io = open
            begin
              yield io

• Read up
  Read up

Method configure has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def configure(conf)
      compat_parameters_convert(conf, :parser)

      super

• Read up
  Read up

Method convert_values has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def convert_values(time, record)
        return time, record unless @execute_convert_values

        record.each_key do |key|
          value = record[key]

• Read up
  Read up

Method on_record has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def on_record(time, record)
      tag = extract_tag_from_record(record)
      tag = @added_prefix_string + tag if tag && @add_prefix
      tag ||= @tag
      time ||= extract_time_from_record(record) || Fluent::EventTime.now

• Read up
  Read up

Method on_timer has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def on_timer
      now = Fluent::EventTime.now

      array = []
      map = {}

• Read up
  Read up

Method try_rollback_all has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def try_rollback_all
        return unless @dequeued_chunks
        @dequeued_chunks_mutex.synchronize do
          until @dequeued_chunks.empty?
            info = @dequeued_chunks.shift

• Read up
  Read up

Method parser_create has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def parser_create(usage: '', type: nil, conf: nil, default_type: nil)
        parser = @_parsers[usage]
        return parser if parser && !type && !conf

        type = if type

• Read up
  Read up

Method formatter_create has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def formatter_create(usage: '', type: nil, conf: nil, default_type: nil)
        formatter = @_formatters[usage]
        return formatter if formatter && !type && !conf

        type = if type

• Read up
  Read up

Method parse_multilines has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def parse_multilines(lines, tail_watcher)
      lb = tail_watcher.line_buffer_timer_flusher.line_buffer
      es = Fluent::MultiEventStream.new
      if @parser.has_firstline?
        tail_watcher.line_buffer_timer_flusher.reset_timer

Method configure has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def configure(conf)
      compat_parameters_convert(conf, :parser)
      parser_config = conf.elements('parse').first
      unless parser_config
        raise Fluent::ConfigError, "<parse> section is required."

Method create_transfer_socket has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def create_transfer_socket(host, port, hostname, &block)
      case @transport
      when :tls
        socket_create_tls(
          host, port,

Method dump_stacktrace has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def dump_stacktrace(type, backtrace, level)
      return if @level > level

      time = Time.now

Method thread_create has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def thread_create(title)
        raise ArgumentError, "BUG: title must be a symbol" unless title.is_a? Symbol
        raise ArgumentError, "BUG: callback not specified" unless block_given?
        m = Mutex.new
        m.lock

Method initialize has 11 arguments (exceeds 4 allowed). Consider refactoring.

Open

        def initialize(title, wait, timeout, forever, max_steps, randomize, randomize_width, backoff_base, max_interval, secondary, secondary_threshold)

Method tls_verify_result_name has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def self.tls_verify_result_name(code)
        case code
        when OpenSSL::X509::V_OK then 'V_OK'
        when OpenSSL::X509::V_ERR_AKID_SKID_MISMATCH then 'V_ERR_AKID_SKID_MISMATCH'
        when OpenSSL::X509::V_ERR_APPLICATION_VERIFICATION then 'V_ERR_APPLICATION_VERIFICATION'

Method start_tcp_server has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def start_tcp_server(tls: false)
      octet_count_frame = @frame_type == :octet_count

      delimiter = octet_count_frame ? " " : @delimiter
      delimiter_size = delimiter.size

Method prepare_option_parser has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def prepare_option_parser
    @parser = OptionParser.new
    @parser.version = Fluent::VERSION
    @parser.banner = <<BANNER
Usage: #{$0} [options] <type> <name>