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 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 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 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 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 81 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 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 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 get_monitor_info has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    def get_monitor_info(pe, opts={})
      obj = {}

      # Common plugin information
      obj['plugin_id'] = pe.plugin_id

• Read up
  Read up

Method parse_multilines has a Cognitive Complexity of 21 (exceeds 5 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

• Read up
  Read up

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

Open

    def configure(conf)
      super

      @connection_cache = Array.new(actual_flush_thread_count, ConnectionCache.new("", nil)) if @reuse_connections

• Read up
  Read up

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

Open

require 'optparse'

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

Method configure has 72 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