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

Open

    def configure(conf)
      exec_filter_compat_parameters_convert!(conf)
      compat_parameters_convert(conf, :buffer)

      if inject_section = conf.elements('inject').first

• Read up
  Read up

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

• Read up
  Read up

Method shutdown has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

      def shutdown
        @_child_process_mutex.synchronize{ @_child_process_processes.keys }.each do |pid|
          process_info = @_child_process_processes[pid]
          next if !process_info
          process_info.writeio && process_info.writeio.close rescue nil

• Read up
  Read up

Method merge has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

      def merge(other) # self is base class, other is subclass
        return merge_for_finalized(other) if self.final?

        [:param_name, :required, :multi, :alias, :configured_in_section].each do |prohibited_name|
          if overwrite?(other, prohibited_name)

• Read up
  Read up

Method on_message has 64 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def on_message(msg, chunk_size, conn)
      if msg.nil?
        # for future TCP heartbeat_request
        return
      end

Method initialize has 64 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def initialize(pat)
      if pat.start_with?('/')
        if pat.end_with?('/')
          @regex = Regexp.new("\\A"+pat[1..-2]+"\\Z")
          return

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

Open

    def configure(conf)
      super

      regexp_and_conditions = {}
      regexp_or_conditions = {}

Class Supervisor has 23 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Supervisor
    def self.serverengine_config(params = {})
      # ServerEngine's "daemonize" option is boolean, and path of pid file is brought by "pid_path"
      pid_path = params['daemonize']
      daemonize = !!params['daemonize']

Class Element has 23 methods (exceeds 20 allowed). Consider refactoring.

Open

    class Element < Hash
      def initialize(name, arg, attrs, elements, unused = nil)
        @name = name
        @arg = arg
        @elements = elements

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

Open

      def configure(conf)
        super

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

Method extract_placeholders has 62 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def extract_placeholders(str, chunk)
        metadata = if chunk.is_a?(Fluent::Plugin::Buffer::Chunk)
                     chunk_passed = true
                     chunk.metadata
                   else

Method enqueue_all has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

      def enqueue_all(force_enqueue = false)
        log.on_trace { log.trace "enqueueing all chunks in buffer", instance: self.object_id }
        update_timekeys if @enable_update_timekeys

        if block_given?

• Read up
  Read up

Method establish_connection has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

      def establish_connection(sock, ri)
        while ri.state != :established
          begin
            # TODO: On Ruby 2.2 or earlier, read_nonblock doesn't work expectedly.
            # We need rewrite around here using new socket/server plugin helper.

• Read up
  Read up

Method run_once has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

      def run_once
        @mutex.synchronize do
          last_cleanup_at = (Time.now - CLEANUP_INTERVAL).to_i
          @mutex_hash.each do |(key, mutex)|
            v = @store.get(key, raw: true)

• Read up
  Read up

Method compat_parameters_inject has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

      def compat_parameters_inject(conf)
        return unless conf.elements('inject').empty?
        return if INJECT_PARAMS.keys.all?{|k| !conf.has_key?(k) }

        # TODO: warn obsolete parameters if these are deprecated

• Read up
  Read up

Method merge_for_finalized has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

      def merge_for_finalized(other)
        # list what subclass can do for finalized section
        #  * append params/defaults/sections which are missing in superclass
        #  * change default values of superclass
        #  * overwrite init to make it enable to instantiate section objects with added default values

• Read up
  Read up

Method expand_paths has 60 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def expand_paths
      date = Fluent::EventTime.now
      paths = []
      @paths.each { |path|
        path = if @path_timezone

File out_file.rb has 265 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fileutils'
require 'zlib'
require 'time'

require 'fluent/plugin/output'

File compat_parameters.rb has 265 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/config/types'
require 'fluent/config/element'

module Fluent
  module PluginHelper

File plugin_config_formatter.rb has 264 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require "erb"
require "optparse"
require "pathname"
require "fluent/plugin"
require "fluent/env"