Method checkout has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def checkout
        @mutex.synchronize do
          loop do
            if @queue.empty?
              return ServerSession.new

• Read up
  Read up

Method do_work has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def do_work
        scan!
        # @next_wanted_scan may be updated by the push monitor.
        # However we need to check for termination flag so that the monitor
        # thread exits when requested.

• Read up
  Read up

Method count has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

        def count(opts = {})
          opts = @options.merge(opts) unless Mongo.broken_view_options
          cmd = { :count => collection.name, :query => filter }
          cmd[:skip] = opts[:skip] if opts[:skip]
          cmd[:hint] = opts[:hint] if opts[:hint]

• Read up
  Read up

Method end_session has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def end_session
      if !ended? && @client
        if within_states?(TRANSACTION_IN_PROGRESS_STATE)
          begin
            abort_transaction

• Read up
  Read up

Method select! has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def select!
        if block_given?
          n_keys = keys.size
          keys.each do |key|
            delete(key) unless yield(key, self[key])

• Read up
  Read up

Method each has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def each
      if @cached_docs
        @cached_docs.each do |doc|
          yield doc
        end

• Read up
  Read up

Method serialize_fields has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def serialize_fields(buffer, max_bson_size = nil)
        fields.each do |field|
          value = instance_variable_get(field[:name])
          if field[:multi]
            value.each do |item|

• Read up
  Read up

Method initialize has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

        def initialize(command_name, database_name, address, request_id,
          operation_id, reply, duration, started_event:,
          server_connection_id: nil, service_id: nil

Method setopt_crypto_hooks has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def self.setopt_crypto_hooks(handle,
        aes_encrypt_cb, aes_decrypt_cb, random_cb,
        hmac_sha_512_cb, hmac_sha_256_cb, hmac_hash_cb

Method server_type has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def server_type
        return :load_balancer if load_balancer?
        return :arbiter if arbiter?
        return :ghost if ghost?
        return :sharded if mongos?

• Read up
  Read up

Method summarize_perf_data has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def summarize_perf_data(data)
        puts '===== Performance Results ====='
        data.each do |item|
          puts format('%s : %4.4g', item['info']['test_name'], item['metrics'][0]['value'])
          next unless item['metrics'].length > 1

• Read up
  Read up

Method check_bidi! has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def check_bidi!(out)
        if out.each_char.any? { |c| table_contains?(Tables::C8, c) }
          raise Mongo::Error::FailedStringPrepValidation.new(Error::FailedStringPrepValidation::INVALID_BIDIRECTIONAL)
        end

• Read up
  Read up

Method find_one_and_delete has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

        def find_one_and_delete(opts = {})
          with_session(opts) do |session|
            write_concern = if opts[:write_concern]
              WriteConcern.get(opts[:write_concern])
            else

• Read up
  Read up

Method check_invariants has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def check_invariants
        return unless Lint.enabled?

        # Server summary calls pool summary which requires pool lock -> deadlock.
        # Obtain the server summary ahead of time.

• Read up
  Read up

Method do_work has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def do_work
        @lock.synchronize do
          return if @stop_requested
        end

• Read up
  Read up

Method set_compressor! has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def set_compressor!(reply)
        server_compressors = reply['compression']

        if options[:compressors]
          if intersection = (server_compressors & options[:compressors])

• Read up
  Read up

Method set_server_list has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def set_server_list(server_address_strs)
      @sdam_flow_lock.synchronize do
        # If one of the new addresses is not in the current servers list,
        # add it to the servers list.
        server_address_strs.each do |address_str|

• Read up
  Read up

Method stop! has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def stop!
        @lock.synchronize do
          @stop_requested = true
          if @connection
            # Interrupt any in-progress exhausted hello reads by

• Read up
  Read up

Method command_failed has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def command_failed(failure, address, operation_id, payload, message, duration,
        started_event:, server_connection_id: nil, service_id: nil

Method initialize has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

        def initialize(command_name, database_name, address, request_id,
          operation_id, command, socket_object_id: nil, connection_id: nil,
          connection_generation: nil, server_connection_id: nil,
          service_id: nil