Method write has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

  def write(record)
    unless secondary_record?(record)
      if record.class != Hash
        raise ArgumentError, "Input must be a map (got #{record.class})"
      end

• Read up
  Read up

Method update_retry_state has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def update_retry_state(chunk_id, using_secondary, error = nil)
        @retry_mutex.synchronize do
          @num_errors_metrics.inc
          chunk_id_hex = dump_unique_id_hex(chunk_id)

• Read up
  Read up

Method install_windows_event_handler has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def install_windows_event_handler
      return unless Fluent.windows?

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

• Read up
  Read up

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

Open

    def configure(conf)
      super

      # initialize <match> and <filter> elements
      conf.elements('filter', 'match').each { |e|

• Read up
  Read up

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

Open

    def start
      @thread = Thread.new do
        $log.disable_events(Thread.current)

        loop do

• Read up
  Read up

Method config_parameter_option_validate! has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def config_parameter_option_validate!(name, type, **kwargs, &block)
        if type.nil? && !block
          type = :string
        end
        kwargs.each_key do |key|

• Read up
  Read up

Method parameter_configuration has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def parameter_configuration(name, type = nil, **kwargs, &block)
        config_parameter_option_validate!(name, type, **kwargs, &block)

        name = name.to_sym

• Read up
  Read up

Method cert_option_server_validate! has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def cert_option_server_validate!(conf)
        case
        when conf.cert_path
          raise Fluent::ConfigError, "private_key_path is required when cert_path is specified" unless conf.private_key_path
          log.warn "For security reason, setting private_key_passphrase is recommended when cert_path is specified" unless conf.private_key_passphrase

• Read up
  Read up

Method collect_response has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def collect_response(select_interval)
        now = Fluent::Clock.now
        sockets = []
        results = []
        begin

Method main_process has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def main_process(&block)
      if @system_config.process_name
        if @system_config.workers > 1
          Process.setproctitle("worker:#{@system_config.process_name}#{ENV['SERVERENGINE_WORKER_ID']}")
        else

Method handle_stream_simple has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def handle_stream_simple(tag, es, enqueue: false)
        if @overrides_emit
          current_emit_count = @emit_count_metrics.get
          size = es.size
          key = data = nil

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

Method zero_downtime_restart has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def zero_downtime_restart
      Thread.new do
        @zero_downtime_restart_mutex.synchronize do
          $log.info "start zero-downtime-restart sequence"

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

Method dump_config_definition has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method message_handler has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def message_handler(data, sock)
      pri = nil
      text = data
      unless @parser_parse_priority
        m = SYSLOG_REGEXP.match(data)

Method read_lines has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def read_lines(lines)
          idx = @buffer.index(@eol)
          has_skipped_line = false

          until idx.nil?

Method compat_parameters_buffer has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def compat_parameters_buffer(conf, default_chunk_key: '')
        # return immediately if <buffer> section exists, or any buffer-related parameters don't exist
        return unless conf.elements('buffer').empty?
        return if (BUFFER_PARAMS.keys + BUFFER_TIME_SLICED_PARAMS.keys).all?{|k| !conf.has_key?(k) }

Method parameter_configuration has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def parameter_configuration(name, type = nil, **kwargs, &block)
        config_parameter_option_validate!(name, type, **kwargs, &block)

        name = name.to_sym

Method merge has 38 lines of code (exceeds 25 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)