Method start has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def start
      super

      log.info "listening udp socket", bind: @bind, port: @port
      server_create(:in_udp_server, @port, proto: :udp, bind: @bind, resolve_name: !!@source_hostname_key, max_bytes: @message_length_limit, receive_buffer_size: @receive_buffer_size) do |data, sock|

• Read up
  Read up

Method preprocess_map has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def preprocess_map(value, force_stringify = false)
        new_value = nil
        if value.is_a?(String)
          if @auto_typecast && !force_stringify
            num_placeholders = value.scan('${').size

• Read up
  Read up

Method synchronize has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def synchronize(*keys)
        return if keys.empty?

        locks = {}
        loop do

• Read up
  Read up

Method calc_next_time has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

        def calc_next_time
          if @forever || !@secondary # primary
            naive = naive_next_time(@steps)
            if @forever
              naive

• Read up
  Read up

Method compat_parameters_parser has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def compat_parameters_parser(conf)
        return unless conf.elements('parse').empty?
        return if PARSER_PARAMS.keys.all?{|k| !conf.has_key?(k) }

        # TODO: warn obsolete parameters if these are deprecated

• Read up
  Read up

Method cert_option_create_context has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def cert_option_create_context(version, insecure, ciphers, conf)
        cert, key, extra = cert_option_server_validate!(conf)

        ctx = OpenSSL::SSL::SSLContext.new
        # inject OpenSSL::SSL::SSLContext::DEFAULT_PARAMS

• Read up
  Read up

Method compat_parameters_extract has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def compat_parameters_extract(conf)
        return unless conf.elements('extract').empty?
        return if EXTRACT_PARAMS.keys.all?{|k| !conf.has_key?(k) } && !conf.has_key?('format')

        # TODO: warn obsolete parameters if these are deprecated

• Read up
  Read up

Method dump_config_definition has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def dump_config_definition
        dumped_config = {}
        if @argument
          argument_name, _block, options = @argument
          options[:required] = !@defaults.key?(argument_name)

• Read up
  Read up

Method try_tls_accept has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

          def try_tls_accept
            return true if @_handler_accepted

            begin
              result = @_handler_socket.accept_nonblock(exception: false) # this method call actually try to do handshake via TLS

• Read up
  Read up

Method scan_double_quoted_string has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

      def scan_double_quoted_string
        string = []
        while true
          if skip(/\"/)
            if string.include?(nil)

• Read up
  Read up

Method install_windows_event_handler has 52 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def install_windows_event_handler
      return unless Fluent.windows?

      @pid_signame = "fluentd_#{Process.pid}"
      @signame = config[:signame]

Method child_process_execute_once has 16 arguments (exceeds 4 allowed). Consider refactoring.

Open

          title, command, arguments, subprocess_name, mode, stderr, env, unsetenv, chdir,
          internal_encoding, external_encoding, scrub, replace_string, wait_timeout, on_exit_callback, &block

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

Open

    def configure(conf)
      super

      if @source_hostname_key
        # TODO: add test

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

Open

      def configure(conf)
        bufconf = CompatOutputUtils.buffer_section(conf)
        config_style = (bufconf ? :v1 : :v0)
        if config_style == :v0
          buf_params = {

Method handle_notify has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def handle_notify
          if limit_bytes_per_second_reached? || group_watcher&.limit_lines_reached?(@path)
            @metrics.throttled.inc
            return
          end

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

Open

      def parse(text, &block)
        loop do
          m =
            if @unmatched_lines
              @parser.call(text) do |time, record|

• Read up
  Read up

Method filter_stream has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

      def filter_stream(tag, es)
        new_es = MultiEventStream.new
        if @has_filter_with_time
          es.each do |time, record|
            begin

• Read up
  Read up

Method before_run has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def before_run
      @fluentd_conf = config[:fluentd_conf]
      @rpc_endpoint = nil
      @rpc_server = nil
      @counter = nil

• Read up
  Read up

Method parse_dot_array_op has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

        def self.parse_dot_array_op(key, param)
          start = key.index('[')
          result = if start.zero?
                     []
                   else

• Read up
  Read up

Method section_build has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

        def section_build(name, config, indent: 0, arg: nil)
          sb = SectionBodyBuilder.new(indent + @base_indent)

          if (v = config.delete('$type'))
            sb.add_line('@type', v)

• Read up
  Read up