Class: Mongo::Server::Connection

# File 'lib/mongo/server/connection.rb', line 141

def connected?
  !closed? && !error? && !interrupted? && !!@socket
end

# File 'lib/mongo/server/connection.rb', line 173

def error?
  !!@error
end

# File 'lib/mongo/server/connection.rb', line 125

attr_reader :global_id

# File 'lib/mongo/server/connection.rb', line 121

attr_reader :id

# File 'lib/mongo/server/connection.rb', line 163

def interrupted?
  !!@interrupted
end

# File 'lib/mongo/server/connection.rb', line 115

attr_reader :last_checkin

# File 'lib/mongo/server/connection.rb', line 185

def pinned?
  !@pin_reasons.empty?
end

# File 'lib/mongo/server/connection.rb', line 133

def connection_pool
  options[:connection_pool]
end

# File 'lib/mongo/server/connection.rb', line 258

private def create_socket(context = nil)
  add_server_diagnostics do
    opts = ssl_options.merge(
      connection_address: address,
      connection_generation: generation,
      pipe: options[:pipe],
      connect_timeout: context&.remaining_timeout_sec,
      csot: !!context&.csot?
    )
    address.socket(socket_timeout, opts)
  end
end

# File 'lib/mongo/server/connection.rb', line 412

def deliver(message, client, options = {})
  handle_errors do
    super
  end
end

# File 'lib/mongo/server/connection.rb', line 311

def disconnect!(options = nil)
  # NOTE: @closed may be true here but we also may have a socket.
  # Check the socket and not @closed flag.
  @auth_mechanism = nil
  @last_checkin = nil
  if socket
    begin
      socket.close
    rescue StandardError
      nil
    end
    @socket = nil
  end
  @closed = true
  interrupted! if options && options[:interrupted]

  # To satisfy CMAP spec tests, publish close events even if the
  # socket was never connected (and thus the ready event was never
  # published). But track whether we published close event and do not
  # publish it multiple times, unless the socket was reconnected -
  # in that case publish the close event once per socket close.
  unless @close_event_published
    reason = options && options[:reason]
    publish_cmap_event(
      Monitoring::Event::Cmap::ConnectionClosed.new(
        address,
        id,
        reason
      )
    )
    @close_event_published = true
  end

  true
end

# File 'lib/mongo/server/connection.rb', line 276

private def do_connect
  raise_if_closed!
  begin
    pending_connection = PendingConnection.new(
      socket, @server, monitoring, options.merge(id: id)
    )
    pending_connection.handshake_and_authenticate!
  rescue Exception
    socket&.close
    @socket = nil
    raise
  end

  [ pending_connection.description, pending_connection.compressor ]
end

# File 'lib/mongo/server/connection.rb', line 418

def handle_errors
  yield
rescue Error::SocketError => e
  @error = e
  @server.unknown!(
    generation: e.generation,
    # or description.service_id?
    service_id: e.service_id,
    stop_push_monitor: true
  )
  raise
rescue Error::SocketTimeoutError => e
  @error = e
  raise
end

# File 'lib/mongo/server/connection.rb', line 168

def interrupted!
  @interrupted = true
end

# File 'lib/mongo/server/connection.rb', line 195

def pin(reason = :cursor)
  @pin_reasons << reason
end

# File 'lib/mongo/server/connection.rb', line 360

def ping
  ensure_connected do |socket|
    reply = add_server_diagnostics do
      socket.write(PING_OP_MSG_BYTES)
      Protocol::Message.deserialize(socket, max_message_size)
    end
    reply.documents[0][Operation::Result::OK] == 1
  end
end

# File 'lib/mongo/server/connection.rb', line 434

def raise_if_closed!
  if error?
    raise Error::ConnectionPerished,
          "Connection #{generation}:#{id} for #{address.seed} is perished. Reconnecting closed or errored connections is no longer supported"
  end

  return unless closed?

  raise Error::ConnectionPerished,
        "Connection #{generation}:#{id} for #{address.seed} is closed. Reconnecting closed or errored connections is no longer supported"
end

# File 'lib/mongo/server/connection.rb', line 389

def record_checkin!
  @last_checkin = Time.now
  self
end

# File 'lib/mongo/server/connection.rb', line 375

def socket_timeout
  @timeout ||= options[:socket_timeout]
end

# File 'lib/mongo/server/connection.rb', line 379

alias timeout socket_timeout

# File 'lib/mongo/server/connection.rb', line 399

def transport
  return nil if @socket.nil?

  case @socket
  when Mongo::Socket::Unix
    :unix
  else
    :tcp
  end
end

# File 'lib/mongo/server/connection.rb', line 205

def unpin(reason = :cursor)
  @pin_reasons.delete(reason)
end

# File 'lib/mongo/server/connection.rb', line 212

def unpin_all
  @pin_reasons.clear
end