fluent/fluentd

View on GitHub

Showing 664 of 664 total issues

Method socket_option_validate! has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def socket_option_validate!(protocol, resolve_name: nil, linger_timeout: nil, recv_timeout: nil, send_timeout: nil, receive_buffer_size: nil, send_keepalive_packet: nil)
        unless resolve_name.nil?
          if protocol != :tcp && protocol != :udp && protocol != :tls
            raise ArgumentError, "BUG: resolve_name in available for tcp/udp/tls"
          end
Severity: Minor
Found in lib/fluent/plugin_helper/socket_option.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method build has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

          def self.build(get: nil, head: nil, post: nil, put: nil, patch: nil, delete: nil, connect: nil, options: nil, trace: nil)
            opt = { get: get, head: head, post: post, put: put, patch: patch, delete: delete, connect: connect, options: options, trace: trace }

            Class.new(WEBrick::HTTPServlet::AbstractServlet) do
              HttpServer::Methods::ALL.each do |name|
Severity: Minor
Found in lib/fluent/plugin_helper/http_server/compat/webrick_handler.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method config_build has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

        def config_build(config, indent: 0, root: false)
          sb = SectionBodyBuilder.new(indent, root: root)
          config.each do |c|
            if (lc = c.delete('label'))
              sb.add_section(label_build(lc, indent: indent))
Severity: Minor
Found in lib/fluent/config/yaml_parser/parser.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method after_shutdown has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def after_shutdown
        timeout_at = Fluent::Clock.now + EVENT_LOOP_SHUTDOWN_TIMEOUT
        @_event_loop_mutex.synchronize do
          @_event_loop.watchers.reverse_each do |w|
            begin
Severity: Minor
Found in lib/fluent/plugin_helper/event_loop.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method child_process_kill has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def child_process_kill(pinfo, force: false)
        return if !pinfo
        pinfo.killed_at = Fluent::Clock.now unless force

        pid = pinfo.pid
Severity: Minor
Found in lib/fluent/plugin_helper/child_process.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method compat_parameters_copy_to_subsection_attributes has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def compat_parameters_copy_to_subsection_attributes(conf, params, &block)
        hash = {}
        params.each do |compat, current|
          next unless current
          if conf.has_key?(compat)
Severity: Minor
Found in lib/fluent/plugin_helper/compat_parameters.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method thread_wait_until_stop has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def thread_wait_until_stop
        timeout_at = Fluent::Clock.now + THREAD_SHUTDOWN_HARD_TIMEOUT_IN_TESTS
        until @_threads_mutex.synchronize{ @_threads.values.reduce(true){|r,t| r && !t[:_fluentd_plugin_helper_thread_running] } }
          break if Fluent::Clock.now > timeout_at
          sleep 0.1
Severity: Minor
Found in lib/fluent/plugin_helper/thread.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method thread_create has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def thread_create(title)
        raise ArgumentError, "BUG: title must be a symbol" unless title.is_a? Symbol
        raise ArgumentError, "BUG: callback not specified" unless block_given?
        m = Mutex.new
        m.lock
Severity: Minor
Found in lib/fluent/plugin_helper/thread.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method inject_values_to_event_stream has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

      def inject_values_to_event_stream(tag, es)
        return es unless @_inject_enabled

        new_es = Fluent::MultiEventStream.new
        es.each do |time, record|
Severity: Minor
Found in lib/fluent/plugin_helper/inject.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method method_missing has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
Open

        def method_missing(name, *args, &block)
          ::Kernel.raise ::ArgumentError, "Configuration DSL Syntax Error: only one argument allowed" if args.size > 1
          value = args.first

          if block
Severity: Minor
Found in lib/fluent/config/dsl.rb - About 1 hr to fix

Cognitive Complexity

Cognitive Complexity is a measure of how difficult a unit of code is to intuitively understand. Unlike Cyclomatic Complexity, which determines how difficult your code will be to test, Cognitive Complexity tells you how difficult your code will be to read and comprehend.

A method's cognitive complexity is based on a few simple rules:

  • Code is not considered more complex when it uses shorthand that the language provides for collapsing multiple statements into one
  • Code is considered more complex for each "break in the linear flow of the code"
  • Code is considered more complex when "flow breaking structures are nested"

Further reading

Method metadata has 27 lines of code (exceeds 25 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)
Severity: Minor
Found in lib/fluent/plugin/output.rb - About 1 hr to fix

    Method filter_one_record has 27 lines of code (exceeds 25 allowed). Consider refactoring.
    Open

        def filter_one_record(tag, time, record, raw_value)
          begin
            @parser.parse(raw_value) do |t, values|
              if values
                t = if @reserve_time
    Severity: Minor
    Found in lib/fluent/plugin/filter_parser.rb - About 1 hr to fix

      Method parse_rfc3164_regex has 27 lines of code (exceeds 25 allowed). Consider refactoring.
      Open

            def parse_rfc3164_regex(text, &block)
              idx = 0
              record = {}
      
              if @with_priority
      Severity: Minor
      Found in lib/fluent/plugin/parser_syslog.rb - About 1 hr to fix

        Method filter_stream has 27 lines of code (exceeds 25 allowed). Consider refactoring.
        Open

            def filter_stream(tag, es)
              new_es = Fluent::MultiEventStream.new
              tag_parts = tag.split('.')
              tag_prefix = tag_prefix(tag_parts)
              tag_suffix = tag_suffix(tag_parts)
        Severity: Minor
        Found in lib/fluent/plugin/filter_record_transformer.rb - About 1 hr to fix

          Method build_spawn_command has 27 lines of code (exceeds 25 allowed). Consider refactoring.
          Open

              def build_spawn_command
                if ENV['TEST_RUBY_PATH']
                  fluentd_spawn_cmd = [ENV['TEST_RUBY_PATH']]
                else
                  fluentd_spawn_cmd = [ServerEngine.ruby_bin_path]
          Severity: Minor
          Found in lib/fluent/supervisor.rb - About 1 hr to fix

            Method synchronize has 27 lines of code (exceeds 25 allowed). Consider refactoring.
            Open

                  def synchronize(*keys)
                    return if keys.empty?
            
                    locks = {}
                    loop do
            Severity: Minor
            Found in lib/fluent/counter/mutex_hash.rb - About 1 hr to fix

              Identical blocks of code found in 2 locations. Consider refactoring.
              Open

                      def file_rename(file, old_path, new_path, callback = nil)
                        pos = file.pos
                        if Fluent.windows?
                          file.close
                          File.rename(old_path, new_path)
              Severity: Major
              Found in lib/fluent/plugin/buffer/file_single_chunk.rb and 1 other location - About 1 hr to fix
              lib/fluent/plugin/buffer/file_chunk.rb on lines 261..275

              Duplicated Code

              Duplicated code can lead to software that is hard to understand and difficult to change. The Don't Repeat Yourself (DRY) principle states:

              Every piece of knowledge must have a single, unambiguous, authoritative representation within a system.

              When you violate DRY, bugs and maintenance problems are sure to follow. Duplicated code has a tendency to both continue to replicate and also to diverge (leaving bugs as two similar implementations differ in subtle ways).

              Tuning

              This issue has a mass of 49.

              We set useful threshold defaults for the languages we support but you may want to adjust these settings based on your project guidelines.

              The threshold configuration represents the minimum mass a code block must have to be analyzed for duplication. The lower the threshold, the more fine-grained the comparison.

              If the engine is too easily reporting duplication, try raising the threshold. If you suspect that the engine isn't catching enough duplication, try lowering the threshold. The best setting tends to differ from language to language.

              See codeclimate-duplication's documentation for more information about tuning the mass threshold in your .codeclimate.yml.

              Refactorings

              Further Reading

              Identical blocks of code found in 2 locations. Consider refactoring.
              Open

                      def file_rename(file, old_path, new_path, callback=nil)
                        pos = file.pos
                        if Fluent.windows?
                          file.close
                          File.rename(old_path, new_path)
              Severity: Major
              Found in lib/fluent/plugin/buffer/file_chunk.rb and 1 other location - About 1 hr to fix
              lib/fluent/plugin/buffer/file_single_chunk.rb on lines 224..238

              Duplicated Code

              Duplicated code can lead to software that is hard to understand and difficult to change. The Don't Repeat Yourself (DRY) principle states:

              Every piece of knowledge must have a single, unambiguous, authoritative representation within a system.

              When you violate DRY, bugs and maintenance problems are sure to follow. Duplicated code has a tendency to both continue to replicate and also to diverge (leaving bugs as two similar implementations differ in subtle ways).

              Tuning

              This issue has a mass of 49.

              We set useful threshold defaults for the languages we support but you may want to adjust these settings based on your project guidelines.

              The threshold configuration represents the minimum mass a code block must have to be analyzed for duplication. The lower the threshold, the more fine-grained the comparison.

              If the engine is too easily reporting duplication, try raising the threshold. If you suspect that the engine isn't catching enough duplication, try lowering the threshold. The best setting tends to differ from language to language.

              See codeclimate-duplication's documentation for more information about tuning the mass threshold in your .codeclimate.yml.

              Refactorings

              Further Reading

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

                    def configure(conf)
                      super
              
                      unless @queue_limit_length.nil?
                        @total_limit_size = @chunk_limit_size * @queue_limit_length
              Severity: Minor
              Found in lib/fluent/plugin/buffer.rb - About 1 hr to fix

                Method <=> has 26 lines of code (exceeds 25 allowed). Consider refactoring.
                Open

                        def <=>(o)
                          timekey2 = o.timekey
                          tag2 = o.tag
                          variables2 = o.variables
                          if (!!timekey ^ !!timekey2) || (!!tag ^ !!tag2) || (!!variables ^ !!variables2)
                Severity: Minor
                Found in lib/fluent/plugin/buffer.rb - About 1 hr to fix
                  Severity
                  Category
                  Status
                  Source
                  Language