increment_num_errors

in lib/fluent/plugin/kinesis_helper/api.rb [210:223]

• 10 lines of code
• 5 McCabe index (conditional complexity)

          def increment_num_errors
            
            
            @num_errors ||= 0
            
            if Gem::Version.new(Fluent::VERSION) >= Gem::Version.new('1.7.0')
              @counter_mutex ||= Mutex.new
              @counter_mutex.synchronize{ @num_errors += 1 }
            else
              @counters_monitor ||= Monitor.new
              @counters_monitor.synchronize{ @num_errors += 1 }
            end
          end