fluent/fluentd

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

Open

    def configure(conf)
      compat_parameters_convert(conf, :parser)

      super

Method fetch_compacted_entries has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def fetch_compacted_entries
        entries = {}

        @file.pos = 0
        file_pos = 0

Method parse has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def self.parse(str, fname, basepath = Dir.pwd, v1_config = nil, syntax: :v1)
      parser = if fname =~ /\.rb$/ || syntax == :ruby
                 :ruby
               elsif v1_config.nil?
                 case syntax

Method calc_next_time has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method format= has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def format=(fmt)
      return if @format == fmt

      @time_format = '%Y-%m-%d %H:%M:%S %z'
      @time_formatter = Strftime.new(@time_format) rescue nil

Method shutdown has 26 lines of code (exceeds 25 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

Method reload_config has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def reload_config(conf, supervisor: false)
      @root_agent_mutex.synchronize do
        # configure first to reduce down time while restarting
        new_agent = RootAgent.new(log: log, system_config: @system_config)
        ret = Fluent::StaticConfigAnalysis.call(conf, workers: system_config.workers)

Method scan_double_quoted_string has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Consider simplifying this complex logical expression.

Open

          if (!!timekey ^ !!timekey2) || (!!tag ^ !!tag2) || (!!variables ^ !!variables2)
            # One has value in a field, but another doesn't have value in same field
            # This case occurs very rarely
            if timekey == timekey2 # including the case of nil == nil
              if tag == tag2

Method expand has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

        def expand(__str_to_eval__, tag, time, record, tag_parts, tag_prefix, tag_suffix, hostname)

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    config_section :and, param_name: :and_conditions, multi: true do
      config_section :regexp, param_name: :regexps, multi: true do
        desc "The field name to which the regular expression is applied."
        config_param :key, :string
        desc "The regular expression."

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

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

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    config_section :or, param_name: :or_conditions, multi: true do
      config_section :regexp, param_name: :regexps, multi: true do
        desc "The field name to which the regular expression is applied."
        config_param :key, :string
        desc "The regular expression."

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

        if conf.has_key?('localtime') || conf.has_key?('utc')
          if conf.has_key?('localtime') && conf.has_key?('utc')
            raise Fluent::ConfigError, "both of utc and localtime are specified, use only one of them"
          elsif conf.has_key?('localtime')
            inject_params['localtime'] = Fluent::Config.bool_value(conf['localtime'])

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

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

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

        if conf.has_key?('localtime') || conf.has_key?('utc')
          if conf.has_key?('localtime') && conf.has_key?('utc')
            raise Fluent::ConfigError, "both of utc and localtime are specified, use only one of them"
          elsif conf.has_key?('localtime')
            hash['localtime'] = Fluent::Config.bool_value(conf['localtime'])

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

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

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

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

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

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

• Read up
  Read up

Similar blocks of code found in 6 locations. 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