Method enqueue_thread_run has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

      def enqueue_thread_run
        value_for_interval = nil
        if @flush_mode == :interval
          value_for_interval = @buffer_config.flush_interval
        end

• Read up
  Read up

Method configure has a Cognitive Complexity of 24 (exceeds 5 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."

• Read up
  Read up

Method fetch_compacted_entries has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

      def fetch_compacted_entries
        entries = {}

        @file.pos = 0
        file_pos = 0

• Read up
  Read up

Method try_flush has 82 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def try_flush
        chunk = @buffer.dequeue_chunk
        return unless chunk

        log.on_trace { log.trace "trying flush for a chunk", chunk: dump_unique_id_hex(chunk.unique_id) }

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

Open

    def configure(conf)
      used_worker_ids = []
      available_worker_ids = (0..Fluent::Engine.system_config.workers - 1).to_a
      # initialize <worker> elements
      conf.elements(name: 'worker').each do |e|

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

Open

      def configure(conf)
        super

        @variable_store = Fluent::VariableStore.fetch_or_build(:buf_file)

• Read up
  Read up

Method resume has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

      def resume
        stage = {}
        queue = []
        exist_broken_file = false

• Read up
  Read up

Method write_guard has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

      def write_guard(&block)
        begin
          block.call
        rescue Fluent::Plugin::Buffer::BufferOverflowError
          log.warn "failed to write data into buffer by buffer overflow", action: @buffer_config.overflow_action

• Read up
  Read up

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

Open

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

• Read up
  Read up

Method event has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    def event(level, args)
      time = Time.now
      message = @optional_header ? @optional_header.dup : ''
      map = @optional_attrs ? @optional_attrs.dup : {}
      args.each {|a|

• Read up
  Read up

Method child_process_execute has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

      def child_process_execute(
          title, command,
          arguments: nil, subprocess_name: nil, interval: nil, immediate: false, parallel: false,
          mode: [:read, :write], stderr: :discard, env: {}, unsetenv: false, chdir: nil,
          internal_encoding: 'utf-8', external_encoding: 'ascii-8bit', scrub: true, replace_string: nil,

• Read up
  Read up

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

Open

    def configure(conf)
      compat_parameters_convert(conf, :buffer, default_chunk_key: 'tag')

      super

Method cmp_variables has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

        def cmp_variables(v1, v2)
          if v1.nil? && v2.nil?
            return 0
          elsif v1.nil? # v2 is non-nil
            return -1

• Read up
  Read up

Method metadata has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

      def metadata(tag, time, record)
        # this arguments are ordered in output plugin's rule
        # Metadata 's argument order is different from this one (timekey, tag, variables)

        raise ArgumentError, "tag must be a String: #{tag.class}" unless tag.nil? || tag.is_a?(String)

• Read up
  Read up

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

Open

      def parse!(allow_include, elem_name = nil, attrs = {}, elems = [])
        while line = @iterator.next
          line.force_encoding('UTF-8')
          @i += 1
          line.lstrip!

• Read up
  Read up

File plugin_generator.rb has 294 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require "optparse"
require "pathname"
require "fileutils"
require "erb"
require "open-uri"

File fluentd.rb has 293 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'optparse'

require 'fluent/supervisor'
require 'fluent/log'
require 'fluent/env'

File child_process.rb has 291 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/plugin_helper/thread'
require 'fluent/plugin_helper/timer'
require 'fluent/clock'

require 'open3'

Method parse_element has 74 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def parse_element(root_element, elem_name, attrs = {}, elems = [])
        while true
          spacing
          if eof?
            if root_element

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

Open

    def configure(conf)
      @variable_store = Fluent::VariableStore.fetch_or_build(:in_tail)
      compat_parameters_convert(conf, :parser)
      parser_config = conf.elements('parse').first
      unless parser_config