Method add_match has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def add_match(type, pattern, conf)
      log_type = conf.for_this_worker? ? :default : :worker0
      log.info log_type, "adding match#{@context.nil? ? '' : " in #{@context}"}", pattern: pattern, type: type

      output = Plugin.new_output(type)

• Read up
  Read up

Method build_spawn_command has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def build_spawn_command
      if ENV['TEST_RUBY_PATH']
        fluentd_spawn_cmd = [ENV['TEST_RUBY_PATH']]
      else
        fluentd_spawn_cmd = [ServerEngine.ruby_bin_path]

• Read up
  Read up

Method warn has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def warn(*args, &block)
      return if @level > LEVEL_WARN
      type = log_type(args)
      return if skipped_type?(type)
      args << block.call if block

• Read up
  Read up

Method set_version_to_context has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def set_version_to_context(ctx, version, min_version, max_version)
      if MIN_MAX_AVAILABLE
        case
        when min_version.nil? && max_version.nil?
          min_version = METHODS_MAP[version] || version

• Read up
  Read up

Method mount_proc has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def mount_proc(path, &block)
        @server.mount_proc(path) { |req, res|
          begin
            code, header, response = block.call(req, res)
          rescue => e

• Read up
  Read up

Method array_value has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def self.array_value(val, opts = {}, name = nil)
      return nil if val.nil?

      param = if val.is_a?(String)
                val.start_with?('[') ? JSON.parse(val) : val.strip.split(/\s*,\s*/)

• Read up
  Read up

Method process_include has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def process_include(attrs, elems, uri, allow_include = true)
        u = URI.parse(uri)
        if u.scheme == 'file' || u.path == uri  # file path
          path = u.path
          if path[0] != ?/

• Read up
  Read up

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

Open

      def self.parse(path)
        context = Kernel.binding

        unless context.respond_to?(:use_nil)
          context.define_singleton_method(:use_nil) do

• Read up
  Read up

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

Open

      def configure(conf)
        super

        if @extract_config
          @_extract_tag_key = @extract_config.tag_key

• Read up
  Read up

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

Open

    def initialize(type, format = nil, localtime = nil, timezone = nil, utc = nil, force_localtime = nil, fallbacks = [])

Method parse_plain has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def parse_plain(re, time, text, idx, record, capture_list, &block)

Method server_create_for_tls_connection has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def server_create_for_tls_connection(shared, bind, port, conf, backlog, socket_option_setter, &block)

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

Open

          def initialize(sock, max_bytes, flags, close_socket, log, under_plugin_development, &callback)

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

Open

          def initialize(sock, context, socket_option_setter, close_callback, log, under_plugin_development, connect_callback)

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

Open

        def initialize(title, interval, repeat, log, checker, detacher, &callback)

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

Open

    def configure(conf)
      super

      unless @as_secondary
        raise Fluent::ConfigError, "This plugin can only be used in the <secondary> section"

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    @ignore_list << p if @ignore_repeated_permission_error

Method read_messages has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def read_messages(conn, &block)
      feeder = nil
      serializer = nil
      bytes = 0
      conn.data do |data|

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                  if adding_bytes > @chunk_limit_size
                    errors << "concatenated/appended a #{adding_bytes} bytes record (nth: #{writing_splits_index}) is larger than buffer chunk limit size (#{@chunk_limit_size})"
                    writing_splits_index += 1
                    next
                  else

Method check_pong has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def check_pong(ri, message)
        @log.debug('checking pong')
        # ['PONG', bool(authentication result), 'reason if authentication failed',
        #  self_hostname, sha512\_hex(salt + self_hostname + nonce + sharedkey)]
        unless message.size == 5 && message[0] == 'PONG'

• Read up
  Read up